You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ap...@apache.org on 2022/10/11 22:37:35 UTC

[beam] branch master updated (3ffdf8dce61 -> 98eeac75159)

This is an automated email from the ASF dual-hosted git repository.

apilloud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 3ffdf8dce61 Remove obsolete and deprecated bigquery native read. (#23557)
     add 98eeac75159 Feature/name all java threads (#23387)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                                       | 1 +
 .../beam/runners/dataflow/worker/DataflowRunnerHarness.java      | 8 +++++++-
 .../worker/FetchAndFilterStreamingSideInputsOperation.java       | 8 +++++++-
 .../org/apache/beam/runners/dataflow/worker/util/JfrInterop.java | 5 ++++-
 .../runners/dataflow/worker/windmill/GrpcWindmillServer.java     | 8 +++++++-
 .../runners/fnexecution/control/BundleCheckpointHandlers.java    | 2 +-
 .../control/ReferenceCountingExecutableStageContextFactory.java  | 7 ++++++-
 .../fnexecution/environment/EmbeddedEnvironmentFactory.java      | 8 +++++++-
 .../structuredstreaming/SparkStructuredStreamingRunner.java      | 5 ++++-
 .../structuredstreaming/SparkStructuredStreamingRunner.java      | 5 ++++-
 .../java/org/apache/beam/runners/spark/SparkPipelineRunner.java  | 8 +++++++-
 .../org/apache/beam/fn/harness/jmh/ProcessBundleBenchmark.java   | 6 +++++-
 .../apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java    | 8 +++++++-
 .../java/org/apache/beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 9 ++++++++-
 .../java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java  | 8 +++++++-
 15 files changed, 82 insertions(+), 14 deletions(-)