(beam) branch master updated: [Dataflow Streaming] Increase stuck commit invalidation timeout to 1 hour (#39083)

[scwhittle]

This is an automated email from the ASF dual-hosted git repository.

scwhittle pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new c3d9a731b42 [Dataflow Streaming] Increase stuck commit invalidation 
timeout to 1 hour (#39083)
c3d9a731b42 is described below

commit c3d9a731b42ec54343347affcb6f558db616a642
Author: Arun Pandian <pandi...@google.com>
AuthorDate: Wed Jun 24 02:20:48 2026 -0700

    [Dataflow Streaming] Increase stuck commit invalidation timeout to 1 hour 
(#39083)
---
 .../beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java
 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java
index 90375ad445a..0897e526382 100644
--- 
a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java
+++ 
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java
@@ -191,7 +191,7 @@ public interface DataflowStreamingPipelineOptions extends 
PipelineOptions {
   void setMaxStackTraceDepthToReport(int value);
 
   @Description("Necessary duration for a commit to be considered stuck and 
invalidated.")
-  @Default.Integer(10 * 60 * 1000)
+  @Default.Integer(60 * 60 * 1000)
   int getStuckCommitDurationMillis();
 
   void setStuckCommitDurationMillis(int value);