You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ja...@apache.org on 2024/02/26 08:05:31 UTC
(beam) 01/01: Merge pull request #30403: [flink] #30402 restore upgradability
This is an automated email from the ASF dual-hosted git repository.
janl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 907a4514386109245a52630907d252cf5609942d
Merge: fb3f6692dbf 4f13a4e1ea2
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Mon Feb 26 09:05:23 2024 +0100
Merge pull request #30403: [flink] #30402 restore upgradability
runners/core-java/build.gradle | 2 ++
.../construction/SerializablePipelineOptions.java | 2 +-
.../runners/core/construction/package-info.java | 24 ++++++++++++++++++++++
.../SerializablePipelineOptionsTest.java | 2 +-
.../runners/flink/FlinkExecutionEnvironments.java | 2 +-
.../FlinkStreamingPortablePipelineTranslator.java | 2 +-
.../flink/FlinkStreamingTransformTranslators.java | 2 +-
.../translation/functions/FlinkDoFnFunction.java | 2 +-
.../functions/FlinkExecutableStageFunction.java | 2 +-
.../FlinkExecutableStagePruningFunction.java | 2 +-
.../FlinkMergingNonShuffleReduceFunction.java | 2 +-
.../functions/FlinkMultiOutputPruningFunction.java | 2 +-
.../functions/FlinkPartialReduceFunction.java | 2 +-
.../translation/functions/FlinkReduceFunction.java | 2 +-
.../functions/FlinkStatefulDoFnFunction.java | 2 +-
.../translation/types/CoderTypeInformation.java | 2 +-
.../translation/types/CoderTypeSerializer.java | 2 +-
.../translation/wrappers/SourceInputFormat.java | 2 +-
.../wrappers/streaming/DoFnOperator.java | 2 +-
.../streaming/ExecutableStageDoFnOperator.java | 2 +-
.../streaming/KvToByteBufferKeySelector.java | 2 +-
.../streaming/SdfByteBufferKeySelector.java | 2 +-
.../wrappers/streaming/WorkItemKeySelector.java | 2 +-
.../wrappers/streaming/io/DedupingOperator.java | 2 +-
.../streaming/io/UnboundedSourceWrapper.java | 2 +-
.../wrappers/streaming/io/source/FlinkSource.java | 2 +-
.../io/source/bounded/FlinkBoundedSource.java | 2 +-
.../io/source/unbounded/FlinkUnboundedSource.java | 2 +-
.../streaming/stableinput/BufferingDoFnRunner.java | 2 +-
.../state/FlinkBroadcastStateInternals.java | 2 +-
.../streaming/state/FlinkStateInternals.java | 2 +-
.../runners/flink/FlinkPipelineOptionsTest.java | 2 +-
.../FlinkBroadcastStateInternalsTest.java | 2 +-
.../flink/streaming/FlinkStateInternalsTest.java | 2 +-
.../translation/types/CoderTypeSerializerTest.java | 2 +-
.../wrappers/streaming/DoFnOperatorTest.java | 2 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../wrappers/streaming/WindowDoFnOperatorTest.java | 2 +-
.../stableinput/BufferingDoFnRunnerTest.java | 2 +-
.../beam/runners/jet/JetTransformTranslators.java | 2 +-
.../beam/runners/jet/JetTranslationContext.java | 2 +-
.../runners/jet/processors/AbstractParDoP.java | 2 +-
.../runners/jet/processors/BoundedSourceP.java | 2 +-
.../apache/beam/runners/jet/processors/ParDoP.java | 2 +-
.../runners/jet/processors/StatefulParDoP.java | 2 +-
.../runners/jet/processors/UnboundedSourceP.java | 2 +-
.../beam/runners/jet/processors/WindowGroupP.java | 2 +-
.../runners/samza/adapter/BoundedSourceSystem.java | 2 +-
.../samza/adapter/UnboundedSourceSystem.java | 2 +-
.../SplittableParDoProcessKeyedElementsOp.java | 2 +-
.../runners/samza/translation/ConfigBuilder.java | 2 +-
.../translation/PipelineTranslator.java | 2 +-
.../translation/SparkSessionFactory.java | 2 +-
.../beam/runners/spark/io/SourceDStream.java | 2 +-
.../apache/beam/runners/spark/io/SourceRDD.java | 2 +-
.../runners/spark/io/SparkUnboundedSource.java | 2 +-
.../SparkGroupAlsoByWindowViaWindowSet.java | 2 +-
.../runners/spark/stateful/StateSpecFunctions.java | 2 +-
.../spark/translation/EvaluationContext.java | 2 +-
.../spark/translation/MultiDoFnFunction.java | 2 +-
.../runners/spark/translation/SparkCombineFn.java | 2 +-
.../translation/SparkExecutableStageFunction.java | 2 +-
.../SparkGroupAlsoByWindowViaOutputBufferFn.java | 2 +-
.../spark/translation/SparkTranslationContext.java | 2 +-
.../streaming/StreamingTransformTranslator.java | 2 +-
.../spark/translation/SparkCombineFnTest.java | 2 +-
.../SparkExecutableStageFunctionTest.java | 2 +-
.../wrappers/Twister2BoundedSource.java | 2 +-
.../translators/functions/DoFnFunction.java | 2 +-
.../org/apache/beam/sdk/transforms/PTransform.java | 3 +++
70 files changed, 96 insertions(+), 67 deletions(-)