This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 09531994e3c [FLINK-35088][core] Watermark alignment
maxAllowedWatermarkDrift and updateInterval param need check
new ffa639a31c7 [FLINK-29050][test-utils] Rename AbstractTestBase,
JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix.
new 29a045574ef [FLINK-29050][test-utils] Use JUnit5 to re-write
AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase and tag the
corresponding old implementation classes as deprecated
new 92eef24d4cc [FLINK-29050][JUnit5 Migration] Module:
flink-hadoop-compatibility
The 3 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:
.../source/reader/CoordinatedSourceITCase.java | 4 +-
.../table/catalog/hive/HiveCatalogUdfITCase.java | 4 +-
.../java/hadoop/mapred/HadoopInputFormatTest.java | 44 +++++----
.../java/hadoop/mapred/HadoopOutputFormatTest.java | 20 ++--
.../mapred/wrapper/HadoopInputSplitTest.java | 35 +++----
.../hadoop/mapreduce/HadoopInputFormatTest.java | 53 +++++------
.../hadoop/mapreduce/HadoopOutputFormatTest.java | 18 ++--
.../api/java/typeutils/WritableExtractionTest.java | 86 ++++++++---------
.../typeutils/runtime/WritableSerializerTest.java | 6 +-
.../mapred/HadoopIOFormatsITCase.java | 53 +++++++----
.../mapred/HadoopMapFunctionITCase.java | 38 ++++----
.../mapred/HadoopMapredITCase.java | 14 ++-
.../mapred/HadoopReduceCombineFunctionITCase.java | 49 +++++-----
.../mapred/HadoopReduceFunctionITCase.java | 38 ++++----
.../mapred/WordCountMapredITCase.java | 22 +++--
.../wrapper/HadoopTupleUnwrappingIteratorTest.java | 69 ++++++--------
.../mapreduce/HadoopInputOutputITCase.java | 19 ++--
.../mapreduce/WordCountMapreduceITCase.java | 19 ++--
.../org.junit.jupiter.api.extension.Extension | 0
.../scala/ScalaWritableTypeInfoTest.scala | 11 +--
.../scala/WordCountMapredITCase.scala | 9 +-
.../scala/WordCountMapreduceITCase.scala | 9 +-
.../streaming/test/StreamingExamplesITCase.java | 4 +-
.../test/socket/SocketWindowWordCountITCase.java | 4 +-
.../flink/formats/avro/AvroOutputFormatITCase.java | 4 +-
.../formats/avro/AvroStreamingFileSinkITCase.java | 4 +-
.../flink/table/runtime/batch/AvroTypesITCase.java | 4 +-
.../flink/formats/csv/TableCsvFormatITCase.java | 4 +-
.../hadoop/bulk/AbstractFileCommitterTest.java | 4 +-
.../bulk/HadoopPathBasedPartFileWriterITCase.java | 4 +-
.../hdfstests/ContinuousFileProcessingITCase.java | 4 +-
.../test/java/org/apache/flink/cep/CEPITCase.java | 4 +-
.../state/api/BootstrapTransformationTest.java | 4 +-
.../api/DataSetSavepointReaderITTestBase.java | 4 +-
.../flink/state/api/SavepointDeepCopyTest.java | 4 +-
.../flink/state/api/SavepointReaderITTestBase.java | 4 +-
.../flink/state/api/SavepointWriterITCase.java | 4 +-
.../state/api/SavepointWriterWindowITCase.java | 4 +-
.../api/StateBootstrapTransformationTest.java | 4 +-
.../flink/state/api/WritableSavepointITCase.java | 4 +-
.../state/api/WritableSavepointWindowITCase.java | 4 +-
.../flink/state/api/utils/SavepointTestBase.java | 4 +-
.../streaming/scala/api/CsvOutputFormatITCase.java | 4 +-
.../scala/api/StatefulFunctionITCase.java | 4 +-
.../scala/api/TextOutputFormatITCase.java | 4 +-
.../api/scala/AsyncDataStreamITCase.scala | 4 +-
.../streaming/api/scala/BroadcastStateITCase.scala | 4 +-
.../streaming/api/scala/CoGroupJoinITCase.scala | 4 +-
.../flink/streaming/api/scala/DataStreamTest.scala | 4 +-
.../streaming/api/scala/IntervalJoinITCase.scala | 4 +-
.../streaming/api/scala/SideOutputITCase.scala | 4 +-
.../api/scala/StreamingOperatorsITCase.scala | 4 +-
.../api/scala/TimeWindowTranslationTest.scala | 4 +-
.../streaming/api/scala/WindowReduceITCase.scala | 4 +-
.../gateway/AbstractSqlGatewayStatementITCase.java | 4 +-
.../flink/test/junit5/MiniClusterExtension.java | 20 ++++
.../apache/flink/test/util/AbstractTestBase.java | 34 +++----
...ctTestBase.java => AbstractTestBaseJUnit4.java} | 7 +-
.../flink/test/util/JavaProgramTestBase.java | 104 ++++++---------------
...estBase.java => JavaProgramTestBaseJUnit4.java} | 5 +-
.../flink/test/util/MultipleProgramsTestBase.java | 30 +++---
...se.java => MultipleProgramsTestBaseJUnit4.java} | 7 +-
.../jobmaster/JobMasterTriggerSavepointITCase.java | 4 +-
.../lifecycle/StopWithSavepointITCase.java | 4 +-
.../flink/test/accumulators/AccumulatorITCase.java | 4 +-
.../accumulators/AccumulatorIterativeITCase.java | 4 +-
.../flink/test/actions/CountCollectITCase.java | 4 +-
.../broadcastvars/BroadcastBranchingITCase.java | 4 +-
.../test/broadcastvars/BroadcastUnionITCase.java | 4 +-
.../BroadcastVarInitializationITCase.java | 4 +-
.../CheckpointAfterAllTasksFinishedITCase.java | 4 +-
.../checkpointing/CoStreamCheckpointingITCase.java | 4 +-
.../test/checkpointing/ManualCheckpointITCase.java | 4 +-
.../test/checkpointing/StateHandleReuseITCase.java | 4 +-
.../StreamCheckpointNotifierITCase.java | 4 +-
.../distributedcache/DistributedCacheTest.java | 4 +-
.../test/example/failing/TaskFailureITCase.java | 4 +-
.../example/java/ConnectedComponentsITCase.java | 4 +-
.../test/example/java/EnumTriangleBasicITCase.java | 4 +-
.../flink/test/example/java/PageRankITCase.java | 4 +-
.../test/example/java/TransitiveClosureITCase.java | 4 +-
.../test/example/java/WebLogAnalysisITCase.java | 4 +-
.../flink/test/example/java/WordCountITCase.java | 4 +-
.../example/java/WordCountNestedPOJOITCase.java | 4 +-
.../example/java/WordCountSimplePOJOITCase.java | 4 +-
.../java/WordCountSubclassInterfacePOJOITCase.java | 4 +-
.../example/java/WordCountSubclassPOJOITCase.java | 4 +-
.../java/WordCountWithCollectionITCase.java | 4 +-
.../org/apache/flink/test/io/CsvReaderITCase.java | 4 +-
.../apache/flink/test/io/InputOutputITCase.java | 4 +-
.../flink/test/io/RichInputOutputITCase.java | 4 +-
.../BulkIterationWithAllReducerITCase.java | 4 +-
.../CoGroupConnectedComponentsITCase.java | 4 +-
.../CoGroupConnectedComponentsSecondITCase.java | 4 +-
.../test/iterative/ConnectedComponentsITCase.java | 4 +-
...onnectedComponentsWithDeferredUpdateITCase.java | 4 +-
.../ConnectedComponentsWithObjectMapITCase.java | 4 +-
...nectedComponentsWithSolutionSetFirstITCase.java | 4 +-
.../test/iterative/DanglingPageRankITCase.java | 4 +-
...taIterationNotDependingOnSolutionSetITCase.java | 4 +-
.../DependencyConnectedComponentsITCase.java | 4 +-
.../iterative/EmptyWorksetIterationITCase.java | 4 +-
.../test/iterative/IdentityIterationITCase.java | 4 +-
...tionIncompleteDynamicPathConsumptionITCase.java | 4 +-
...ationIncompleteStaticPathConsumptionITCase.java | 4 +-
.../IterationTerminationWithTerminationTail.java | 4 +-
.../IterationTerminationWithTwoTails.java | 4 +-
.../iterative/IterationWithAllReducerITCase.java | 4 +-
.../iterative/IterationWithChainingITCase.java | 4 +-
.../test/iterative/IterationWithUnionITCase.java | 4 +-
.../iterative/KMeansWithBroadcastSetITCase.java | 4 +-
.../iterative/MultipleSolutionSetJoinsITCase.java | 4 +-
.../iterative/SolutionSetDuplicatesITCase.java | 4 +-
.../iterative/StaticlyNestedIterationsITCase.java | 4 +-
.../UnionStaticDynamicIterationITCase.java | 4 +-
.../aggregators/AggregatorConvergenceITCase.java | 4 +-
.../iterative/aggregators/AggregatorsITCase.java | 4 +-
.../flink/test/misc/CustomPartitioningITCase.java | 4 +-
.../flink/test/operators/AggregateITCase.java | 4 +-
.../test/operators/CoGroupGroupSortITCase.java | 4 +-
.../apache/flink/test/operators/CoGroupITCase.java | 4 +-
.../apache/flink/test/operators/CrossITCase.java | 4 +-
.../flink/test/operators/DataSinkITCase.java | 4 +-
.../flink/test/operators/DataSourceITCase.java | 4 +-
.../flink/test/operators/DistinctITCase.java | 4 +-
.../apache/flink/test/operators/FilterITCase.java | 4 +-
.../apache/flink/test/operators/FirstNITCase.java | 4 +-
.../apache/flink/test/operators/FlatMapITCase.java | 4 +-
.../flink/test/operators/GroupCombineITCase.java | 4 +-
.../flink/test/operators/GroupReduceITCase.java | 4 +-
.../apache/flink/test/operators/JoinITCase.java | 4 +-
.../org/apache/flink/test/operators/MapITCase.java | 4 +-
.../flink/test/operators/MapPartitionITCase.java | 4 +-
.../flink/test/operators/ObjectReuseITCase.java | 4 +-
.../flink/test/operators/OuterJoinITCase.java | 4 +-
.../flink/test/operators/PartitionITCase.java | 4 +-
.../apache/flink/test/operators/ProjectITCase.java | 4 +-
.../apache/flink/test/operators/ReduceITCase.java | 4 +-
.../test/operators/ReduceWithCombinerITCase.java | 4 +-
.../operators/ReplicatingDataSourceITCase.java | 4 +-
.../apache/flink/test/operators/SampleITCase.java | 4 +-
.../flink/test/operators/SortPartitionITCase.java | 4 +-
.../flink/test/operators/SumMinMaxITCase.java | 4 +-
.../flink/test/operators/TypeHintITCase.java | 4 +-
.../apache/flink/test/operators/UnionITCase.java | 4 +-
.../flink/test/recovery/FastFailuresITCase.java | 4 +-
.../ConsumePipelinedAndBlockingResultITCase.java | 4 +-
.../flink/test/runtime/JoinDeadlockITCase.java | 4 +-
.../RegisterTypeWithKryoSerializerITCase.java | 4 +-
.../flink/test/runtime/SelfJoinDeadlockITCase.java | 4 +-
.../flink/test/state/ManualWindowSpeedITCase.java | 4 +-
.../streaming/api/StreamingOperatorsITCase.java | 4 +-
.../api/outputformat/CsvOutputFormatITCase.java | 4 +-
.../api/outputformat/TextOutputFormatITCase.java | 4 +-
.../test/streaming/experimental/CollectITCase.java | 4 +-
.../streaming/runtime/BroadcastStateITCase.java | 4 +-
.../streaming/runtime/BufferTimeoutITCase.java | 4 +-
.../flink/test/streaming/runtime/CacheITCase.java | 4 +-
.../runtime/ChainedRuntimeContextITCase.java | 4 +-
.../test/streaming/runtime/CoGroupJoinITCase.java | 4 +-
.../test/streaming/runtime/CoStreamITCase.java | 4 +-
.../streaming/runtime/DataStreamPojoITCase.java | 4 +-
.../streaming/runtime/GlobalAggregateITCase.java | 4 +-
.../test/streaming/runtime/IterateITCase.java | 4 +-
.../streaming/runtime/MultipleInputITCase.java | 4 +-
.../test/streaming/runtime/PartitionerITCase.java | 4 +-
.../streaming/runtime/SelfConnectionITCase.java | 4 +-
.../test/streaming/runtime/SideOutputITCase.java | 4 +-
.../flink/test/streaming/runtime/SinkITCase.java | 4 +-
.../streaming/runtime/SinkV2DeprecatedITCase.java | 4 +-
.../flink/test/streaming/runtime/SinkV2ITCase.java | 4 +-
.../runtime/SortingBoundedInputITCase.java | 4 +-
.../test/streaming/runtime/StateBackendITCase.java | 4 +-
.../streaming/runtime/StreamTaskTimerITCase.java | 4 +-
.../apache/flink/test/util/DataSetUtilsITCase.java | 2 +-
.../sessionwindows/SessionWindowITCase.java | 4 +-
.../api/scala/actions/CountCollectITCase.scala | 6 +-
.../api/scala/functions/ClosureCleanerITCase.scala | 6 +-
.../scala/io/ScalaCsvReaderWithPOJOITCase.scala | 7 +-
.../api/scala/operators/AggregateITCase.scala | 6 +-
.../flink/api/scala/operators/CoGroupITCase.scala | 6 +-
.../flink/api/scala/operators/CrossITCase.scala | 6 +-
.../flink/api/scala/operators/DistinctITCase.scala | 6 +-
.../flink/api/scala/operators/ExamplesITCase.scala | 6 +-
.../flink/api/scala/operators/FilterITCase.scala | 6 +-
.../flink/api/scala/operators/FirstNITCase.scala | 6 +-
.../flink/api/scala/operators/FlatMapITCase.scala | 6 +-
.../api/scala/operators/GroupCombineITCase.scala | 6 +-
.../api/scala/operators/GroupReduceITCase.scala | 6 +-
.../flink/api/scala/operators/JoinITCase.scala | 6 +-
.../flink/api/scala/operators/MapITCase.scala | 6 +-
.../api/scala/operators/OuterJoinITCase.scala | 6 +-
.../api/scala/operators/PartitionITCase.scala | 6 +-
.../flink/api/scala/operators/ReduceITCase.scala | 6 +-
.../flink/api/scala/operators/SampleITCase.scala | 6 +-
.../api/scala/operators/SortPartitionITCase.scala | 6 +-
.../api/scala/operators/SumMinMaxITCase.scala | 6 +-
.../flink/api/scala/operators/UnionITCase.scala | 6 +-
.../scala/runtime/ScalaSpecialTypesITCase.scala | 7 +-
.../flink/api/scala/util/DataSetUtilsITCase.scala | 6 +-
200 files changed, 768 insertions(+), 791 deletions(-)
copy {flink-clients =>
flink-connectors/flink-hadoop-compatibility}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
(100%)
copy
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/{AbstractTestBase.java
=> AbstractTestBaseJUnit4.java} (96%)
copy
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/{JavaProgramTestBase.java
=> JavaProgramTestBaseJUnit4.java} (98%)
copy
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/{MultipleProgramsTestBase.java
=> MultipleProgramsTestBaseJUnit4.java} (95%)
