Repository: incubator-beam Updated Branches: refs/heads/master d75e9df50 -> ac314eefd
IntervalBoundedExponentialBackOff: add deprecated copy of old API This fixes a bug submitting jobs to Google Cloud Dataflow service. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c4862c0e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c4862c0e Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c4862c0e Branch: refs/heads/master Commit: c4862c0ea08b664c55a885b64039f4a4be16022a Parents: d75e9df Author: Dan Halperin <dhalp...@google.com> Authored: Mon Apr 4 14:40:00 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Apr 4 15:24:43 2016 -0700 ---------------------------------------------------------------------- .../dataflow/sdk/util/IntervalBoundedExponentialBackOff.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c4862c0e/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java b/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java index 51ff9f2..206c83b 100644 --- a/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java +++ b/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java @@ -54,6 +54,12 @@ public class IntervalBoundedExponentialBackOff implements BackOff { private final long initialIntervalMillis; private int currentAttempt; + // BEAM-168: https://issues.apache.org/jira/browse/BEAM-168 + @Deprecated + public IntervalBoundedExponentialBackOff(int maximumIntervalMillis, long initialIntervalMillis) { + this((long) maximumIntervalMillis, initialIntervalMillis); + } + public IntervalBoundedExponentialBackOff(long maximumIntervalMillis, long initialIntervalMillis) { Preconditions.checkArgument( maximumIntervalMillis > 0, "Maximum interval must be greater than zero.");
