This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch revert-4805-go-sdk
in repository https://gitbox.apache.org/repos/asf/beam.git.
omit bea6536 Revert "Merge master into go-sdk"
add 303efb1 Bump sdks/go/container.pom.xml to 2.5.0-SNAPSHOT
add d562f65 Merge pull request #4809: Bump sdks/go/container/pom.xml to
2.5.0-SNAPSHOT
add a9a1fa9 [BEAM-3791] Update version number in build_rules.gradle
add 5c1e49c Merge pull request #4810 from alanmyrvold/alan-version
add 788c83c [BEAM-3753] Fix failing integration tests
add f28d198 [BEAM-3753] Rename *ITCase.java tests files to *Test.java
add 8ec9c81 Merge pull request #4767: [BEAM-3753] Fix Flink Runner
integration tests
add c6467d8 [BEAM-3043] Set user-specified PTransform names on Flink
operators
add d497bfa Merge pull request #4759: [BEAM-3043] Set user-specified
PTransform names on Flink operators
add 24ff5b6 Make StateInternals short state method defaulting to the
implementation all runners use to simplify the contract the user has to
implement
add 3ca6e8c Merge pull request #4813: [BEAM-3794] Make StateInternals
short state method defaulting to the implementation all runners use to simplify
the contract the user has to implement
new 56515fa Revert "Merge master into go-sdk"
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 (bea6536)
\
N -- N -- N refs/heads/revert-4805-go-sdk (56515fa)
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.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build_rules.gradle | 2 +-
.../apex/translation/utils/ApexStateInternals.java | 6 ---
.../beam/runners/core/InMemoryStateInternals.java | 6 ---
.../apache/beam/runners/core/StateInternals.java | 5 ++-
.../direct/CopyOnAccessInMemoryStateInternals.java | 5 ---
runners/flink/build.gradle | 1 +
runners/flink/pom.xml | 6 +++
.../flink/FlinkBatchTransformTranslators.java | 40 +++++++++++---------
.../flink/FlinkStreamingTransformTranslators.java | 43 ++++++++++++----------
.../state/FlinkBroadcastStateInternals.java | 9 -----
.../state/FlinkKeyGroupStateInternals.java | 9 -----
.../streaming/state/FlinkSplitStateInternals.java | 9 -----
.../streaming/state/FlinkStateInternals.java | 9 -----
...ingITCase.java => ReadSourceStreamingTest.java} | 14 +++++--
.../{ReadSourceITCase.java => ReadSourceTest.java} | 4 +-
...nsITCase.java => TopWikipediaSessionsTest.java} | 15 ++++++--
.../spark/stateful/SparkStateInternals.java | 6 ---
17 files changed, 81 insertions(+), 108 deletions(-)
rename
runners/flink/src/test/java/org/apache/beam/runners/flink/{ReadSourceStreamingITCase.java
=> ReadSourceStreamingTest.java} (81%)
rename
runners/flink/src/test/java/org/apache/beam/runners/flink/{ReadSourceITCase.java
=> ReadSourceTest.java} (96%)
rename
runners/flink/src/test/java/org/apache/beam/runners/flink/streaming/{TopWikipediaSessionsITCase.java
=> TopWikipediaSessionsTest.java} (93%)
--
To stop receiving notification emails like this one, please contact
k...@apache.org.
