diff --git standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java index 80d2111..5b67a25 100644 --- standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -12674,7 +12674,7 @@ ObjectStoreTestHook.onScheduledQueryPoll(); commited = commitTransaction(); ret.setScheduleKey(schq.getScheduleKey()); - ret.setQuery(schq.getQuery()); + ret.setQuery("/* schedule: " + schq.getScheduleName() + " */" + schq.getQuery()); ret.setUser(schq.getUser()); int executionId = ((IntIdentity) pm.getObjectId(execution)).getKey(); ret.setExecutionId(executionId);