Skip to content

Commit 7e78d7f

Browse files
authored
explicit sql timeout CopySpacePost (#1811)
Signed-off-by: qGYdXbY2 <47661341+qGYdXbY2@users.noreply.github.com>
1 parent cf978c7 commit 7e78d7f

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

  • xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport

xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/CopySpacePost.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ public class CopySpacePost extends SpaceBasedStep<CopySpacePost> {
5252
public static final String STATISTICS = "statistics";
5353
private static final Logger logger = LogManager.getLogger();
5454

55+
private static final int STATEMENT_TIMEOUT = 895;
56+
5557
@JsonView({Internal.class, Static.class})
5658
private boolean skipCounts = false;
5759

@@ -156,6 +158,7 @@ select count(1), coalesce( sum( (coalesce(pg_column_size(jsondata),0) + coalesce
156158
""")
157159
.withVariable("schema", targetSchema)
158160
.withVariable("table", targetTable)
161+
.withTimeout(STATEMENT_TIMEOUT)
159162
.withQueryFragment("fetchedVersion", "" + fetchedVersion);
160163

161164
FeatureStatistics statistics = runReadQuerySync(incVersionSql, db(), 0, rs -> rs.next()

0 commit comments

Comments
 (0)