This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from f6f785fd1a9 [FLINK-33418][test] Uses getHost()
new 68437b937a6 [FLINK-28050][connectors] Move DataGeneratorSource tests
into a separate module
new 80fd59ccfc3 [FLINK-28050][connectors] Deprecate OutputTypeConfigurable
in flink-streaming-java
new ad64e72cf3e [FLINK-28050][connectors] Introduce FLIP-27 alternative to
StreamExecutionEnvironment#fromElements()
new d351c5bd9c1 [FLINK-28050][connectors] Deprecate
StreamExecutionEnvironment#fromElements()
The 4 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:
.../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 8 +-
.../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 87 +++++----
.../flink-architecture-tests-production/pom.xml | 5 +
flink-architecture-tests/pom.xml | 7 +
.../program/PackagedProgramUtilsPipelineTest.java | 2 +-
.../org/apache/flink/client/testjar/TestJob.java | 2 +-
.../6dae736c-6957-4d04-93bf-d7ebc5ca97ab} | 0
.../f2b2daa5-8ca8-4a74-bb17-cb9f49e3e0e2} | 0
.../archunit-violations/stored.rules | 6 +-
.../pom.xml | 67 ++++++-
.../architecture/TestCodeArchitectureTest.java | 0
.../FromElementsGeneratorSourceITCase.java | 122 +++++++++++++
.../datagen/source/DataGeneratorSourceITCase.java | 56 +++++-
.../datagen/source/DataGeneratorSourceTest.java | 0
.../src/test/resources/archunit.properties | 0
.../src/test/resources/avro/user.avsc | 9 +
.../src/test/resources/log4j2-test.properties | 0
flink-connectors/flink-connector-datagen/pom.xml | 33 ----
.../functions/FromElementsGeneratorFunction.java | 200 +++++++++++++++++++++
.../datagen/source/DataGeneratorSource.java | 35 +++-
flink-connectors/pom.xml | 1 +
.../api/operators/OutputTypeConfigurable.java | 16 +-
.../tests/DistributedCacheViaBlobTestProgram.java | 2 +-
.../java/org/apache/flink/tests/scala/JavaJob.java | 2 +-
.../tests/scala/JavaJobWithKryoSerializer.java | 2 +-
.../tests/FailureEnricherTestProgram.java | 2 +-
.../streaming/tests/ClassLoaderTestProgram.java | 2 +-
.../examples/sideoutput/SideOutputExample.java | 2 +-
.../examples/windowing/WindowWordCount.java | 2 +-
.../streaming/examples/wordcount/WordCount.java | 2 +-
.../streaming/test/StreamingExamplesITCase.java | 4 +-
.../java/basics/TemporalJoinSQLExample.java | 4 +-
.../flink/table/runtime/batch/AvroTypesITCase.java | 2 +-
.../flink/hdfstests/DistributedCacheDfsTest.java | 2 +-
.../test/java/org/apache/flink/cep/CEPITCase.java | 30 ++--
.../flink/state/api/SavepointDeepCopyTest.java | 2 +-
.../flink/state/api/SavepointWriterITCase.java | 2 +-
.../api/StateBootstrapTransformationTest.java | 10 +-
.../state/api/runtime/OperatorIDGeneratorTest.java | 2 +-
...st_stream_execution_environment_completeness.py | 2 +-
.../java/org/apache/flink/client/cli/TestJob.java | 2 +-
.../client/python/PythonFunctionFactoryTest.java | 2 +-
.../PythonScalarFunctionOperatorTestBase.java | 2 +-
.../webmonitor/history/HistoryServerTest.java | 2 +-
flink-streaming-java/pom.xml | 6 +
.../streaming/api/datastream/DataStreamSource.java | 2 +-
.../environment/StreamExecutionEnvironment.java | 116 ++++++++++++
.../api/operators/SourceOperatorFactory.java | 15 ++
.../apache/flink/streaming/api/DataStreamTest.java | 39 ++--
.../flink/streaming/api/RestartStrategyTest.java | 6 +-
.../api/datastream/CoGroupedStreamsTest.java | 4 +-
.../api/datastream/DataStreamSinkTest.java | 4 +-
.../api/datastream/JoinedStreamsTest.java | 4 +-
.../StreamExecutionEnvironmentTest.java | 73 ++++++--
.../SinkV1TransformationTranslatorITCase.java | 4 +-
.../StreamGraphGeneratorBatchExecutionTest.java | 46 ++---
.../api/graph/StreamGraphGeneratorTest.java | 65 +++----
.../api/graph/StreamingJobGraphGeneratorTest.java | 90 ++++++----
...hGeneratorWithGlobalStreamExchangeModeTest.java | 4 +-
.../api/operators/StateDescriptorPassingTest.java | 12 +-
.../api/operators/async/AsyncWaitOperatorTest.java | 2 +-
.../operators/StreamOperatorChainingTest.java | 4 +-
.../windowing/AllWindowTranslationTest.java | 56 +++---
.../windowing/TimeWindowTranslationTest.java | 6 +-
.../operators/windowing/WindowTranslationTest.java | 62 +++----
.../scala/StreamingScalaAPICompletenessTest.scala | 7 -
.../internal/StreamTableEnvironmentImplTest.java | 4 +-
.../apache/flink/table/api/EnvironmentTest.java | 2 +-
.../planner/delegation/DefaultExecutorTest.java | 8 +-
.../MultipleInputNodeCreationProcessorTest.java | 4 +-
.../runtime/batch/sql/MatchRecognizeITCase.java | 20 +--
.../runtime/stream/sql/DataStreamJavaITCase.java | 24 +--
.../client/testjar/TestUserClassLoaderJob.java | 2 +-
...niClusterExtensionDefaultParallelismITCase.java | 2 +-
flink-tests/pom.xml | 45 ++++-
.../datastream/DataStreamBatchExecutionITCase.java | 32 ++--
.../datastream/DataStreamCollectTestITCase.java | 16 +-
.../test/classloading/jar/StreamingProgram.java | 2 +-
.../completeness/TypeInfoTestCoverageTest.java | 6 +-
.../TypeSerializerTestCoverageTest.java | 7 +-
.../flink/test/execution/JobListenerITCase.java | 8 +-
.../flink/test/runtime/NettyEpollITCase.java | 2 +-
.../api/StreamExecutionEnvironmentITCase.java | 89 ++++++---
.../streaming/api/StreamingOperatorsITCase.java | 2 +-
.../DataStreamWithSharedPartitionNodeITCase.java | 2 +-
.../api/datastream/GetOperatorUniqueIDTest.java | 2 +-
.../environment/RemoteStreamEnvironmentTest.java | 4 +-
.../api/outputformat/CsvOutputFormatITCase.java | 2 +-
.../api/outputformat/TextOutputFormatITCase.java | 2 +-
.../runtime/BigUserProgramJobSubmitITCase.java | 2 +-
.../flink/test/streaming/runtime/CacheITCase.java | 4 +-
.../test/streaming/runtime/CoGroupJoinITCase.java | 4 +-
.../test/streaming/runtime/CoStreamITCase.java | 2 +-
.../test/streaming/runtime/IntervalJoinITCase.java | 32 ++--
.../test/streaming/runtime/IterateITCase.java | 37 ++--
.../streaming/runtime/MultipleInputITCase.java | 12 +-
.../test/streaming/runtime/PartitionerITCase.java | 4 +-
.../streaming/runtime/SelfConnectionITCase.java | 4 +-
.../test/streaming/runtime/SideOutputITCase.java | 4 +-
.../runtime/SortingBoundedInputITCase.java | 6 +-
.../test/streaming/runtime/StateBackendITCase.java | 2 +-
.../test/streaming/runtime/TimestampITCase.java | 6 +-
flink-tests/src/test/resources/avro/user.avsc | 9 +
pom.xml | 5 +
104 files changed, 1270 insertions(+), 517 deletions(-)
rename
flink-connectors/{flink-connector-datagen/archunit-violations/0fbe3123-5829-4891-93a5-a99bd8413fd9
=>
flink-connector-datagen-test/archunit-violations/6dae736c-6957-4d04-93bf-d7ebc5ca97ab}
(100%)
rename
flink-connectors/{flink-connector-datagen/archunit-violations/5a661a23-5b47-407c-9994-b6215a46c45c
=>
flink-connector-datagen-test/archunit-violations/f2b2daa5-8ca8-4a74-bb17-cb9f49e3e0e2}
(100%)
rename flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/archunit-violations/stored.rules (50%)
copy flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/pom.xml (56%)
rename flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
(100%)
create mode 100644
flink-connectors/flink-connector-datagen-test/src/test/java/org/apache/flink/connector/datagen/functions/FromElementsGeneratorSourceITCase.java
rename flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/src/test/java/org/apache/flink/connector/datagen/source/DataGeneratorSourceITCase.java
(81%)
rename flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/src/test/java/org/apache/flink/connector/datagen/source/DataGeneratorSourceTest.java
(100%)
rename flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/src/test/resources/archunit.properties (100%)
create mode 100644
flink-connectors/flink-connector-datagen-test/src/test/resources/avro/user.avsc
rename flink-connectors/{flink-connector-datagen =>
flink-connector-datagen-test}/src/test/resources/log4j2-test.properties (100%)
create mode 100644
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/functions/FromElementsGeneratorFunction.java
rename {flink-streaming-java =>
flink-core}/src/main/java/org/apache/flink/streaming/api/operators/OutputTypeConfigurable.java
(74%)
create mode 100644 flink-tests/src/test/resources/avro/user.avsc
