beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (a724602 -> 24179c3)
Date Fri, 22 Jan 2021 03:59:14 GMT
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 a724602  (commit)
      to 24179c3  (commit)
    from a724602  [BEAM-11659]: Add DlqProvider, a way of handling failures in a generic way.
(#13773)
     add e8eed0b  [BEAM-11325] ReadFromKafkaDoFn should stop reading when topic/partition
is removed or marked as stopped.
     add d2e1f69  Merge pull request #13710 from [BEAM-11325] ReadFromKafkaDoFn should stop
reading when topic/partition is removed or marked as stopped
     add 61ea255  [BEAM-11092][Go SDK] Ack Harness monitoring requests (#13788)
     add a9e31ba  [BEAM-10961] Enabled strict dependencies on samza (#13667)
     add 0f6af9b  [BEAM-11200] Update Go SDK version on release. (#13789)
     add 014c76c  [BEAM-10890] Log error counts to debug BigQuery streaming insert requests
for Java SDK
     add 171ba9d  add API_REQUEST_LATENCIES, match by MetricName
     add b44d928  fix encoding error in windows
     add cd13f6e  Merge pull request #12852 from ihji/BEAM-10890
     add e8fcb74  Remove boilerplate notes from 2.27.0
     add 24179c3  Merge pull request #13790 from Remove boilerplate notes from 2.27.0

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |  15 -
 model/pipeline/src/main/proto/metrics.proto        |  28 +-
 release/src/main/scripts/cut_release_branch.sh     |   6 +-
 .../runners/core/metrics/MetricsContainerImpl.java |  25 +-
 .../core/metrics/MonitoringInfoConstants.java      |   6 +
 runners/samza/build.gradle                         |  21 +-
 runners/samza/job-server/build.gradle              |   2 +
 .../task/task.go => sdks/go/pkg/beam/core/core.go  |  25 +-
 sdks/go/pkg/beam/core/runtime/harness/harness.go   |  10 +
 .../pkg/beam/runners/dataflow/dataflowlib/job.go   |   5 +-
 .../org/apache/beam/sdk/metrics/MetricsLogger.java |   8 +-
 .../LatencyRecordingHttpRequestInitializer.java    |   7 +-
 .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java  |  49 ++-
 .../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java |  37 ++-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  36 ++-
 .../beam/sdk/io/kafka/ReadFromKafkaDoFn.java       |  43 ++-
 .../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java   | 344 +++++++++++++++++++++
 17 files changed, 598 insertions(+), 69 deletions(-)
 copy learning/katas/go/core_transforms/combine/combine_perkey/pkg/task/task.go => sdks/go/pkg/beam/core/core.go
(58%)
 create mode 100644 sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java


Mime
View raw message