This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/sdks/golang.org/x/net-0.8.0
in repository https://gitbox.apache.org/repos/asf/beam.git
discard d299d7e976c Bump golang.org/x/net from 0.7.0 to 0.8.0 in /sdks
add 5a2b93ddaa7 [Spark Dataset runner] Avoid copying outputs for most
cases in ParDo translation (related to #24711) (#25624)
add 9b6b72f3379 [Spark Dataset runner] Prevent stackoverflow in ParDo load
tests when using RDDs to break linage for large number of consequtive ParDos
(#25732)
add fcf111d299a Update documentation by adding parameters for Dataflow
Runner (#25561)
add 08198142087 [Playground] Apache Kafka based Kafka emulator for
Playground examples (#25357)
add 6452dc79822 [Flink Runner] Add new Source classes that are based on
FLIP-27 Source API. (#25525)
add fd13e14dd67 Bump golang.org/x/sys from 0.5.0 to 0.6.0 in /sdks (#25727)
add b3a9aa795ce Bump github.com/tetratelabs/wazero in /sdks (#25689)
add 4645b61ba20 Bump golang.org/x/net from 0.7.0 to 0.8.0 in /sdks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d299d7e976c)
\
N -- N -- N
refs/heads/dependabot/go_modules/sdks/golang.org/x/net-0.8.0 (4645b61ba20)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
playground/backend/cmd/server/controller.go | 30 +-
playground/backend/containers/go/Dockerfile | 7 +
playground/backend/containers/go/build.gradle | 8 +
playground/backend/containers/java/Dockerfile | 7 +-
playground/backend/containers/java/build.gradle | 9 +
playground/backend/containers/python/Dockerfile | 7 +
playground/backend/containers/python/build.gradle | 8 +
playground/backend/containers/scio/Dockerfile | 6 +
playground/backend/containers/scio/build.gradle | 8 +
.../internal/code_processing/code_processing.go | 29 +-
.../code_processing/code_processing_test.go | 8 +-
.../internal/db/mapper/datastore_mapper_test.go | 2 +-
.../db/schema/migration/migrations_test.go | 2 +-
playground/backend/internal/emulators/emulator.go | 51 +--
playground/backend/internal/emulators/kafka.go | 109 +++++-
.../backend/internal/environment/application.go | 37 +-
.../internal/environment/environment_service.go | 91 ++---
.../environment/environment_service_test.go | 14 +-
playground/backend/internal/fs_tool/fs.go | 24 ++
.../setup_tools/life_cycle/life_cycle_setuper.go | 44 ++-
.../life_cycle/life_cycle_setuper_test.go | 3 +-
playground/kafka-emulator/build.gradle | 53 +++
.../org/apache/beam/playground/KafkaEmulator.java | 72 ++++
.../org/apache/beam/playground/package-info.java | 22 ++
.../io/source/compat/FlinkSourceCompat.java | 31 ++
.../io/source/compat/SplitEnumeratorCompat.java | 27 ++
.../streaming/io/source/compat/package-info.java | 20 +
.../streaming/io/source/SourceTestCompat.java | 62 ++++
.../io/source/compat/SplitEnumeratorCompat.java | 27 ++
.../io/source/compat/FlinkSourceCompat.java | 28 ++
.../streaming/io/source/SourceTestCompat.java | 93 +++++
runners/flink/flink_runner.gradle | 2 +
.../flink/translation/utils/SerdeUtils.java | 85 +++++
.../wrappers/streaming/io/source/FlinkSource.java | 152 ++++++++
.../streaming/io/source/FlinkSourceReaderBase.java | 399 ++++++++++++++++++++
.../streaming/io/source/FlinkSourceSplit.java | 76 ++++
.../io/source/FlinkSourceSplitEnumerator.java | 181 +++++++++
.../io/source/bounded/FlinkBoundedSource.java | 67 ++++
.../source/bounded/FlinkBoundedSourceReader.java | 146 ++++++++
.../streaming/io/source/bounded/package-info.java | 21 ++
.../io/source/impulse/BeamImpulseSource.java | 107 ++++++
.../streaming/io/source/impulse/package-info.java | 21 ++
.../wrappers/streaming/io/source/package-info.java | 21 ++
.../io/source/unbounded/FlinkUnboundedSource.java | 64 ++++
.../unbounded/FlinkUnboundedSourceReader.java | 272 ++++++++++++++
.../io/source/unbounded/package-info.java | 21 ++
.../streaming/io/TestBoundedCountingSource.java | 150 ++++++++
.../wrappers/streaming/io/TestCountingSource.java | 63 +++-
.../io/source/FlinkSourceReaderTestBase.java | 403 +++++++++++++++++++++
.../io/source/FlinkSourceSplitEnumeratorTest.java | 151 ++++++++
.../wrappers/streaming/io/source/TestSource.java | 38 ++
.../bounded/FlinkBoundedSourceReaderTest.java | 146 ++++++++
.../unbounded/FlinkUnboundedSourceReaderTest.java | 318 ++++++++++++++++
.../translation/batch/ParDoTranslatorBatch.java | 42 ++-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
settings.gradle.kts | 1 +
.../en/documentation/ml/large-language-modeling.md | 27 +-
58 files changed, 3748 insertions(+), 171 deletions(-)
create mode 100644 playground/kafka-emulator/build.gradle
create mode 100644
playground/kafka-emulator/src/main/java/org/apache/beam/playground/KafkaEmulator.java
create mode 100644
playground/kafka-emulator/src/main/java/org/apache/beam/playground/package-info.java
create mode 100644
runners/flink/1.12/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/FlinkSourceCompat.java
create mode 100644
runners/flink/1.12/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/SplitEnumeratorCompat.java
create mode 100644
runners/flink/1.12/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/package-info.java
create mode 100644
runners/flink/1.12/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/SourceTestCompat.java
create mode 100644
runners/flink/1.13/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/SplitEnumeratorCompat.java
create mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/FlinkSourceCompat.java
create mode 100644
runners/flink/1.14/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/SourceTestCompat.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/SerdeUtils.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/FlinkSource.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/FlinkSourceReaderBase.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/FlinkSourceSplit.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/FlinkSourceSplitEnumerator.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/bounded/FlinkBoundedSource.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/bounded/FlinkBoundedSourceReader.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/bounded/package-info.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/impulse/BeamImpulseSource.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/impulse/package-info.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/package-info.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/FlinkUnboundedSource.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/FlinkUnboundedSourceReader.java
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/package-info.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/TestBoundedCountingSource.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/FlinkSourceReaderTestBase.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/FlinkSourceSplitEnumeratorTest.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/TestSource.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/bounded/FlinkBoundedSourceReaderTest.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/FlinkUnboundedSourceReaderTest.java
