This is an automated email from the ASF dual-hosted git repository.
xinyu 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 14ca840f346 Change the type of Samza Runner MaxBundleSize pipeline
option to match with Flink Runner (#25854)
14ca840f346 is described below
commit 14ca840f3462aa9ba3ebbe773b498d4a914d50aa
Author: Xinyu Liu <[email protected]>
AuthorDate: Wed Mar 15 17:11:47 2023 -0700
Change the type of Samza Runner MaxBundleSize pipeline option to match with
Flink Runner (#25854)
---
.../java/org/apache/beam/runners/samza/SamzaPipelineOptions.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java
b/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java
index 9dd5234c35b..46066cb3027 100644
---
a/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java
+++
b/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java
@@ -125,15 +125,15 @@ public interface SamzaPipelineOptions extends
PipelineOptions {
@Description("The maximum number of elements in a bundle.")
@Default.Long(1)
- long getMaxBundleSize();
+ Long getMaxBundleSize();
- void setMaxBundleSize(long maxBundleSize);
+ void setMaxBundleSize(Long maxBundleSize);
@Description("The maximum time to wait before finalising a bundle (in
milliseconds).")
@Default.Long(1000)
- long getMaxBundleTimeMs();
+ Long getMaxBundleTimeMs();
- void setMaxBundleTimeMs(long maxBundleTimeMs);
+ void setMaxBundleTimeMs(Long maxBundleTimeMs);
@Description(
"Wait if necessary for completing a remote bundle processing for at most
the given time (in milliseconds). if the value of timeout is negative, wait
forever until the bundle processing is completed. Used only in portable mode
for now.")
