This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from d0206f57ea2 Merge pull request #32735 from
ffernandez92/beam-yaml-proto-bp
add 3ce219434a3 Update generate_pydoc.sh
add df3c45d58d7 Merge pull request #32903 from apache/liferoad-patch-1
add 68b600dc779 Doc fixes after 2.60 release (#32908)
add 0ee13b2865b Kafka metrics (#32402)
add d3478f1e386 Bump google.golang.org/api from 0.199.0 to 0.202.0 in
/sdks (#32906)
add 7ac462ef8e2 Bump cloud.google.com/go/storage from 1.44.0 to 1.45.0 in
/sdks (#32854)
add 172a0298c55 Fix JavaPreCommit on Java11 (#32912)
add d8c3ede4f5f Test fix after runner bump to Java11 (#32909)
add 135a5be0877 Increase RemoteExecutionTest sdk start timeout, caused
flaky failure. (#32882)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 1 +
contributor-docs/release-guide.md | 10 +-
.../google-cloud-dataflow-java/worker/build.gradle | 1 +
.../MetricsToPerStepNamespaceMetricsConverter.java | 9 +-
.../dataflow/worker/StreamingDataflowWorker.java | 5 +
.../dataflow/worker/streaming/StageInfo.java | 5 +-
.../worker/StreamingStepMetricsContainerTest.java | 39 +++++-
.../fnexecution/control/RemoteExecutionTest.java | 2 +-
.../apache/beam/runners/prism/PrismExecutor.java | 12 ++
.../beam/runners/prism/PrismExecutorTest.java | 13 +-
.../TestSamzaRunnerWithTransformMetrics.java | 3 +
.../runners/samza/runtime/GroupByKeyOpTest.java | 10 ++
.../runtime/SamzaStoreStateInternalsTest.java | 8 ++
sdks/go.mod | 17 ++-
sdks/go.sum | 40 +++----
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 10 +-
.../apache/beam/sdk/io/gcp/firestore/RpcQos.java | 3 +-
.../beam/sdk/io/gcp/firestore/RpcQosImpl.java | 4 +-
.../pubsub/PubsubReadSchemaTransformProvider.java | 11 +-
.../pubsub/PubsubWriteSchemaTransformProvider.java | 11 +-
.../PubsubLiteReadSchemaTransformProvider.java | 17 +--
.../PubsubLiteWriteSchemaTransformProvider.java | 17 +--
.../SpannerReadSchemaTransformProvider.java | 17 +--
.../SpannerWriteSchemaTransformProvider.java | 16 +--
...erChangestreamsReadSchemaTransformProvider.java | 16 +--
.../gcp/firestore/BaseFirestoreV1WriteFnTest.java | 39 +++---
...storeV1FnBatchWriteWithDeadLetterQueueTest.java | 2 +-
.../FirestoreV1FnBatchWriteWithSummaryTest.java | 2 +-
.../sdk/io/gcp/firestore/RpcQosSimulationTest.java | 2 +-
.../beam/sdk/io/gcp/firestore/RpcQosTest.java | 6 +-
.../org/apache/beam/sdk/io/kafka/KafkaMetrics.java | 131 +++++++++++++++++++++
.../apache/beam/sdk/io/kafka/KafkaSinkMetrics.java | 89 ++++++++++++++
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 32 ++++-
.../apache/beam/sdk/io/kafka/KafkaMetricsTest.java | 129 ++++++++++++++++++++
.../beam/sdk/io/kafka/KafkaSinkMetricsTest.java} | 26 ++--
sdks/java/javadoc/build.gradle | 2 +-
sdks/python/scripts/generate_pydoc.sh | 1 -
37 files changed, 583 insertions(+), 175 deletions(-)
create mode 100644
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaMetrics.java
create mode 100644
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaSinkMetrics.java
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaMetricsTest.java
copy
sdks/java/{core/src/test/java/org/apache/beam/sdk/util/construction/ReshuffleTranslationTest.java
=>
io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaSinkMetricsTest.java}
(61%)
