This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch tvalentyn-gha
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 7e52aee8974 Explicitly install now-optional setuptools package as some
tests depend on it.
discard f9fc794196b drop: restrict tests to py312 only.
discard 7bcbc139239 Support Python 3.12 in Beam.
discard 290d0dcf4ed Support Python 3.12 in Dataflow.
discard 679072e9b78 Build Python 3.12 wheels.
discard ec34ca4b526 Switch remaining GHA workflows to test Python 3.12.
discard c3a03fbd926 Switch Py3.11 Gradle suites to use Python 3.12.
discard b8abd0ffa72 Gradle definitions for Python 3.12
discard 2e15be0d18a Add a tox suite for Py312.
discard a905963e2d4 Define Python 3.12 test environments in tox.
add 33fccac00e0 Updates the Java Expansion Service container to support
gRPC ALTS authentication (#31352)
add bedba65a1f7 Update README.md (fix typo) (#31380)
add 2ee266bec03 Fixed the extension name in Java SDK Ordered Processing
extension (#31382)
add 5c8338a38c1 Reapply "[#30789] Add support for Flink 1.18 (#31062)"
add a37df32264b [runners-flink] use mvn exec:exec for
runQuickstartJavaFlinkLocal
add 736ed4a0a31 Merge pull request #31328: Reapply "[#30789] Add support
for Flink 1.18 (#31062)"
add 81d58d83d87 Fix beam quest link
add ec9e963735f Merge pull request #31383 from apache/users/damccorm/bql
add 1f6319624a4 move playground ci nightly to highmem due to mem exaustion
(#31384)
add 0e075b69f07 Define Python 3.12 test environments in tox.
add a0e950b454e Add a tox suite for Py312.
add 7e102700b52 Gradle definitions for Python 3.12
add ddb4e7f29ff Switch Py3.11 Gradle suites to use Python 3.12.
add dac22e3d074 Switch remaining GHA workflows to test Python 3.12.
add d12c628a388 Explicitly install now-optional setuptools package as some
tests depend on it.
add 6486591594a Build Python 3.12 wheels.
add 42c84822d42 Support Python 3.12 in Dataflow.
add ab460c1f5ba Support Python 3.12 in Beam.
add dc6b72caf73 Merge pull request #30828 - Add Python 3.12 support
add 6876734da12 Don't install TF on Python 3.12.
add 697c18fd6a5 Update setup.py
add 1ed29e1f94a Merge pull request #31386 from tvalentyn/py312_tf
add ca002724341 Update beam-master version to 20240524. (#31393)
add 3b9b6ed0038 added pytest.mark.flaky for
test_big_query_write_temp_table_append_sc… (#31364)
add cf3592bbfa0 Fix an incompatibility with hamcrest 2.2 (#31395)
add c10f5d40456 [runners-flink] Drop Flnk 1.14 and clean up code (#31112)
add 0790d698251 Merge pull request #31394: #31112 drop flink 1.14
add 5a822adc269 [flink] #31390 emit watermark with empty source
add 836e77e755b Merge pull request #31391: [flink] #31390 emit watermark
with empty source
add 5c30b1d6db2 Clean up stale code in BigtableService (#30172)
add 2719ca7f37a Changed the retry order for
test_big_query_write_temp_table_append_schema_update (#31407)
add e764fc9c17d remove unused field (#31293)
add 919bbea3bbd pin the lower bound for typing-extensions
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 (7e52aee8974)
\
N -- N -- N refs/heads/tvalentyn-gha (919bbea3bbd)
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:
.../test-properties.json | 2 +-
.github/workflows/beam_Playground_CI_Nightly.yml | 2 +-
.../workflows/beam_PostCommit_Java_Tpcds_Flink.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_Flink.yml | 2 +-
.github/workflows/beam_PostCommit_Python.yml | 2 +-
..._PostCommit_Python_ValidatesRunner_Dataflow.yml | 2 +-
CHANGES.md | 4 +-
contributor-docs/release-guide.md | 2 +-
examples/multi-language/README.md | 2 +-
gradle.properties | 2 +-
.../runner-concepts/description.md | 2 +-
release/build.gradle.kts | 2 +-
.../main/groovy/quickstart-java-flinklocal.groovy | 24 +++---
.../streaming/AbstractStreamOperatorCompat.java | 91 ----------------------
.../streaming/ProcessingTimeCallbackCompat.java | 22 ------
.../io/source/compat/FlinkSourceCompat.java | 28 -------
.../io/source/compat/SplitEnumeratorCompat.java | 27 -------
.../streaming/io/source/compat/package-info.java | 20 -----
.../beam/runners/flink/MiniClusterCompat.java | 29 -------
.../runners/flink/metrics/MetricGroupWrapper.java | 31 --------
.../translation/types/CoderTypeSerializer.java | 0
.../streaming/ProcessingTimeCallbackCompat.java | 22 ------
.../beam/runners/flink/MiniClusterCompat.java | 30 -------
runners/flink/{1.14 => 1.18}/build.gradle | 4 +-
.../job-server-container/build.gradle | 0
.../flink/{1.14 => 1.18}/job-server/build.gradle | 2 +-
.../flink/FlinkStreamingTransformTranslators.java | 8 +-
.../wrappers/streaming/DoFnOperator.java | 57 ++++++++++++--
.../streaming/io/UnboundedSourceWrapper.java | 8 +-
.../streaming/io/source/FlinkSourceReaderBase.java | 12 +--
.../io/source/FlinkSourceSplitEnumerator.java | 9 +--
.../unbounded/FlinkUnboundedSourceReader.java | 8 +-
.../beam/runners/flink/FlinkSavepointTest.java | 6 +-
.../beam/runners/flink/RemoteMiniClusterImpl.java | 0
.../flink/metrics/FlinkMetricContainerTest.java | 3 +-
.../runners/flink/streaming/StreamSources.java | 0
.../translation/types/CoderTypeSerializerTest.java | 0
.../streaming/io/UnboundedSourceWrapperTest.java | 4 +-
.../streaming/io/source/EmptyUnboundedSource.java | 4 +-
.../io/source/FlinkSourceReaderTestBase.java | 20 ++---
.../streaming/io/source/SourceTestMetrics.java} | 2 +-
.../bounded/FlinkBoundedSourceReaderTest.java | 2 +-
.../unbounded/FlinkUnboundedSourceReaderTest.java | 56 ++++++++++++-
.../dataflow/worker/StreamingDataflowWorker.java | 6 --
sdks/go/examples/stringsplit/stringsplit.go | 2 +-
sdks/go/examples/wasm/README.md | 2 +-
.../beam/sdk/testing/CoderPropertiesTest.java | 6 +-
sdks/java/expansion-service/container/boot.go | 4 +
.../sdk/expansion/service/ExpansionService.java | 10 ++-
.../expansion/service/ExpansionServiceOptions.java | 6 ++
sdks/java/extensions/ordered/build.gradle | 2 +-
sdks/java/io/expansion-service/build.gradle | 4 +
.../beam/sdk/io/gcp/bigtable/BigtableService.java | 7 --
.../sdk/io/gcp/bigtable/BigtableServiceImpl.java | 78 ++-----------------
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 10 ---
.../io/gcp/bigtable/BigtableServiceImplTest.java | 43 +---------
.../apache_beam/io/gcp/bigquery_write_it_test.py | 5 +-
.../ml/inference/tensorflow_inference_test.py | 14 ++--
.../ml/inference/tensorflow_tests_requirements.txt | 1 +
.../python/apache_beam/options/pipeline_options.py | 2 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
sdks/python/setup.py | 5 +-
sdks/python/test-suites/tox/py312/build.gradle | 2 +-
sdks/typescript/src/apache_beam/runners/flink.ts | 2 +-
settings.gradle.kts | 4 -
website/www/site/content/en/blog/beamquest.md | 2 +-
.../site/content/en/documentation/runners/flink.md | 9 ++-
.../shortcodes/flink_java_pipeline_options.html | 10 +++
.../shortcodes/flink_python_pipeline_options.html | 10 +++
69 files changed, 263 insertions(+), 540 deletions(-)
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ProcessingTimeCallbackCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/FlinkSourceCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/SplitEnumeratorCompat.java
delete mode 100644
runners/flink/1.14/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/compat/package-info.java
delete mode 100644
runners/flink/1.14/src/test/java/org/apache/beam/runners/flink/MiniClusterCompat.java
delete mode 100644
runners/flink/1.14/src/test/java/org/apache/beam/runners/flink/metrics/MetricGroupWrapper.java
rename runners/flink/{1.14 =>
1.15}/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java
(100%)
delete mode 100644
runners/flink/1.15/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ProcessingTimeCallbackCompat.java
delete mode 100644
runners/flink/1.15/src/test/java/org/apache/beam/runners/flink/MiniClusterCompat.java
rename runners/flink/{1.14 => 1.18}/build.gradle (94%)
rename runners/flink/{1.14 => 1.18}/job-server-container/build.gradle (100%)
rename runners/flink/{1.14 => 1.18}/job-server/build.gradle (95%)
rename runners/flink/{1.14 =>
}/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java (100%)
rename runners/flink/{1.14 =>
}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(100%)
rename runners/flink/{1.14 =>
}/src/test/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializerTest.java
(100%)
rename
runners/flink/{1.14/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/SourceTestCompat.java
=>
src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/SourceTestMetrics.java}
(99%)
