This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 5c41e7bc0a9 [FLINK-27718][hive] Fix fail to count mutiple fields
excpetion in Hive dialect (#19406)
add 9955c85a53d [FLINK-28659][flink-java][JUnit5 Migration] Migrate
flink-java to use junit5.
No new revisions were added by this update.
Summary of changes:
.../flink/hadoopcompatibility/HadoopUtilsTest.java | 6 +-
.../api/common/io/SequentialFormatTestBase.java | 98 +-
.../flink/api/common/io/SerializedFormatTest.java | 28 +-
.../CollectionExecutionAccumulatorsTest.java | 15 +-
.../CollectionExecutionIterationTest.java | 58 +-
...llectionExecutionWithBroadcastVariableTest.java | 29 +-
.../base/CoGroupOperatorCollectionTest.java | 50 +-
.../operators/base/GroupReduceOperatorTest.java | 59 +-
.../operators/base/InnerJoinOperatorBaseTest.java | 66 +-
.../common/operators/base/ReduceOperatorTest.java | 32 +-
.../java/ExecutorDiscoveryAndJobClientTest.java | 13 +-
.../flink/api/java/MultipleInvokationsTest.java | 27 +-
.../apache/flink/api/java/TypeExtractionTest.java | 12 +-
.../api/java/functions/SelectByFunctionsTest.java | 207 ++-
.../api/java/functions/SemanticPropUtilTest.java | 1483 +++++++++++---------
.../SemanticPropertiesPrecedenceTest.java | 38 +-
.../SemanticPropertiesProjectionTest.java | 207 +--
.../SemanticPropertiesTranslationTest.java | 455 +++---
.../apache/flink/api/java/io/CSVReaderTest.java | 242 ++--
.../api/java/io/CollectionInputFormatTest.java | 58 +-
.../flink/api/java/io/CsvInputFormatTest.java | 602 ++++----
.../flink/api/java/io/CsvOutputFormatTest.java | 34 +-
.../apache/flink/api/java/io/FromElementsTest.java | 21 +-
.../api/java/io/PrimitiveInputFormatTest.java | 71 +-
.../api/java/io/PrintingOutputFormatTest.java | 48 +-
.../flink/api/java/io/RowCsvInputFormatTest.java | 467 +++---
.../flink/api/java/io/TextInputFormatTest.java | 102 +-
.../api/java/io/TypeSerializerFormatTest.java | 33 +-
.../api/java/operator/AggregateOperatorTest.java | 55 +-
.../api/java/operator/CoGroupOperatorTest.java | 360 +++--
.../flink/api/java/operator/CrossOperatorTest.java | 153 +-
.../flink/api/java/operator/DataSinkTest.java | 147 +-
.../api/java/operator/DistinctOperatorTest.java | 83 +-
.../api/java/operator/FirstNOperatorTest.java | 111 +-
.../java/operator/FullOuterJoinOperatorTest.java | 77 +-
.../java/operator/GroupCombineOperatorTest.java | 287 ++--
.../api/java/operator/GroupReduceOperatorTest.java | 287 ++--
.../flink/api/java/operator/GroupingTest.java | 344 ++---
.../flink/api/java/operator/JoinOperatorTest.java | 656 ++++-----
.../java/operator/LeftOuterJoinOperatorTest.java | 72 +-
.../flink/api/java/operator/MaxByOperatorTest.java | 102 +-
.../flink/api/java/operator/MinByOperatorTest.java | 97 +-
.../flink/api/java/operator/OperatorTest.java | 20 +-
.../api/java/operator/PartitionOperatorTest.java | 194 ++-
.../api/java/operator/ProjectionOperatorTest.java | 99 +-
.../api/java/operator/ReduceOperatorTest.java | 170 +--
.../java/operator/RightOuterJoinOperatorTest.java | 70 +-
.../flink/api/java/operator/SortPartitionTest.java | 161 ++-
.../apache/flink/api/java/operators/NamesTest.java | 34 +-
.../translation/AggregateTranslationTest.java | 26 +-
.../translation/BulkIterationTranslationTest.java | 18 +-
.../translation/CoGroupSortTranslationTest.java | 67 +-
.../translation/DeltaIterationTranslationTest.java | 69 +-
.../translation/DistinctTranslationTest.java | 115 +-
.../translation/ReduceTranslationTests.java | 76 +-
.../translation/UnionTranslationTest.java | 42 +-
.../flink/api/java/sampling/RandomSamplerTest.java | 183 +--
.../aggregation/AggregateCombineHarness.java | 2 +-
.../aggregation/BooleanSummaryAggregatorTest.java | 63 +-
.../BooleanValueSummaryAggregatorTest.java | 12 +-
.../summarize/aggregation/CompensatedSumTest.java | 32 +-
.../aggregation/DoubleSummaryAggregatorTest.java | 204 +--
.../DoubleValueSummaryAggregatorTest.java | 17 +-
.../aggregation/FloatSummaryAggregatorTest.java | 201 ++-
.../FloatValueSummaryAggregatorTest.java | 17 +-
.../aggregation/IntegerSummaryAggregatorTest.java | 148 +-
.../IntegerValueSummaryAggregatorTest.java | 43 +-
.../aggregation/LongSummaryAggregatorTest.java | 158 +--
.../LongValueSummaryAggregatorTest.java | 43 +-
.../aggregation/ShortSummaryAggregatorTest.java | 150 +-
.../ShortValueSummaryAggregatorTest.java | 43 +-
.../aggregation/StringSummaryAggregatorTest.java | 74 +-
.../StringValueSummaryAggregatorTest.java | 23 +-
.../aggregation/SummaryAggregatorFactoryTest.java | 89 +-
.../api/java/utils/AbstractParameterToolTest.java | 506 ++++---
.../api/java/utils/MultipleParameterToolTest.java | 48 +-
.../apache/flink/api/java/utils/OptionsTest.java | 70 +-
.../flink/api/java/utils/ParameterToolTest.java | 55 +-
.../flink/api/java/utils/PlanGeneratorTest.java | 23 +-
.../api/java/utils/RequiredParametersTest.java | 187 +--
.../org.junit.jupiter.api.extension.Extension | 0
81 files changed, 5212 insertions(+), 5732 deletions(-)
copy {flink-clients =>
flink-java}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
(100%)
