This is an automated email from the ASF dual-hosted git repository.
janl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from fb3f6692dbf Fix invalid escape sequence '\#' (#30393)
add 436f3b223f0 [runners-core-java] restore original
SerializablePipelineOptions
add 4982f6ac6e4 [sdks-java-core] add serialVersionUID to PTransform
add 4f13a4e1ea2 [runners-core] add jackson
new 907a4514386 Merge pull request #30403: [flink] #30402 restore
upgradability
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:
runners/core-java/build.gradle | 2 ++
.../beam/runners/core}/construction/SerializablePipelineOptions.java | 2 +-
.../beam/runners/core/{metrics => construction}/package-info.java | 4 ++--
.../runners/core}/construction/SerializablePipelineOptionsTest.java | 2 +-
.../org/apache/beam/runners/flink/FlinkExecutionEnvironments.java | 2 +-
.../beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java | 2 +-
.../apache/beam/runners/flink/FlinkStreamingTransformTranslators.java | 2 +-
.../beam/runners/flink/translation/functions/FlinkDoFnFunction.java | 2 +-
.../flink/translation/functions/FlinkExecutableStageFunction.java | 2 +-
.../translation/functions/FlinkExecutableStagePruningFunction.java | 2 +-
.../translation/functions/FlinkMergingNonShuffleReduceFunction.java | 2 +-
.../flink/translation/functions/FlinkMultiOutputPruningFunction.java | 2 +-
.../flink/translation/functions/FlinkPartialReduceFunction.java | 2 +-
.../beam/runners/flink/translation/functions/FlinkReduceFunction.java | 2 +-
.../flink/translation/functions/FlinkStatefulDoFnFunction.java | 2 +-
.../beam/runners/flink/translation/types/CoderTypeInformation.java | 2 +-
.../beam/runners/flink/translation/types/CoderTypeSerializer.java | 2 +-
.../beam/runners/flink/translation/wrappers/SourceInputFormat.java | 2 +-
.../runners/flink/translation/wrappers/streaming/DoFnOperator.java | 2 +-
.../translation/wrappers/streaming/ExecutableStageDoFnOperator.java | 2 +-
.../translation/wrappers/streaming/KvToByteBufferKeySelector.java | 2 +-
.../translation/wrappers/streaming/SdfByteBufferKeySelector.java | 2 +-
.../flink/translation/wrappers/streaming/WorkItemKeySelector.java | 2 +-
.../flink/translation/wrappers/streaming/io/DedupingOperator.java | 2 +-
.../translation/wrappers/streaming/io/UnboundedSourceWrapper.java | 2 +-
.../flink/translation/wrappers/streaming/io/source/FlinkSource.java | 2 +-
.../wrappers/streaming/io/source/bounded/FlinkBoundedSource.java | 2 +-
.../wrappers/streaming/io/source/unbounded/FlinkUnboundedSource.java | 2 +-
.../wrappers/streaming/stableinput/BufferingDoFnRunner.java | 2 +-
.../wrappers/streaming/state/FlinkBroadcastStateInternals.java | 2 +-
.../translation/wrappers/streaming/state/FlinkStateInternals.java | 2 +-
.../java/org/apache/beam/runners/flink/FlinkPipelineOptionsTest.java | 2 +-
.../runners/flink/streaming/FlinkBroadcastStateInternalsTest.java | 2 +-
.../apache/beam/runners/flink/streaming/FlinkStateInternalsTest.java | 2 +-
.../beam/runners/flink/translation/types/CoderTypeSerializerTest.java | 2 +-
.../flink/translation/wrappers/streaming/DoFnOperatorTest.java | 2 +-
.../wrappers/streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../flink/translation/wrappers/streaming/WindowDoFnOperatorTest.java | 2 +-
.../wrappers/streaming/stableinput/BufferingDoFnRunnerTest.java | 2 +-
.../java/org/apache/beam/runners/jet/JetTransformTranslators.java | 2 +-
.../main/java/org/apache/beam/runners/jet/JetTranslationContext.java | 2 +-
.../java/org/apache/beam/runners/jet/processors/AbstractParDoP.java | 2 +-
.../java/org/apache/beam/runners/jet/processors/BoundedSourceP.java | 2 +-
.../src/main/java/org/apache/beam/runners/jet/processors/ParDoP.java | 2 +-
.../java/org/apache/beam/runners/jet/processors/StatefulParDoP.java | 2 +-
.../java/org/apache/beam/runners/jet/processors/UnboundedSourceP.java | 2 +-
.../java/org/apache/beam/runners/jet/processors/WindowGroupP.java | 2 +-
.../org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java | 2 +-
.../org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java | 2 +-
.../runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java | 2 +-
.../java/org/apache/beam/runners/samza/translation/ConfigBuilder.java | 2 +-
.../spark/structuredstreaming/translation/PipelineTranslator.java | 2 +-
.../spark/structuredstreaming/translation/SparkSessionFactory.java | 2 +-
.../src/main/java/org/apache/beam/runners/spark/io/SourceDStream.java | 2 +-
.../src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java | 2 +-
.../java/org/apache/beam/runners/spark/io/SparkUnboundedSource.java | 2 +-
.../runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java | 2 +-
.../org/apache/beam/runners/spark/stateful/StateSpecFunctions.java | 2 +-
.../org/apache/beam/runners/spark/translation/EvaluationContext.java | 2 +-
.../org/apache/beam/runners/spark/translation/MultiDoFnFunction.java | 2 +-
.../org/apache/beam/runners/spark/translation/SparkCombineFn.java | 2 +-
.../beam/runners/spark/translation/SparkExecutableStageFunction.java | 2 +-
.../spark/translation/SparkGroupAlsoByWindowViaOutputBufferFn.java | 2 +-
.../beam/runners/spark/translation/SparkTranslationContext.java | 2 +-
.../spark/translation/streaming/StreamingTransformTranslator.java | 2 +-
.../org/apache/beam/runners/spark/translation/SparkCombineFnTest.java | 2 +-
.../runners/spark/translation/SparkExecutableStageFunctionTest.java | 2 +-
.../runners/twister2/translation/wrappers/Twister2BoundedSource.java | 2 +-
.../beam/runners/twister2/translators/functions/DoFnFunction.java | 2 +-
.../core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java | 3 +++
70 files changed, 74 insertions(+), 69 deletions(-)
rename {sdks/java/core/src/main/java/org/apache/beam/sdk/util =>
runners/core-java/src/main/java/org/apache/beam/runners/core}/construction/SerializablePipelineOptions.java
(98%)
copy runners/core-java/src/main/java/org/apache/beam/runners/core/{metrics =>
construction}/package-info.java (89%)
rename {sdks/java/core/src/test/java/org/apache/beam/sdk/util =>
runners/core-java/src/test/java/org/apache/beam/runners/core}/construction/SerializablePipelineOptionsTest.java
(98%)
