diff --git a/apm-collector/apm-collector-cache/src/main/java/org/skywalking/apm/collector/cache/dao/InstanceH2CacheDAO.java b/apm-collector/apm-collector-cache/src/main/java/org/skywalking/apm/collector/cache/dao/InstanceH2CacheDAO.java index 7ff94b3e7da475270bc15438d1e55df22ea7b0b5..696ceac56e8d0f2b5d13a07845606ede516eb85a 100644 --- a/apm-collector/apm-collector-cache/src/main/java/org/skywalking/apm/collector/cache/dao/InstanceH2CacheDAO.java +++ b/apm-collector/apm-collector-cache/src/main/java/org/skywalking/apm/collector/cache/dao/InstanceH2CacheDAO.java @@ -40,7 +40,7 @@ public class InstanceH2CacheDAO extends H2DAO implements IInstanceCacheDAO { @Override public int getApplicationId(int applicationInstanceId) { logger.info("get the application id with application id = {}", applicationInstanceId); H2Client client = getClient(); - String sql = SqlBuilder.buildSql(GET_APPLICATION_ID_SQL, InstanceTable.COLUMN_APPLICATION_ID, InstanceTable.TABLE, InstanceTable.COLUMN_APPLICATION_ID); + String sql = SqlBuilder.buildSql(GET_APPLICATION_ID_SQL, InstanceTable.COLUMN_APPLICATION_ID, InstanceTable.TABLE, InstanceTable.COLUMN_INSTANCE_ID); Object[] params = new Object[] {applicationInstanceId}; try (ResultSet rs = client.executeQuery(sql, params)) { if (rs.next()) {