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
