From commits-return-114524-archive-asf-public=cust-asf.ponee.io@beam.apache.org Tue Aug 3 03:26:04 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id C28D9180621 for ; Tue, 3 Aug 2021 05:26:04 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id 0F0FD3FAFC for ; Tue, 3 Aug 2021 03:26:04 +0000 (UTC) Received: (qmail 55650 invoked by uid 500); 3 Aug 2021 03:26:03 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 55636 invoked by uid 99); 3 Aug 2021 03:26:03 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 03 Aug 2021 03:26:03 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 77E5A81F23; Tue, 3 Aug 2021 03:26:03 +0000 (UTC) Date: Tue, 03 Aug 2021 03:25:51 +0000 To: "commits@beam.apache.org" Subject: [beam] tag nightly-master updated (dce846b -> 7b54b0b) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162796114669.19685.2939099845311178098@gitbox.apache.org> From: github-bot@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: beam X-Git-Refname: refs/tags/nightly-master X-Git-Reftype: tag X-Git-Oldrev: dce846b36a4fb9140c4c5d14e10b72f835f03d98 X-Git-Newrev: 7b54b0bd3dac0fe59a11294217be969d0c03da86 X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to tag nightly-master in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag nightly-master was modified! *** from dce846b (commit) to 7b54b0b (commit) from dce846b Merge pull request #15247: [BEAM-12686] Enable self-managed relative timers add 8bd1e20 Ensure timer consistency in Dataflow and portable runners add 7b54b0b Merge pull request #15123: Ensure timer consistency in runners No new revisions were added by this update. Summary of changes: .../apache/beam/runners/core/TimerInternals.java | 1 + runners/direct-java/build.gradle | 2 + runners/google-cloud-dataflow-java/build.gradle | 2 - .../worker/StreamingModeExecutionContext.java | 129 ++++++++--- .../dataflow/worker/WindmillTimerInternals.java | 47 ++-- ...sesStatefulParDo.java => UsesLoopingTimer.java} | 4 +- .../sdk/transforms/reflect/DoFnSignatures.java | 3 +- .../org/apache/beam/sdk/transforms/ParDoTest.java | 77 ++++--- .../apache/beam/fn/harness/FnApiDoFnRunner.java | 175 ++++++++++----- .../fn/harness/state/FnApiTimerBundleTracker.java | 224 +++++++++++++++++++ .../beam/fn/harness/FnApiDoFnRunnerTest.java | 238 +++++++++++---------- 11 files changed, 636 insertions(+), 266 deletions(-) copy sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesStatefulParDo.java => UsesLoopingTimer.java} (88%) create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiTimerBundleTracker.java