You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/03/15 16:22:41 UTC
[flink] branch master updated (2710878 -> 7fe549e)
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 2710878 [FLINK-26650][checkpoint] Avoid to print stack trace for checkpoint trigger failure if not all tasks are started
add 7fe549e [FLINK-26582][table][tests] Convert table modules assertions to AssertJ
No new revisions were added by this update.
Summary of changes:
.../apache/flink/table/client/SqlClientTest.java | 27 +-
.../flink/table/client/cli/CliResultViewTest.java | 8 +-
.../table/client/cli/CliTableauResultViewTest.java | 240 ++++---
.../flink/table/client/cli/CliUtilsTest.java | 10 +-
.../client/gateway/context/SessionContextTest.java | 77 +--
.../table/client/gateway/local/DependencyTest.java | 33 +-
.../client/gateway/local/LocalExecutorITCase.java | 42 +-
.../local/result/BaseMaterializedResultTest.java | 7 +-
.../local/result/ChangelogCollectResultTest.java | 4 +-
.../result/MaterializedCollectBatchResultTest.java | 8 +-
.../MaterializedCollectStreamResultTest.java | 10 +-
.../flink/sql/parser/CreateTableLikeTest.java | 45 +-
.../flink/sql/parser/FlinkDDLDataTypeTest.java | 16 +-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 10 +-
.../sql/parser/TableApiIdentifierParsingTest.java | 5 +-
.../types/DecimalDataRandomGeneratorTest.java | 83 ++-
.../internal/StreamTableEnvironmentImplTest.java | 6 +-
.../table/factories/BlackHoleSinkFactoryTest.java | 19 +-
.../table/factories/CsvTableSinkFactoryTest.java | 19 +-
.../factories/DataGenTableSourceFactoryTest.java | 297 ++++----
.../table/factories/PrintSinkFactoryTest.java | 6 +-
.../flink/table/api/EnvironmentSettingsTest.java | 7 +-
.../apache/flink/table/api/TableConfigTest.java | 23 +-
.../flink/table/api/TableDescriptorTest.java | 103 ++-
.../catalog/CatalogBaseTableResolutionTest.java | 53 +-
.../flink/table/catalog/CatalogTableImpTest.java | 14 +-
.../catalog/GenericInMemoryCatalogFactoryTest.java | 14 +-
.../table/catalog/GenericInMemoryCatalogTest.java | 21 +-
.../flink/table/catalog/SchemaResolutionTest.java | 86 ++-
.../table/expressions/ObjectToExpressionTest.java | 5 +-
.../resolver/ExpressionResolverTest.java | 5 +-
.../flink/table/operations/QueryOperationTest.java | 44 +-
.../flink/table/typeutils/FieldInfoUtilsTest.java | 12 +-
.../AddBooleanBeforeReturnRewriterTest.java | 37 +-
.../table/codesplit/CodeRewriterTestBase.java | 6 +-
.../table/codesplit/JavaCodeSplitterTest.java | 16 +-
.../flink/table/codesplit/JavaParserTest.java | 7 +-
.../apache/flink/table/api/TableSchemaTest.java | 72 +-
.../api/constraints/UniqueConstraintTest.java | 10 +-
.../apache/flink/table/catalog/CatalogTest.java | 204 +++---
.../flink/table/catalog/CatalogTestUtil.java | 138 ++--
.../flink/table/connector/ProjectionTest.java | 192 +++---
.../connector/sink/TestManagedSinkCommitter.java | 4 +-
.../connector/sink/TestManagedSinkWriter.java | 4 +-
.../data/columnar/vector/ColumnVectorTest.java | 85 ++-
.../columnar/vector/VectorizedColumnBatchTest.java | 45 +-
.../descriptors/DescriptorPropertiesTest.java | 23 +-
.../table/descriptors/DescriptorTestBase.java | 4 +-
.../flink/table/expressions/ExpressionTest.java | 208 +++---
.../factories/TableFormatFactoryBaseTest.java | 6 +-
.../factories/TableSinkFactoryServiceTest.java | 12 +-
.../factories/module/CoreModuleFactoryTest.java | 4 +-
.../flink/table/plan/stats/TableStatsTest.java | 41 +-
.../flink/table/sources/TableSourceTestBase.java | 10 +-
.../types/LegacyTypeInfoDataTypeConverterTest.java | 12 +-
.../types/inference/TypeTransformationsTest.java | 10 +-
.../flink/table/utils/EncodingUtilsTest.java | 18 +-
.../flink/table/utils/PartitionPathUtilsTest.java | 24 +-
.../flink/table/utils/TableSchemaUtilsTest.java | 6 +-
.../flink/table/utils/TypeMappingUtilsTest.java | 20 +-
.../flink/table/utils/TypeStringUtilsTest.java | 35 +-
.../flink/table/utils/print/TableauStyleTest.java | 161 ++---
.../file/table/FileSystemTableFactoryTest.java | 168 ++---
.../apache/flink/table/api/EnvironmentTest.java | 7 +-
.../table/api/internal/StatementSetImplTest.java | 18 +-
.../planner/catalog/CatalogConstraintTest.java | 9 +-
.../flink/table/planner/catalog/CatalogITCase.java | 14 +-
.../planner/catalog/CatalogStatisticsTest.java | 147 ++--
.../planner/catalog/DatabaseCalciteSchemaTest.java | 18 +-
.../flink/table/planner/codegen/CodeSplitTest.java | 18 +-
.../codegen/EqualiserCodeGeneratorTest.java | 20 +-
.../planner/codegen/LongHashJoinGeneratorTest.java | 5 +-
.../planner/codegen/SortCodeGeneratorTest.java | 24 +-
.../planner/codegen/calls/BuiltInMethodsTest.java | 11 +-
.../planner/delegation/DefaultExecutorTest.java | 21 +-
.../table/planner/delegation/ParserImplTest.java | 15 +-
.../converter/ExpressionConverterTest.java | 117 ++--
.../factories/TestValuesRuntimeFunctions.java | 9 +-
.../planner/factories/TestValuesTableFactory.java | 3 +-
.../BuiltInAggregateFunctionTestBase.java | 16 +-
.../planner/functions/CastFunctionMiscITCase.java | 9 +-
.../ConstructedAccessFunctionsITCase.java | 45 +-
.../aggfunctions/AggFunctionTestBase.java | 4 +-
.../planner/functions/casting/CastRulesTest.java | 5 +-
.../planner/operations/MergeTableLikeUtilTest.java | 105 +--
.../operations/SqlToOperationConverterTest.java | 4 +-
.../plan/FlinkCalciteCatalogReaderTest.java | 7 +-
.../nodes/exec/common/CommonExecSinkITCase.java | 43 +-
.../MultipleInputNodeCreationProcessorTest.java | 7 +-
.../processor/utils/InputOrderCalculatorTest.java | 46 +-
.../utils/InputPriorityConflictResolverTest.java | 43 +-
.../utils/InputPriorityGraphGeneratorTest.java | 13 +-
.../exec/processor/utils/TopologyGraphTest.java | 61 +-
.../nodes/exec/serde/LogicalWindowSerdeTest.java | 10 +-
.../plan/nodes/exec/serde/LookupKeySerdeTest.java | 4 +-
.../nodes/exec/serde/PartitionSpecSerdeTest.java | 14 +-
.../exec/serde/RankProcessStrategySerdeTest.java | 4 +-
.../plan/nodes/exec/serde/RankRangeSerdeTest.java | 4 +-
.../plan/nodes/exec/serde/RankTypeSerdeTest.java | 4 +-
.../nodes/exec/serde/RexWindowBoundSerdeTest.java | 50 +-
.../plan/nodes/exec/serde/SortSpecSerdeTest.java | 11 +-
.../PushProjectIntoTableSourceScanRuleTest.java | 40 +-
.../runtime/batch/ParallelismSettingTest.java | 12 +-
.../batch/sql/CompactManagedTableITCase.java | 2 +-
.../stream/jsonplan/TemporalSortJsonITCase.java | 12 +-
.../runtime/stream/module/ModuleITCase.java | 16 +-
.../runtime/stream/sql/CompactionITCaseBase.java | 12 +-
.../runtime/stream/sql/DataStreamJavaITCase.java | 67 +-
.../planner/runtime/stream/sql/FunctionITCase.java | 308 +++------
.../stream/table/DataGeneratorConnectorITCase.java | 5 +-
.../runtime/stream/table/FunctionITCase.java | 7 +-
.../runtime/stream/table/PrintConnectorITCase.java | 29 +-
.../planner/runtime/stream/table/ValuesITCase.java | 12 +-
.../utils/JavaUserDefinedScalarFunctions.java | 2 +-
.../table/planner/typeutils/RowTypeUtilsTest.java | 21 +-
.../utils/CatalogTableStatisticsConverterTest.java | 13 +-
.../planner/utils/InternalConfigOptionsTest.java | 4 +-
.../table/planner/utils/JsonPlanTestBase.java | 3 +-
.../planner/utils/StreamExchangeModeUtilsTest.java | 57 +-
.../flink/table/data/BinaryArrayDataTest.java | 255 +++----
.../apache/flink/table/data/BinaryRowDataTest.java | 310 +++++----
.../flink/table/data/BinaryStringDataTest.java | 755 +++++++++++----------
.../flink/table/data/DataFormatConvertersTest.java | 22 +-
.../table/data/DataStructureConvertersTest.java | 6 +-
.../apache/flink/table/data/DecimalDataTest.java | 200 +++---
.../apache/flink/table/data/NestedRowDataTest.java | 38 +-
.../org/apache/flink/table/data/RowDataTest.java | 82 ++-
.../apache/flink/table/data/TimestampDataTest.java | 86 +--
.../table/data/binary/BinarySegmentUtilsTest.java | 69 +-
.../flink/table/data/util/DataFormatTestUtil.java | 4 +-
.../table/formats/raw/RawFormatFactoryTest.java | 121 ++--
.../formats/raw/RawFormatSerDeSchemaTest.java | 7 +-
.../table/runtime/generated/CompileUtilsTest.java | 11 +-
.../runtime/hashtable/BinaryHashTableTest.java | 161 +++--
.../table/runtime/hashtable/LongHashTableTest.java | 98 ++-
.../io/CompressedHeaderlessChannelTest.java | 4 +-
.../runtime/operators/aggregate/HashAggTest.java | 13 +-
.../window/SlicingWindowAggOperatorTest.java | 54 +-
.../operators/bundle/MapBundleOperatorTest.java | 16 +-
.../bundle/trigger/CountBundleTriggerTest.java | 10 +-
.../bundle/trigger/CountCoBundleTriggerTest.java | 14 +-
...niBatchDeduplicateKeepFirstRowFunctionTest.java | 6 +-
...iniBatchDeduplicateKeepLastRowFunctionTest.java | 10 +-
...niBatchLatestChangeDeduplicateFunctionTest.java | 22 +-
.../RowTimeWindowDeduplicateOperatorTest.java | 6 +-
.../operators/join/AsyncLookupJoinHarnessTest.java | 11 +-
.../operators/join/Int2HashJoinOperatorTest.java | 22 +-
.../join/Int2SortMergeJoinOperatorTest.java | 2 +-
.../join/RandomSortMergeInnerJoinTest.java | 147 ++--
.../join/RandomSortMergeOuterJoinTest.java | 179 +++--
.../operators/join/SortMergeJoinIteratorTest.java | 24 +-
.../join/interval/ProcTimeIntervalJoinTest.java | 42 +-
.../join/interval/RowTimeIntervalJoinTest.java | 70 +-
.../temporal/TemporalRowTimeJoinOperatorTest.java | 38 +-
.../join/window/WindowJoinOperatorTest.java | 86 +--
.../BatchMultipleInputStreamOperatorTest.java | 148 ++--
.../TableOperatorWrapperGeneratorTest.java | 126 ++--
.../multipleinput/TableOperatorWrapperTest.java | 98 ++-
.../input/InputSelectionHandlerTest.java | 31 +-
.../operators/multipleinput/input/InputTest.java | 33 +-
.../operators/multipleinput/output/OutputTest.java | 101 ++-
.../over/BufferDataOverWindowOperatorTest.java | 4 +-
.../over/NonBufferOverWindowOperatorTest.java | 4 +-
.../ProcTimeRangeBoundedPrecedingFunctionTest.java | 10 +-
.../RowTimeRangeBoundedPrecedingFunctionTest.java | 12 +-
...RowTimeRangeUnboundedPrecedingFunctionTest.java | 4 +-
.../RowTimeRowsBoundedPrecedingFunctionTest.java | 4 +-
.../RowTimeRowsUnboundedPrecedingFunctionTest.java | 4 +-
.../rank/window/WindowRankOperatorTest.java | 4 +-
.../operators/sink/SinkUpsertMaterializerTest.java | 7 +-
.../operators/sort/BinaryExternalSorterTest.java | 39 +-
.../operators/sort/BinaryMergeIteratorTest.java | 9 +-
.../sort/BufferedKVExternalSorterTest.java | 9 +-
.../table/runtime/operators/sort/SortUtilTest.java | 15 +-
.../source/InputConversionOperatorTest.java | 52 +-
.../operators/window/MergingWindowSetTest.java | 342 +++++-----
.../window/WindowOperatorContractTest.java | 4 +-
.../operators/window/WindowOperatorTest.java | 43 +-
.../runtime/operators/window/WindowTestUtils.java | 30 -
.../assigners/CumulativeWindowAssignerTest.java | 180 +++--
.../assigners/SessionWindowAssignerTest.java | 29 +-
.../assigners/SlidingWindowAssignerTest.java | 210 +++---
.../assigners/TumblingWindowAssignerTest.java | 29 +-
.../window/grouping/HeapWindowsGroupingTest.java | 15 +-
.../slicing/CumulativeSliceAssignerTest.java | 303 ++++-----
.../window/slicing/HoppingSliceAssignerTest.java | 225 +++---
.../window/slicing/SliceAssignerTestBase.java | 15 +-
.../window/slicing/TumblingSliceAssignerTest.java | 69 +-
.../window/slicing/WindowedSliceAssignerTest.java | 131 ++--
.../operators/window/triggers/TriggersTest.java | 39 +-
.../ProcTimeMiniBatchAssignerOperatorTest.java | 22 +-
.../RowTimeMiniBatchAssginerOperatorTest.java | 10 +-
.../wmassigners/WatermarkAssignerOperatorTest.java | 33 +-
.../WatermarkAssignerOperatorTestBase.java | 7 +-
.../runtime/types/DataTypePrecisionFixerTest.java | 4 +-
.../runtime/types/LogicalTypeAssignableTest.java | 10 +-
.../runtime/typeutils/RowDataSerializerTest.java | 4 +-
.../runtime/typeutils/SerializerTestUtil.java | 4 +-
.../runtime/util/ResettableExternalBufferTest.java | 132 ++--
.../table/runtime/util/RowDataHarnessAssertor.java | 10 +-
.../table/runtime/util/TimeWindowUtilTest.java | 114 ++--
.../collections/binary/BytesHashMapTestBase.java | 69 +-
.../collections/binary/BytesMultiMapTestBase.java | 5 +-
203 files changed, 4944 insertions(+), 5387 deletions(-)
delete mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/window/WindowTestUtils.java