This is an automated email from the ASF dual-hosted git repository.
suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 75684ca [GOBBLIN-1415] HotFix to make default timeout of writer to be
Long.MAX_VALUE
75684ca is described below
commit 75684ca8cc0bd968208a4a6e25978460cd663cb6
Author: Zihan Li <[email protected]>
AuthorDate: Mon Mar 22 11:04:30 2021 -0700
[GOBBLIN-1415] HotFix to make default timeout of writer to be Long.MAX_VALUE
Closes #3249 from ZihanLi58/GOBBLIN-1415-new
---
.../src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
b/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
index 3c95a6b..16b9365 100644
---
a/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
+++
b/gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java
@@ -83,7 +83,7 @@ public class PartitionedDataWriter<S, D> extends
WriterWrapper<D> implements Fin
public static final String PARTITIONED_WRITER_CACHE_TTL_SECONDS =
"partitionedDataWriter.cache.ttl.seconds";
public static final Long DEFAULT_PARTITIONED_WRITER_CACHE_TTL_SECONDS =
Long.MAX_VALUE;
public static final String PARTITIONED_WRITER_WRITE_TIMEOUT_SECONDS =
"partitionedDataWriter.write.timeout.seconds";
- public static final Long DEFAULT_PARTITIONED_WRITER_WRITE_TIMEOUT_SECONDS =
480L;
+ public static final Long DEFAULT_PARTITIONED_WRITER_WRITE_TIMEOUT_SECONDS =
Long.MAX_VALUE;
private static final GenericRecord NON_PARTITIONED_WRITER_KEY =
new
GenericData.Record(SchemaBuilder.record("Dummy").fields().endRecord());