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 be6216357bd Clean up integration test manual run parameters (#31938)
add c0f6ac980ba PubsubMessageWithTopicCoder.of() is returning wrong coder
(#31619)
add 1284986ed05 Modify casing in workflow (#31911)
add 12ad2afd2d6 Use default auth for Iceberg integration tests (#31940)
add bdd5fff78c8 [Prism] Implement PrismPipelineResult (#31937)
No new revisions were added by this update.
Summary of changes:
.../IO_Iceberg_Integration_Tests.json | 2 +-
.../beam_PostCommit_Java_SingleStoreIO_IT.yml | 4 +-
runners/prism/java/build.gradle | 2 +
.../apache/beam/runners/prism/PrismExecutor.java | 8 ++
.../beam/runners/prism/PrismPipelineResult.java | 109 +++++++++++++++++
.../runners/prism/PrismPipelineResultTest.java | 130 +++++++++++++++++++++
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 +-
.../io/gcp/pubsub/PubsubMessageWithTopicCoder.java | 4 +-
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 6 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 2 +-
.../apache/beam/sdk/io/iceberg/IcebergIOIT.java | 3 +-
11 files changed, 260 insertions(+), 12 deletions(-)
create mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismPipelineResult.java
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismPipelineResultTest.java
