Skip to content

Commit

Permalink
fix: possible out of memory error
Browse files Browse the repository at this point in the history
  • Loading branch information
klopfdreh committed Jul 24, 2023
1 parent 9c77238 commit 5027ce8
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -61,9 +61,9 @@ public class JdbcDataflowTaskExecutionMetadataDao implements DataflowTaskExecuti
"task_execution_manifest) VALUES (:id, :taskExecutionId, :taskExecutionManifest)";

private static final String FIND_MANIFEST_BY_TASK_EXECUTION_ID = "select m.task_execution_manifest as task_execution_manifest " +
"from task_execution_metadata m inner join " +
"TASK_EXECUTION e on m.task_execution_id = e.TASK_EXECUTION_ID " +
"where e.TASK_EXECUTION_ID = :taskExecutionId";
"from task_execution_metadata m, TASK_EXECUTION e " +
"where m.task_execution_id = e.TASK_EXECUTION_ID " +
"and e.TASK_EXECUTION_ID = :taskExecutionId";

private static final String DELETE_MANIFEST_BY_TASK_EXECUTION_IDS =
"DELETE FROM task_execution_metadata " +
Expand Down

0 comments on commit 5027ce8

Please sign in to comment.