You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/09/29 08:34:42 UTC
[flink] branch dependabot/maven/flink-connectors/flink-connector-jdbc/org.postgresql-postgresql-42.4.1 updated (4f20a0b31a5 -> a1acdab8a5b)
This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch dependabot/maven/flink-connectors/flink-connector-jdbc/org.postgresql-postgresql-42.4.1
in repository https://gitbox.apache.org/repos/asf/flink.git
discard 4f20a0b31a5 Bump postgresql in /flink-connectors/flink-connector-jdbc
add 3e1018e0cbc [FLINK-27619][sql] Support NTILE Function
add 8ac7e9724a6 [FLINK-27619][sql] fix use wrong constant for over window.
add bca84305750 [FLINK-28570][table-planner] Extends FlinkRelOptUtil to support print upsertKey info
add 5daebae30b9 [FLINK-28570][table-planner] Append upsertMaterialize info by a simpler way of overriding the explainTerms method for StreamPhysicalSink
add 512e4e0f2de [FLINK-28570][table-planner] Introduces a base class StreamPhysicalGroupWindowAggregateBase for all related sub-classes
add a4189170dce [FLINK-28570][table-planner] Extracts common attributes into StreamPhysicalGroupAggregateBase for all sub-classes
add fa3aa8f3759 [FLINK-28570][table-planner] Optimize upsertKey inference for lookup join and fix ConnectorCatalogTable lost pk on stream source
add fd6c1cc96ce [FLINK-28570][table-planner] Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or error
add cf1a29d47a5 [FLINK-27524][datastream] Introduce cache API to DataStream
add 6d06cdaa163 [FLINK-28772][hive] Supports ADD JAR command in Hive dialect
add 1a094eb3619 [FLINK-28772][hive] Improve exception messages for ADD JAR
add 62786320eb5 [FLINK-28834][examples-table] Add temporal join example and IT test
add 33c550052c5 [hotfix][tests] Remove unnecessary mock
add fb95798b1c3 [FLINK-28807] Honor schema lifecycle
add 9bda6779562 [FLINK-28709][source] Introduce coordinatorListeningID in SourceCoordinator to listen to events from other coordinators
add 3a8e71e286d [FLINK-28709][table] Introduce DynamicFilteringData and the DynamicFilteringDataCollectorOperator to build and distribute the data
add b0859789e77 [FLINK-28709][table] Introduce ExecutionOrderEnforcerOperator to ensure the source with dynamic filtering is executed after the DynamicFilteringData is collected
add 05de0a295ef [FLINK-28826][network] Avoid notifying too frequently when recycling buffers for BatchShuffleReadBufferPool
add 07a309ad934 [FLINK-28828][network] Improvements for sort-shuffle data reading
add b6cc5b24c0e [FLINK-28782][python][connector/filesystem] FileSink supports compaction
add 2176ec0aa13 [FLINK-28710][table-planner] The fact source of DPP must be FLIP-27 source
add 8011f139dfa [FLINK-28710][table-planner] Supports dynamic filtering execution
add 782982fc99b [FLINK-28633][sql-gateway][hive] Allow to GetTables in the HiveServer2 Endpoint
add e47cb6eeb4c [FLINK-28822][python] Avoid creating VectorizedColumnBatch for each read in ArrowReader (#20458)
add 437978fdf8a [FLINK-28234][table-planner] Fix Infinite or NaN exception in ExpressionReducer
add 3aaa160bd80 [FLINK-28851][sql-gateway][hive] Remove useless OperationType
add 29ca0ad8e33 [FLINK-28851][hive] Allow to GetTypeInfo in the HiveServer2 Endpoint
add c5c66af680e [FLINK-27790][table] Port ADD JAR & SHOW JARS syntax implementation from SqlClient to TableEnvironment side
add 823611b1d4d [FLINK-27790][table] Revert changes to AddJarOperation
add d19a0a7b650 [FLINK-27790][table] Fix test failure in set.q and function.q of SQL Client
add fe9c726ac1a [FLINK-27790][table] Fix NoClassDefFoundError of guava in UsingRemoteJarITCase
add bc76a93239e [FLINK-28420][table] Support partial caching in sync and async lookup runner
add d137c12877f [FLINK-28688][python] Support DataStream PythonWindowOperator in Thread Mode
add d17dcbd43b2 [FLINK-28678][table-planner] Copy some nodes from calcite, and need revert when upgrade calcite-1.31
add 4e46602342f [FLINK-28678][table-planner] Support SQL hint for Filter, SetOp, and etc. Mainly cherry-pick from [calcite-5107]
add 53f1a66f67c [FLINK-28682][table-planner] Copy SqlToRelConverter from calcite
add f794d72903c [FLINK-28682][table-planner] Support join hint in batch rules
add caef5b7a5c1 [FLINK-28713][yarn] Bump curator-test dependency
add ca45a28205b [FLINK-28823][network] Consider the actual number of subpartition readers when requesting buffers for SortMergeResultPartitionReadScheduler
add 9dd2b19995b [FLINK-27966][python] Make the connector imports more explicit by adding connector type
add 4cf0b81d4f4 [hotfix][python][tests] Split the test cases of connectors & formats into separate files
add 1c40dc15fbc [FLINK-28827][python] Complete DataType support in DataStream API (#20460)
add ff91aa53cfc [FLINK-28836][python] Support broadcast in Thread Mode
add 6886e444c2b [FLINK-28599][table-planner] Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join
add ac0bbe608f5 [FLINK-28793][sql-gateway][hive] Allow to GetInfo in the HiveServer2 Endpoint
add 7047916a487 [FLINK-28788][python] Support SideOutput in Thread Mode
add 94411a169a1 [FLINK-23143][state/changelog] Support state migration for ChangelogStateBackend
add a267dcfeae7 [refactor][state] Rename createInternalState to createOrUpdateInternalState
add 413912d7fd3 [hotfix][python] Make the format imports more explicit by adding format type
add b3be6bbd9c9 [hotfix][tests] Migrate tests relevant to FLINK-28663 to Junit5/AssertJ
add 72405361610 [FLINK-28663][runtime] Allow multiple downstream consumer job vertices sharing the same intermediate dataset at scheduler side
add d442384309a [hotfix][csv][tests] Open schemas
add 9a967c010a5 [FLINK-28621][formats] Initialize mappers in open()
add c0bf0ac3fb1 [FLINK-28621][core] Add central Jackson mapper factory methods
add 328007f0b9a [FLINK-28621] Enable Date/Time&Optional support for all mappers
add 28e952631bb [FLINK-28094][kinesis] Removing references to Regions enum and instead using RegionUtils so that we include future AWS Regions as well
add 15e60e6cc5f [FLINK-23252][state/changelog] [docs] Update the docs about disabling changelog
add aaea1adc155 [FLINK-28865] Add new PrintSink
add 60bc87c0b83 [FLINK-28380][runtime] Produce one intermediate dataset for multiple consumer job vertices consuming the same data
add 5c731a37e1a [FLINK-24614][parquet] Support complex types (arrya, map, row) for parquet reader
add def2f543809 [FLINK-28631][sql-gateway][hive] Support to GetFunctions in the HiveServer2Endpoint
add fcde111410d [hotfix][sql-gateway] Use camelCase for REST request/response body fields in session related APIs.
add 91eccea38c8 [FLINK-28162][sql-gateway]Introduce the operation related API for REST endpoint
add 41bde65874c [FLINK-28164][sql-gateway]Introduce utilities API for REST endpoint
add 47970b0435a [FLINK-28163][sql-gateway]Introduce the statement related API for REST endpoint
add af7c775ab57 [hotfix] Migrate PipelinedRegionSchedulingStrategyTest and StrategyTestUtil to Junit5 and AssertJ.
add b01730579fa [FLINK-28799] PipelinedRegionSchedulingStrategy maintain scheduled regions
add 4deaf6edc15 [FLINK-28799] PipelinedRegionSchedulingStrategy supports all resultPartitionType.
add 5506930cc79 [FLINK-28183][python] Model python test dependencies in Maven
add 0e6e4198ad8 [FLINK-28753][table-planner] Improve FilterIntoJoinRule which could push some predicates to another side
add 7f708d0ba42 [FLINK-28843][StateBackend] Fix restore from incremental checkpoint with changelog checkpoint in claim mode
add 3f18cafa058 [FLINK-28568][table-runtime] Implements a new lookup join operator (sync mode only) with state to eliminate non-deterministic result
add d9a067e5e1c [FLINK-28699][state] Make non-incremental rocksdb checkpoint as native format
add a08b050eb9f [FLINK-28880][docs][cep] Fix wrong result of strict contiguity of looping patterns
add 1ec4acd2c99 [FLINK-27155][changelog] Reduce multiple reads to the same Changelog file in the same taskmanager during restore
add d2704b111a2 [FLINK-28094][kinesis][glue] Updating AWS SDK versions for Kinesis connectors and Glue Schema Registry formats
add 6c91cc59998 [FLINK-26413][hive] Supports "LOAD DATA INPATH" in Hive dialect
add d6a47d897a9 [FLINK-28373][network] Read a full buffer of data per file IO read request for sort-shuffle
add 61374638c02 [FLINK-25485][connector/jdbc] Add default jdbc option 'rewriteBatchedStatements' for MySQL dialect
add b442394c65b [FLINK-28785][network] Hybrid shuffle consumer thread and upstream thread may have deadlock.
add 2c56c40e55e [hotfix][build][hbase] Remove unused property
add 5fb135e23e3 [FLINK-25244][hbase] Enable Java 11 tests for HBase 2.2
add 208f08b406a [FLINK-28860][tests] Disable CacheITCase temporarily
add 0dc8890f1b8 [FLINK-28711][hive] Hive source supports dynamic filtering
add 1f9632a0719 [FLINK-27693][changelog] Support local recovery for non-materialized part
add 52eb7e76b5d [FLINK-27693][docs] Remove local recovery from the Limitations of changelog
add 9ed70a1e8b5 [FLINK-28178][runtime-web] Show the delegated StateBackend and whether changelog is enabled in the UI
add 1486743ef3d [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks
add 7be6783cb22 [FLINK-28606][Runtime/Checkpointing] Refractor coordination tests with JUnit5 Assertions
add 15f87d4a470 [FLINK-28873][configuration] Make jobmanager.scheduler visible in documentation
add 3c8402a97a2 [FLINK-28854][connector/jdbc] Migrate JDBC lookup table to the new LookupFunction and caching interface
add f53dd03fd5f [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy for AsyncSinkWriter
add 64b430b0738 [hotfix][python] Refactor thread mode Python runtime to make it more readable
add 1719ff85b8e [FLINK-28871][table-planner] Force the output edges of dynamic filtering data collector to be BLOCKING
add 21712c932cd [FLINK-28857][docs] Add Document for DataStream Cache API
add e92b87df738 [hotfix] Migrate PartitionFileWriteReadTest, SortMergeResultPartitionReadSchedulerTest, SortMergeSubpartitionReaderTest to Junit5 and AssertJ
add 87d4f70e492 [FLINK-28623][network] Optimize the use of off-heap memory by blocking and hybrid shuffle reader
add de8ff096a53 [FLINK-28862][python][format/parquet] Support ParquetBulkWriter
add fda2bdd05c7 [FLINK-28886][python] Support HybridSource in Python DataStream API
add 6fb49b1d708 [FLINK-28778][SQL/API] Bulk fetch of table and column statistics for given partitions
add 43eda5d3fe2 [FLINK-28797][hive] HiveSource enables vector reading for complex data type with parquet format
add 9237e63bd8a [FLINK-28797][hive] Simplify useModules for the parquet complex type tests
add 6b20433e7f0 [FLINK-28731][conf] Log dynamic properties
add 10a6f41fa12 [FLINK-28532][table] Support full caching in lookup join runner using InputFormats as scan runtime provider (#20447)
add 6b725d13153 [FLINK-28529][state/changelog] Fix unstable ChangelogPeriodicMaterializationSwitchStateBackendITCase#testSwitchFromDisablingToEnablingInClaimMode
add c5a8b0f3c29 [refactor][state/changelog] Rename ChangelogPeriodicMaterialization* to ChangelogRecovery*
add bf81768ff56 [FLINK-28868][connector/hbase] Migrate HBase table connector to the new LookupFunction interface
add cf3beff586a [FLINK-28876][python][format/orc] Support Orc format
add be5893c582e [hotfix] Migrate RestartPipelinedRegionFailoverStrategyTest to Junit5 and AssertJ.
add bfe64603242 [FLINK-28701] Split HYBRID result partition type to HYBRID_FULL and HYBRID_SELECTIVE.
add 9df886e222e [FLINK-28701] RestartPipelinedRegionFailoverStrategy takes reConsumable into account when decide partition available.
add 56e91700ca5 [FLINK-28701] Remove WIP prefix of ALL_EXCHANGE_HYBRID_FULL and ALL_EXCHANGE_HYBRID_SELECTIVE in BatchShuffleMode and expose them to documents.
add dd16b080130 [FLINK-27338][hive] Improve splitting file for Hive source
add 10acb641a03 [FLINK-26929][table-runtime] Introduce adaptive hash join strategy for batch hash join (#20365)
add 320f4cd5e5f [FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp
add f2ec01241c5 [FLINK-28481][k8s] Bump the fabric8 kubernetes client to 5.12.3
add 22dba69f16d [FLINK-28774][hive] Allow user to configure whether to enable sort not when it's for dynamic partition writing for HiveSource
add d0a5023f989 [FLINK-28632][sql-gateway][hive] Allow to GetColumns/GetPrimaryKeys/GetTableTypes in the HiveServer2 Endpoint
add 8b25b969d41 [FLINK-28848][table-planner] Introduces LOOKUP join hint to support delayed retry for lookup join (table alias unsupported in hint)
add fa6d62dd6bb [hotfix][table-planner] Use scala isInstanceOf to check lookup function type instead of one-level parent class compartion in LookupJoinCodeGenerator
add 3a2fc5ef34f [hotfix][runtime] Do last attempt without successfully canceling the retry timer to prevent unexpected incomplete element during finish phase in AsyncWaitOperator
add c5b5d436843 [FLINK-28849][table-planner] Fix errors when enable retry on async lookup and add more tests
add bc9b401ed1f [FLINK-28060][kafka] Bump Kafka to 3.2.1
add 07858933aac [hotfix][python] Move json/avro/csv SerializationSchema implementations into the corresponding files
add 6844be2128d [FLINK-28895][python] Perform RowRowConverter automically when writing RowData into sink
add 465db25502e [FLINK-28904][python][docs] Add missing connector/format documentation
add 3268ec6a7ce [FLINK-28898][state/changelog] Fix unstable ChangelogRecoverySwitchStateBackendITCase#testSwitchFromEnablingToDisablingWithRescalingOut
add dea5f09017a [FLINK-28900] Fix RecreateOnResetOperatorCoordinatorTest compilation failure
add 3143526637e [FLINK-28783] [flink-core] Fix typo in ConfigOptions's example code
add 0f376641e88 [FLINK-28884] HsSubpartitionView should be initialized to a notifiable state.
add 0b5aa420180 [FLINK-28884] Reset needNotify to true when get a zero backlog.
add e39fb24ecd7 [FLINK-28888] The statistics of HsResultPartition are not updated correctly
add 4739a5c88cc [FLINK-27588][python][docs] Update broadcast state related documentation (#20550)
add 4ebb787ff35 [FLINK-28887][python] Fix the bug of custom metrics in Thread Mode
add 8813a5ac914 [FLINK-28767][sql-gateway] Fix unstable SqlGatewayServiceITCase.testCancelOperation
add 5e554c17742 [FLINK-27856][k8s] Fix the NPE when no spec is configured in pod template
add bbccea04093 [hotfix][python][dcos] Fix the typos in the Metrics Doc
add 5fb8d24c1c3 [FLINK-28921][python][docs] Optimize the Python DataStream Window Documentation
add 88b309b7dca [FLINK-27570][runtime] Count checkpoint finalization failures in CheckpointFailureManager
add 7cf71585a60 [FLINK-28626][tests] Fix unstable RescaleCheckpointManuallyITCase when unaligned checkpoint is enabled
add f2fb6b20ec4 [FLINK-28942][network] Fix the deadlock bug when recycling readers for SortMergeResultPartition
add 18d21a0618f [FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint. (#19972)
add ea3b44183a8 [FLINK-28932][Table/SQL] Remove use of deprecated method
add 1455e51c7cd [FLINK-26771][hive] Fix incomparable exception between boolean type and numeric type in Hive dialect
add 6e80d90b161 [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint (#20530)
add 1232629c80c [FLINK-28855][hive] Fix 'Table.INDEX_TABLE' not found in the Hive3 (#20514)
add 15c422b483e [FLINK-28208][hive] Set parallelism for map operator in class HiveTableSink's method createBatchSink (#20471)
add a62c5a35aa2 [FLINK-28944][python][docs] Update the Python execution mode documentation
add 5f8f387cba7 [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase
add 9b50ff584ec [FLINK-28908][python] Fix LIST type in Python DataStream API
add 662f9de97ff [FLINK-28795][hive] Fix unstable test in HiveDialectQueryITCase
add 7661af066f5 [FLINK-28916][e2e] Add e2e test for create function using jar syntax (#20545)
add cb4ead75d59 [FLINK-28913][hive] Fix failed to open HiveCatalog when it's for hive3 (#20573)
add b1428603527 [FLINK-28861][table] Make UID generation behavior configurable and plan-only by default
add 881b2bf046e [FLINK-28861][table] Fix bug in UID format for future migrations and make it configurable
add cd173e71162 [FLINK-28899][table-planner] Fix LOOKUP hint with retry option on async lookup mode
add 00cded67075 [FLINK-28773][hive] Allow to write a success file after finish for Hive sink in batch mode
add c3072db5f08 [FLINK-28773][hive] Improve tests of writing success files
add b66680bb658 [FLINK-28773][hive] Fix the NPE of FileSystemOutputFormat#finalizeGlobal
add 226f1602c04 [FLINK-28003][sql-client] Disable SqlCompleter when using -f {file} in SQL Client
add f2abb51ac91 [FLINK-28548][filesystem] Fix FileNotFoundException when the commit partition base path is not created
add 0a10112f34e [hotfix][files] Fix the compile problem of FileSystemCommitterTest
add a17ff2b9f65 [FLINK-28955][yarn] Add direct curator-test dependency
add bd274ca8a1b [FLINK-28994][runtime-web] Enable withCredentials for outgoing HTTP requests
add 24ac1215883 [FLINK-27386][hive] Fix assert exception when specific join hint in union statement (#19583)
add 479ddeaa02a [FLINK-26505][hive] Support non equality condition for left semi join in Hive dialect. (#18994)
add 435dab64f61 [FLINK-27015][hive] Fix exception for casting timestamp to decimal in Hive dialect (#20571)
add f7af9f6462b [FLINK-27917][Connector/Pulsar] Drop Consumer.seek() in the testing method for fixing the race condition. (#20567)
add a9d5def8471 [FLINK-28925][runtime] HsSubpartitionMemeoryDataManager return a readOnlySlice to downstream instead of original buffer.
add 7ed817f2054 [FLINK-28925][runtime] Fix the NPE problem caused by double release buffer.
add f8bfb59b57f [FLINK-28861][table][docs] Update "upgrading" documentation to include notice regarding the Table API operator issue
add 59843ae275c [FLINK-28780][docs] Fix incorrect description of function dayofmonth. (#20424)
add 39300144339 [FLINK-28922][docs-zh] Translate "ORDER BY clause" page into Chinese.
add ae7f325a358 [FLINK-28924][docs-zh] Translate "LIMIT clause" page into Chinese.
add a42e7373f79 [FLINK-28978][kinesis] Update AWS Regions validation to allow for future AWS regions
add 3c2fa303074 [FLINK-28488][kafka] Only forward measurable Kafka metrics and ignore others
add 56a7c847df1 [FLINK-28996][datadog] Move parameter parsing into factory
add 7e7fd76078e [FLINK-28997][datadog] Add switch to use logical identifier
add 62e53e0e672 [hotfix][docs] Fix typo
add 3e6f47c9d36 [FLINK-29002][datadog] Deprecate 'tags' option
add 0be27a5e7b8 [FLINK-29007][e2e] Add missing hadoop-hdfs-client with Hadoop 3
add 22f574fc660 [FLINK-28951][table-planner] Make header with one line comments
add bdffb6bd4ae [FLINK-28986][table-planner] UNNEST function with nested filter fails to generate plan
add b550e3f59d0 [FLINK-28963][sql-gateway] Add REST API compatibility test
add b2c9e00d8a5 [FLINK-28800][network] BatchShuffleReadIOExecutor using ScheduledExecutorService instead of ExecutorService.
add 5d13403429d [FLINK-28800][network] HsFileDataManager should avoid busy-loop when fileReader has not data to read
add 06e8b7fb30f [FLINK-28990][table-planner] Fix BatchPhysicalDynamicFilteringDataCollector with empty output type
add e967a7b54da [FLINK-28965][hive] Partition shouldn't be created if no data is generated for dynamic partition
add d9516238cef [FLINK-28917][table-runtime] Add SQL test for adaptive hash join
add 682ec6a5d73 [FLINK-28956][hive] Fix non-multi insert statement fall into multi insert logic in Hive dialect (#20572)
add f6fbb8ac185 [FLINK-29017][docs] Replace all links to github master with shortcode
add 335cfe21d72 [hotfix][flink-runtime] Fix the task class typo
add f0a6c0cbd83 [FLINK-29034] HYBRID_FULL result partition type is not yet reConsumable
add e9f8c791f9f [FLINK-29009][build] Converge nimbus-jose-jwt
add d524e1dc3fd [FLINK-29009][build] Converge okio
add d402fe255cd [FLINK-28987][table-planner] Fix incorrect async to sync lookup fallback path of LegacyTableSourceTable
add ef97c651f06 [FLINK-28987][table-planner] Refine description of lookup join transformation with async params and retry strategy for easier debugging
add 77ea6638f15 [FLINK-28972][python][connector/pulsar] Align Start/StopCursor methods with the Java API
add 97519d1683f [FLINK-29028][python][docs] Align DataStream.cache in Python DataStream API
add 10e4c829021 [FLINK-28992][table-planner] Fix: Change Ndv takes the max value instead of sum of all partitions when getting partition table column stats
add 042e1b8b785 [hotfix][build] Use ${flink.shaded.version} for flink-docs and flink-runtime
add 0ffb3ed7437 [hotfix][build] Add japicmp exclusion for getSideOutput incompatibility
add d21ab7ba816 [hotfix][build] Fix streaming-java oldVersion artifactId
add 65046d573bc [FLINK-29051][quickstarts] Do not create dependency-reduced-pom
add 70d9f6c31b2 [FLINK-28139][docs] Add documentation for speculative execution
add 803027a1527 [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files
add b7c6116c98d [FLINK-29012][docs] Fix incorrect description of function minus
add 58296bfd987 [FLINK-29036][docs] Cleanup Source documentation
add 2322791284e [FLINK-28995][hive] HiveSourceDynamicFileEnumerator filters out a partition without matching if one of the fields is null but its type is not nullable
add 9201f1e3684 [hotfix][core][table] Use ReadableConfig were applicable
add cb26f08ee82 [hotfix][streaming-java] Avoid deep copy in StreamExecutionEnvironment.getConfiguration
add 4befe480319 [hotfix][table] table.resource.download.dir -> table.resources.download-dir
add 56ac1dc4d5c [hotfix][table-api-java] Small improvements to TableConfig
add eb69b11532e [FLINK-29014][streaming-java][table] Improve end-to-end story about PipelinesOptions.JARS
add ee4d27411b3 [FLINK-28977] NullPointerException in HybridSourceSplitEnumerator.close (#20587)
add 1a0f591a59b [FLINK-28993][table-planner] Refactor SupportsDynamicFiltering to provide getAcceptedFilterFields method to avoid modifing the DynamicTableSource object if calling applyDynamicFiltering method in join reorder rules
add 1ed1deb351b [FLINK-28993][table-planner] Fix adjusting join cost for dpp query pattern error
add 254b276c79a [FLINK-29041][tests] Add utility to test POJO compliance without any Kryo usage
add cb507651368 [FLINK-28735][scripts] Deprecate jobmanager.sh host/port parameters
add 90d8de66b29 [FLINK-29030][core] Add constant for generic type doc reference
add bbf74f2e8ad [FLINK-29030][core] Note that generic types can affect schema evolution
add 01fb742d094 [FLINK-29030][core] Log a message if any tuple/pojo field is handle as generic type
add 4409d96514b [FLINK-29016][docs] Clarify Kryo limitations w.r.t. data-structures
add aae96d0c9d1 [FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent
add 221d70d9930 [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese
add 64f11ee9549 [FLINK-28936][sql-gateway] Fix REST endpoint can not serialize uncompacted LogicalType (#20617)
add 58c4be49001 [FLINK-28841][scripts][docs] Document dynamic properties support
add fcaa4f77e0b [FLINK-29081][table-planner] Capitalize join hints to avoid case sensitive
add 7166625ff78 [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax
add 0af535a9134 [FLINK-29029][python] Fix the bug of InternalTypeInfo mapping to IdentityConverter in Thread Mode
add fe392645421 [FLINK-29059][table-planner] Fix the existing column stats are deleted incorrectly when analyze table for partial columns
add cdc4f4b100d [FLINK-28177][Connectors/ElasticSearch] Fix the unstable Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey
add b1db372c1e9 [hotfix][sql-gateway]Modify url in operation related message headers
add ad68495bb64 [hotfix][sql-gateway]Modify the response format and adjust SqlGatewayRestEndpointFactory
add 221fb98daa8 [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway
add 0fd718c03d8 fixup! [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway
add 60e594414a7 [FLINK-29096][table] Add test for json_value, which json path has blank characters.
add 3149c621671 [FLINK-29096][table] Update documentation for JSON_VALUE special characters
add a38b852bbbd [hotfix][state] Extract PeriodicMaterializationManager into state-backend-common
add aaa35607866 [hotfix][tests] Use negative changelog materialization interval in tests
add 0e083c119b2 [hotfix][state] Fix logging in Materializer and make FLINK-28976 more explicit
add 91e1291e942 [FLINK-28976][state] Don't add extra delay to the 1st materialization
add d501b88be55 [FLINK-29046][Connectors/Hive] Fix HiveTableSourceStatisticsReportTest fails with Hive 3.x
add c086a91d977 [FLINK-27175][hive] Fix fail to call Hive UDAF when the UDAF accepts one parameter with array type
add 0ade193d393 [FLINK-29035][table-planner] Fix bug of ExpressionReducer does not work with jar resources
add 4399b3fc40d [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode
add c643a2953ba [FLINK-29056] Throw PartitionNotFoundException if the partition file is not readable for hybird shuffle.
add 7b394a3ddd5 [FLINK-29105][k8s] Fix the unstable k8s test 'testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents'
add b63424ec7ab [hotfix] Add TaskManager id in the exception message
add e246a05cd89 [FLINK-29121][sql-gateway] Fix failed SqlGatewayRestAPIStabilityTest
add d61a7a9c2bd [hotfix][tests] Nicer migration path for typo fix
add 7ac37c08918 [FLINK-29062][build] Fix protobuf plugin proxy issue on flink-protobuf module.
add aa3c124b536 [FLINK-27030][tests] Prevent race-condition
add d0434e698fc [hotfix][tests] Minor cleanup
add e18782f9bb8 [FLINK-29097][sql-gateway] Move json se/deserializers from sql-gateway-api to sql-gateway
add d9bcbffc006 [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized. (#20698)
add a1d74c131b0 [FLINK-29038][runtime] Fix unstable case AsyncWaitOperatorTest#testProcessingTimeRepeatedCompleteOrderedWithRetry
add 7669daffdc5 [FLINK-28814][Connectors][JDBC] Update org.postgresql:postgresql to 42.4.1
add b3dcafa9db2 [FLINK-28121][docs-zh]Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page
add c37643031dc [FLINK-29123][k8s] Dynamic paramters are not pushed to working with kubernetes
add 2220f24925a [FLINK-28751][table] Improve the performance of JSON functions with json path (#20397)
add d55be6850dc [FLINK-29087][connector/jdbc] Change dependencies order to avoid compile failure while running in idea
add 00f585234f8 [FLINK-29005][parquet] Parquet row type reader should not return null value when some child fields is null
add fc5730ab2de [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passed
add 27985657080 [FLINK-29019][doc][parquet] Updating parquet format document that support read complex type
add 581e1fe3682 [FLINK-29130][state] Correct the doc description of local-recovery
add c0f080762e7 [FLINK-24718] Update Avro dependency to 1.11.1
add a377d0d46a8 [hotfix][docs] List FileSystem also as a source
add 44119780ff3 [hotfix][tests] Replace deprecated AbstractThrowableAssert#getRootCause
add 6630ce7d6fc [FLINK-28938][hive] Fix HiveServer2 Endpoint can not set variable correctly
add 549d4327cf4 [FLINK-28938][hive] Improve error messages for unsupported interfaces
add 8ccbf3bbac1 [hotfix][doc]Update doc of REST API in runtime module
add 55902053a4c [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway rest endpoint
add 2e2fb24bdbc [FLINK-29138][table-planner] fix project can not be pushed into lookup source
add 8b8245ba46b [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled
add a9c94e06d6c [FLINK-29161][tests] Fix the built docker image name
add 87cbea30c20 [hotfix][docs] Fix typo
add 5c8db127470 [hotfix][csv][javadoc] Fix reference
add 655184cdb08 [FLINK-28078][tests] Mitigate likelihood to run into test stability issues caused by CURATOR-645
add 20e00fd8284 [FLINK-28948][table] Increase test coverage for lookup full caching + fix metrics
add bbe969059b1 [FLINK-28971][docs] Adds user documentation for the new LOOKUP hint
add 69872241788 [FLINK-29112][table-planner] Print the lookup join hint on the node in the original RelNode tree for easier debugging
add 121e63e8702 [FLINK-29180] fix: show subtask metrics as default in vertex detail (#20737)
add 72f0cb6fc7c [FLINK-28858][docs] Add document to describe join hints for batch sql
add 4b15bc900eb [FLINK-29091][table-planner] Fix the determinism declaration of the rand function to be consistent with the current behavior
add c95aeb6cb32 Update version to 1.17-SNAPSHOT
add 88779dbda0d [hotfix][release] Add 1.17 to the flink version enum
add b98534cafd0 [FLINK-29182][table] fix redundant computations in SumAggFunction. (#20738)
add df0bc117341 [FLINK-27017][hive] Fix divide by zero exception with Hive dialect (#19216)
add f52b65fa071 [FLINK-28429][python] Remove the warnings in the Python tests
add 10663811ffc [FLINK-28429][python] Optimize PyFlink tests
add 3929eb207b9 [FLINK-28429][python] Skip cython test on python-only-PRs
add 9a725746b0a [FLINK-28429][python] Upgrade the version of grpcio-tools
add 8c2a2854eb0 [FLINK-29013][hive] Fix fail to use BinaryRecordReader in "transform using" syntax with Hive dialect (#20643)
add f3a00d85006 [FLINK-28070][tests] Migrate ScalaAPICompletenessTestBase to Junit5
add 2a3e2bb62df [FLINK-28122][docs-zh] Translate "Overview" and "Project Configuration" in "User-defined Sources & Sinks" page into Chinese
add 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.
add 666ef186536 [FLINK-29022][docs][table] Add document for CREATE FUNCTION USING JAR feature (#20628)
add ed29940ace7 [FLINK-29196][python] Update flink-python NOTICE
add b9516348ce7 [hotfix][cassandra][tests] Use CassandraTupleOutputFormat
add 97f5a45cd03 [FLINK-28897][runtime] Fix bug of failed to generate JobGraph when using UDF and enable checkpoint
add a18150bc87c [hotfix][docs] Fix file reference
add 034030b5a48 [FLINK-28941][Runtime/Checkpointing] Add concurrent checkpoint support in Operator Coordinator
add cb32dad3006 [FLINK-29205][connectors/kinesis] Passthrough use config to HTTP client when constructing Async Client for Kinesis EFO
add 016fa93813d [hotfix][docs][release] Update the building branch in workflow
add 523546101f0 [fixup][table-planner] Using user classloader instead of thread context classloader
add e0257883900 [FLINK-29074][Connectors/JDBC] Fix ClassNotFound exception when using jdbc connector by add jar syntax
add 481ed78bec4 [FLINK-29096][table] Keep backward compatibility of JdbcCatalog constructor
add a8ca381c577 [FLINK-14101][jdbc-connector] Support SQLServer dialect in the jdbc connector.
add f27779b0213 [FLINK-29210][Docs][SQL Client] Add required parameter when running SQL Client via Docker Compose
add 442ab0ce6cb [FLINK-29210][Docs][SQL Client] Copy English Docker documentation to Chinese documentation to bring them back in sync
add a901911266b [FLINK-28860][datastream] Cache consumption in stream mode recompute result in case of cache miss
add 3d05f275225 [hotfix][datastream] Fix cache invalidate with remote session cluster
add b7dd42617a4 [FLINK-28860][runtime] JobMaster wait for partition promote before close
add 833e7ffbb5f [FLINK-29118][sql-gateway][hive] Remove default GenericInMemoryCatalog in the HiveServer2 Endpoint when openSession
add bd1d97391be [FLINK-29184][sql-gateway] Close resource manager when closing Session
add 26eeabfdd1f [FLINK-29132][rest] Cleanup subtask attempt metrics according to the JobDetails to avoid memory leak.
add 3e883e687d2 [FLINK-29153][connector/kafka] Retry KafkaConsumer#commitAsync on WakeupException in KafkaConsumerThread
add 264eff6084d [hotfix][tests][table-planner] Add two more cases to verify the conflict of multiple LOOKUP hints
add 347316ea639 [FLINK-28787][table-planner] Rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin
add 10a934fa6c4 [hotfix] Fix the missing comma in create_snapshot_branch.sh
add 1e6897c24e3 [FLINK-29207][connector/pulsar] Fix Pulsar message eventTime may be incorrectly set to a negative number (#20765)
add 17d7c39bb2a [FLINK-29047][k8s] Shade fabric8 kubernetes dependency with org.apache.flink.shaded prefix in flink-kubernetes
add ec2f3d99ac9 [FLINK-29211][hive][legal] Update 2.3.9 NOTICE
add b0a12410c91 [FLINK-28934][Connector/pulsar] Fix split assignment in different Pulsar subscriptions.
add d92ef3bc00c [FLINK-27388][Connector/pulsar] Change the topic setup logic in Pulsar runtime operator.
add ce0d043b1d4 [FLINK-28084][Connector/pulsar] Disable retry and delete reconsume logic on PulsarUnorderedPartitionSplitReader.
add b614e94b9fc [FLINK-27611][Connector/pulsar] Fix ConcurrentModificationException during checkpoint on Pulsar unordered reader.
add 5a354857913 [FLINK-27400][Connector/pulsar] Filter system topics for Pulsar connector.
add 290137c201c [FLINK-28934][Connector/pulsar] Support connector testing tools for Pulsar unordered source.
add 3a91ded2891 [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config
add 6722c89d0df [FLINK-29120][table-planner] Avoid join hint propagating into view
add 36396f789cd [FLINK-29217][tests] Guarantee checkpoint order in OC test
add b8fc7f34d2c [FLINK-29248][rpc] Remove RpcService#fenceRpcServer
add c5248b62abf [FLINK-29223][coordination] Add missing output info for jobs already reached terminal state
add 6393f00db8f [FLINK-29223][coordination] Address feedback
add ea3ff8e4f51 [FLINK-27937][tests][pubsub] Migrate flink-connectors-gcp-pubsub to JUnit5
add a4841408aa9 [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5
add 813e0d11123 [hotfix][javadoc] Move javadoc before @Test
add 35c6ac6891a [FLINK-25868][build] Limit japicmp to jar modules
add ddd034b1528 [FLINK-25868][build] Disable japicmp in packaging/e2e modules
add 8fb3da763d9 [FLINK-25868][build] Use custom japicmp plugin version
add ccdf270fc91 [FLINK-25868][build] Enable japicmp for all modules
add 84e5c63d3c7 [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema
add d62df6899a1 [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle
add fa199c1b514 Revert "[FLINK-19869][connectors/jdbc] Add support for postgres UUID type"
add 4e99d64b491 [FLINK-29253][runtime] Removes synchronous close call from DefaultJobManagerRunnerRegistry#localCleanupAsync
add dbae7aefb21 [hotfix][tests] Cleaned up JDK/assertj plugin warnings
add 5ddf4f2568e [hotfix][release] Mark 1.15 as latest stable
add 83f87b22c15 [hotfix] Avoid possible deadlock in SubpartitionView and FileDataManager.
add 12dfe6abd66 [FLINK-29238] Wrong index information will be obtained after the downstream failover in hybrid full mode
add fbd369ce406 [FLINK-27660][table] add table api for registering function with resource uris
add 3ff0ef8474f [FLINK-27660][table] Improve Javadoc of TableEnvironment#createFunction
add 19ddba04a4b [FLINK-29260][release] Wipe exclusion list when updating reference version
add a91501f3726 [FLINK-27976][Web-UI] Allow order jobs by name
add 0bbee3047ed [FLINK-29249][rpc] Drop RpcService#execute/scheduleRunnable
add 030baed8d6e [FLINK-29262][docs] Document API compatibility guarantees
add d518086f475 [FLINK-29113][table-planner] Throw exception when finding at least one invalid table name in join hints
add 545ce28da09 [FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase
add 21ec759fce8 [FLINK-28928][tests] Add IT test for hybrid shuffle mode.
add 8de6f9208fc [FLINK-28928][tests] Add E2E test for hybrid shuffle mode.
add 9b31810c229 [FLINK-28853][connector-base] Revise threading model of SplitFetcher.
add a22cc4341fd [FLINK-28853][connector-base] Add support for paused SplitFetcher.
add ec2c33fc8e3 [FLINK-28853][source][connector-base] Add support for aligning individual splits
add ea8f943443c [FLINK-28853][kafka] Implement pausing Kafka partitions in case of watermark drift
add 175a819fc27 [FLINK-28853][pulsar] Implement pausing Pulsar splits in case of watermark drift
add b9ccc78649b [FLINK-28853][connector-base] Add allow-unaligned-source-splits config option
add 2e5a8032ce5 [FLINK-28853][connector-base] Add source reader split alignment test
add 0612a997ddc [FLINK-28853] Address PR comments / Add Kafka and Pulsar split pausing tests
add 869233d10ba [hotfix] make schedulingDownStreamTasksInBatchJobBenchmark more in line with the real scene.
add 77eab72fb01 [hotfix] Let scheduledRegions using the set backed up by IdentityHashMap
add f78fcb5ed05 [FLINK-29101] Filter the the execution vertex finished event for non-finished ConsumedPartitionGroup
add f5764e9b8ef [FLINK-29101] Use loop instead of recursive algorithm for maybeScheduleRegions to avoid stackOverFlow.
add c0165a8a7e3 [FLINK-29101] ignore non canBePipelined consumedPartitionGroup in getAllSchedulableRegions.
add 469049a4359 [FLINK-29285][tests] Move TestUtils#getResource
add db98322472c [FLINK-29282][tests] Decouple Quickstart E2E test from Elasticsearch
add a37161f0ffb [hotfix][ci] Improve output when NOTICE is missing
add 2d6fa8876a6 [FLINK-29301] loadFromResources works as jar
add d91f7dc5a01 [FLINK-29301] Automatically determine modules skipping deployment
add 3ae5313d473 [FLINK-29301] Rename java-ci-tools to flink-ci-tools
add bb23cf7b2f6 [FLINK-29301] Publish flink-ci-tools
add d3513d98953 [FLINK-29299][network] Fix the network memory size calculation issue in fine-grained resource mode
add 33afc3c8924 [FLINK-29305][tests] UpsertTestSinkWriter creates parent directories
add 68ec91bdc3b [hotfix][tests] Update job name
add dbcd2d7b86f [FLINK-28569][table-planner] Add projectRowType to RowTypeUtils and deprecate AggCodeGenHelper#projectRowType
add 7df115c016c [FLINK-28569][table-planner] Move non-deterministic test functions to userDefinedScalarFunctions
add bff1fc2782e [FLINK-28569][table-planner] Fix SinkUpsertMaterializer that should be aware of the input upsertKey if it is not empty to prevent wrong results
add a98726ee416 [FLINK-29287][tests] Add PackagingTestUtils
add 06b75071062 [FLINK-29287][tests] Rewrite sql-client packaging tests
add ef93bcace70 [FLINK-27142][test] Rework SQL client E2E test
add d268ea105cc [FLINK-29263] Remove Elasticsearch connector
add 9d2ae557289 [FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreFileOperationsTest
add 4910076bafc [FLINK-29250][rpc] Drop RcService#getTerminationFuture
add a02b2c232ea [FLINK-28738][table-planner] Adds a user doc about the determinism in streaming
add 22cb5540083 [FLINK-29280][table-planner] Fix join hints could not be propagated in subquery
add b515da4409c [FLINK-24907] Support side out late data for interval join
add 530019a59e0 [FLINK-29188][sql-gateway][hive] Make option "sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir" required
add 8a8cd087e40 [hotfix] Bind to broadcast address when host is not specified
add d766b25dceb [FLINK-29148][docs][sql-gateway][hive] Add SQL Gateway docs
add be3c35c560d [FLINK-29148][docs][hive] Improve the docs of HiveServer2 page
add f6520ec1653 [FLINK-29023][docs][table] Update documentation of JAR statement page
add 65907bc5470 [FLINK-29023][docs][table] Improve docs of limitation of ADD JAR
add 99e89273617 [FLINK-29025][docs] add overview page for Hive dialect
add 2521e8097ec [FLINK-29025][docs] add overview page of queries for Hive dialect
add ca85cabcbcd [FLINK-29025][docs] add sort/cluster/distribute by page for Hive dialect
add c2b6449a535 [FLINK-29025][docs] add group by page for Hive dialect
add 55838396b21 [FLINK-29025][docs] add join page for Hive dialect
add 0ee0fcabf4f [FLINK-29025][docs] add set operation page for Hive dialect
add d9f2d394a48 [FLINK-29025][docs] add lateral view page for Hive dialect
add 9b6eba6d20b [FLINK-29025][docs] add window functions page for Hive dialect
add 091d7560656 [FLINK-29025][docs] add sub query page for Hive dialect
add e8957f5d526 [FLINK-29025][docs] add cte page for Hive dialect
add 5054a8e057d [FLINK-29025][docs] add transform page for Hive dialect
add 989b52575bd [FLINK-29025][docs] add table sample page for Hive dialect
add 19dedcfcda2 [FLINK-29025][docs] add `add jar` page for Hive dialect
add 90705b675e1 [FLINK-29025][docs] add alter page for Hive dialect
add 0c156970dc0 [FLINK-29025][docs] add create page for Hive dialect
add 631462224e1 [FLINK-29025][docs] add drop page for Hive dialect
add c563e2d6fe9 [FLINK-29025][docs] add insert page for Hive dialect
add 9417e92f813 [FLINK-29025][docs] add load data page for Hive dialect
add caefdc74153 [FLINK-29025][docs] add set page for Hive dialect
add f1f79a4fe0e [FLINK-29025][docs] add show page for Hive dialect
add 0f2b26f4420 [FLINK-29025][docs] Improve documentation of Hive compatibility pages
add 5381ef595ee [FLINK-29025][docs] Update page weight of Hive compatibility pages
add 9dc7766cdaa [FLINK-29025][docs][hive] Use dash-case instead of camelCase in URL of Hive compatibility pages
add f412eeeea70 [FLINK-29025][docs][hive] Fix links of Hive compatibility pages
add 7c9f5ec1845 [FLINK-29025][docs][hive] Remove "alias" front matter of new added Hive compatibility pages
add 53d5e1cf966 [hotfix] Add 1.15 release note in Chinese doc
add 3994788892f [FLINK-29185][hive] Fix ClassNotFoundException for CREATE TEMPORARY FUNCTION USING JAR with Hive dialect
add 791d8396163 [FLINK-29045][hive] Optimize error message in Flink SQL Client and Gateway when try to use Hive Dialect
add 4448d9fd5e3 [FLINK-29222][hive] Fix wrong behavior for Hive's load data inpath
add 71fea9a4522 [FLINK-29324][Connectors/Kinesis] Fix NPE for Kinesis connector when closing (#20853)
add 64c550c67c2 [FLINK-29191][hive] Fix Hive dialect can't get value for the variables set by set command
add 05600f844a9 [FLINK-29325][docs] Fix documentation bug on how to enable batch mode for streaming examples
add aab13977bea [hotfix] Make ParquetProtoWriters.ParquetProtoWriterBuilder public to support customized scenarios
add 7ddf059d3b7 [FLINK-29152][hive] Fix "SHOW CREATE TABLE" doesn't work for Hive dialect
add b5cd9f34ab7 [FLINK-29152][hive] Fix inconsistent behavior with Hive for `desc table` in Hive dialect
add b9e3dfe0ae7 [FLINK-29377][rpc] Reusable timeout extraction
add 1650734eeb3 [FLINK-29228][hive] Align the schema of the HiveServer2 getMetadata with JDBC
add f2c72772345 [FLINK-29229][hive] Fix HiveServer2 endpoint doesn't support execute statements in sync mode
add c4654f2cbe6 [FLINK-29374][rpc][tests] Use proper RPC url
add 5766d50dc14 [FLINK-29378][coordination] Improve logging of failed execution state transitions
add 162db046e1c [FLINK-29397][runtime] Check if changelog provider is null
add a54b2a8674e [FLINK-29340][coordination][tests] Avoid selfGateway implementation details
add 24c685a58ef [FLINK-28890][table] Fix semantic of latestLoadTime in caching lookup function
add 0154de9edb4 [FLINK-29375][rpc] Move getSelfGateway() into RpcService
add 298b8884202 [FLINK-29309][streaming-java] Relax allow-client-job-configurations for Table API and parameters
add 340b100f2de [FLINK-29093][table] Fix InternalCompilerException in LookupJoinITCase + reset resource counter before each test
add 3fa7d03ddad [FLINK-29389][docs] Update documentation of JDBC and HBase lookup table for new caching options (#20884)
add c0d90070332 [hotfix][docs] Fix typo in Kinesis Connector docs.
add 89be642cb6d [hotfix] fix the problem that BatchShuffleItCase not subject to configuration.
add 8ce056c5943 [FLINK-29020][docs] Add document for CREATE TABLE AS SELECT
add b7b366c0fda [FLINK-29386][hive] Fix failed to compile flink-connector-hive in hive3 profile (#20882)
add ca2200e75d2 [FLINK-24476][docs] Rename Elasticsearch case in docs. This closes #17451
add 6c5f8a8e3cc [FLINK-29274][hive] Fix ObjectStore leak when different users has different config (#20891)
add 680303c091d [hotfix][docs] Fix typo in try-flink/datastream.md
add 0f8909cfb51 [FLINK-29349][table-runtime] Use state ttl instead of timer to clean up state in proctime unbounded over aggregate
add 44009efc540 [FLINK-29219][table] Fix CREATE TABLE AS statement blocks SQL client's execution
add 54f81c4a9d1 [FLINK-14896][connectors/kinesis] Shade and relocate Jackson dependencies
add f360a8740aa [hotfix] Show paramter for templated tests with junit5
add fe3bdcf0182 [FLINK-29425] Hybrid full spilling strategy triggering spilling frequently
add 6cce68dcdc1 [FLINK-29372] Add suffix to all options that conflict with YAML
add ed2537321f9 [hotfix] Migrate StreamingJobGraphGeneratorTest all tests to assertj and make testing method package private
add 853ea452bff [FLINK-29431] Exceptions during job graph serialization lock up client
add 7bae0ebb637 [FLINK-29348][table] DynamicFilteringEvent can be stored in the CoordinatorStore if it's received before the listener source coordinator is started.
add a1c4919aa4f [hotfix][release] Update the compatibility table for the release 1.16
add c321c5c70f5 [FLINK-28998][Docs] Translate 'Fine-Grained Resource Management' page into Chinese. This closes #20660
add a1acdab8a5b [FLINK-29466][Connector/JDBC] Bump postgresql in /flink-connectors/flink-connector-jdbc
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (4f20a0b31a5)
\
N -- N -- N refs/heads/dependabot/maven/flink-connectors/flink-connector-jdbc/org.postgresql-postgresql-42.4.1 (a1acdab8a5b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/docs.yml | 4 +-
NOTICE | 2 +-
docs/config.toml | 5 +-
docs/content.zh/_index.md | 2 +-
.../docs/connectors/datastream/cassandra.md | 2 +-
.../docs/connectors/datastream/filesystem.md | 113 +-
.../docs/connectors/datastream/firehose.md | 2 +
.../docs/connectors/datastream/formats/csv.md | 17 +-
.../docs/connectors/datastream/formats/json.md | 32 +-
.../docs/connectors/datastream/formats/parquet.md | 6 +-
.../connectors/datastream/formats/text_files.md | 24 +
.../docs/connectors/datastream/hybridsource.md | 30 +-
.../docs/connectors/datastream/kinesis.md | 2 +
.../docs/connectors/datastream/pulsar.md | 70 +-
.../docs/connectors/datastream/rabbitmq.md | 2 +
.../docs/connectors/table/formats/parquet.md | 8 +-
docs/content.zh/docs/connectors/table/hbase.md | 69 +-
.../docs/connectors/table/hive/hive_catalog.md | 2 +-
.../docs/connectors/table/hive/hive_dialect.md | 421 --
.../docs/connectors/table/hive/hive_functions.md | 10 +-
.../docs/connectors/table/hive/hive_read_write.md | 75 +
.../docs/connectors/table/hive/overview.md | 2 +-
docs/content.zh/docs/connectors/table/jdbc.md | 114 +-
docs/content.zh/docs/connectors/table/kinesis.md | 4 +-
docs/content.zh/docs/deployment/cli.md | 2 +-
docs/content.zh/docs/deployment/config.md | 2 +-
.../docs/deployment/finegrained_resource.md | 232 +-
.../content.zh/docs/deployment/ha/kubernetes_ha.md | 6 +-
docs/content.zh/docs/deployment/ha/zookeeper_ha.md | 6 +-
.../content.zh/docs/deployment/metric_reporters.md | 10 +-
docs/content.zh/docs/deployment/overview.md | 2 +-
.../resource-providers/native_kubernetes.md | 10 +-
.../resource-providers/standalone/docker.md | 521 +-
.../resource-providers/standalone/kubernetes.md | 4 +-
.../resource-providers/standalone/overview.md | 4 +-
.../docs/deployment/speculative_execution.md | 92 +
.../docs/dev/datastream/execution_mode.md | 2 +-
.../datastream/fault-tolerance/broadcast_state.md | 126 +-
.../serialization/schema_evolution.md | 27 +-
.../serialization/types_serialization.md | 1 +
.../docs/dev/datastream/operators/overview.md | 45 +
.../docs/dev/datastream/operators/windows.md | 126 +-
docs/content.zh/docs/dev/datastream/sources.md | 42 +-
.../docs/dev/python/datastream/data_types.md | 2 +-
.../python/datastream/intro_to_datastream_api.md | 15 +-
.../dev/python/datastream/operators/windows.md | 564 +-
.../docs/dev/python/datastream_tutorial.md | 3 +-
.../docs/dev/python/python_execution_mode.md | 72 +-
.../docs/dev/python/table/table_environment.md | 4 +-
docs/content.zh/docs/dev/table/catalogs.md | 4 +
.../docs/dev/table/concepts/determinism.md | 261 +
.../content.zh/docs/dev/table/concepts/overview.md | 3 +-
docs/content.zh/docs/dev/table/data_stream_api.md | 12 +-
docs/content.zh/docs/dev/table/functions/udfs.md | 53 +
.../docs/dev/table/hive-compatibility/_index.md | 23 +
.../hive-compatibility/hive-dialect/_index.md | 21 +
.../table/hive-compatibility/hive-dialect/add.md | 56 +
.../table/hive-compatibility/hive-dialect/alter.md | 324 ++
.../hive-compatibility/hive-dialect/create.md | 246 +
.../table/hive-compatibility/hive-dialect/drop.md | 144 +
.../hive-compatibility/hive-dialect/insert.md | 212 +
.../hive-compatibility/hive-dialect/load-data.md | 84 +
.../hive-compatibility/hive-dialect/overview.md | 104 +
.../hive-dialect/queries/_index.md | 21 +
.../hive-compatibility/hive-dialect/queries/cte.md | 67 +
.../hive-dialect/queries/group-by.md | 135 +
.../hive-dialect/queries/join.md | 105 +
.../hive-dialect/queries/lateral-view.md | 90 +
.../hive-dialect/queries/overview.md | 162 +
.../hive-dialect/queries/set-op.md | 95 +
.../queries/sort-cluster-distribute-by.md | 98 +
.../hive-dialect/queries/sub-queries.md | 69 +
.../hive-dialect/queries/table-sample.md | 49 +
.../hive-dialect/queries/transform.md | 135 +
.../hive-dialect/queries/window-functions.md | 105 +
.../table/hive-compatibility/hive-dialect/set.md | 65 +
.../table/hive-compatibility/hive-dialect/show.md | 116 +
.../dev/table/hive-compatibility/hiveserver2.md | 316 +
docs/content.zh/docs/dev/table/sourcesSinks.md | 453 +-
.../docs/dev/table/sql-gateway/_index.md | 23 +
.../docs/dev/table/sql-gateway/hiveserver2.md | 34 +
.../docs/dev/table/sql-gateway/overview.md | 236 +
docs/content.zh/docs/dev/table/sql-gateway/rest.md | 119 +
docs/content.zh/docs/dev/table/sql/analyze.md | 385 ++
docs/content.zh/docs/dev/table/sql/create.md | 50 +-
docs/content.zh/docs/dev/table/sql/jar.md | 40 +-
docs/content.zh/docs/dev/table/sql/overview.md | 3 +-
.../content.zh/docs/dev/table/sql/queries/hints.md | 506 +-
.../content.zh/docs/dev/table/sql/queries/limit.md | 4 +-
.../docs/dev/table/sql/queries/orderby.md | 4 +-
docs/content.zh/docs/dev/table/sqlClient.md | 2 +-
docs/content.zh/docs/libs/cep.md | 4 +-
.../docs/ops/debugging/application_profiling.md | 10 +-
docs/content.zh/docs/ops/metrics.md | 34 +-
.../docs/ops/state/large_state_tuning.md | 4 +-
docs/content.zh/docs/ops/state/state_backends.md | 17 +-
.../docs/ops/state/task_failure_recovery.md | 8 +-
docs/content.zh/docs/ops/upgrading.md | 74 +
docs/content.zh/docs/try-flink/datastream.md | 8 +-
docs/content.zh/docs/try-flink/table_api.md | 161 +-
.../release-notes/flink-1.15.md | 0
docs/content.zh/release-notes/flink-1.6.md | 4 +-
.../docs/connectors/datastream/cassandra.md | 2 +-
.../docs/connectors/datastream/filesystem.md | 113 +-
.../content/docs/connectors/datastream/firehose.md | 2 +
.../docs/connectors/datastream/formats/csv.md | 9 +-
.../docs/connectors/datastream/formats/json.md | 32 +-
.../docs/connectors/datastream/formats/parquet.md | 6 +-
.../connectors/datastream/formats/text_files.md | 24 +
.../docs/connectors/datastream/hybridsource.md | 30 +-
docs/content/docs/connectors/datastream/kinesis.md | 8 +-
.../content/docs/connectors/datastream/overview.md | 2 +-
docs/content/docs/connectors/datastream/pulsar.md | 77 +-
.../content/docs/connectors/datastream/rabbitmq.md | 2 +
.../docs/connectors/table/formats/parquet.md | 10 +-
docs/content/docs/connectors/table/hbase.md | 73 +-
.../docs/connectors/table/hive/hive_catalog.md | 2 +-
.../docs/connectors/table/hive/hive_dialect.md | 434 --
.../docs/connectors/table/hive/hive_functions.md | 10 +-
.../docs/connectors/table/hive/hive_read_write.md | 80 +
.../content/docs/connectors/table/hive/overview.md | 4 +-
docs/content/docs/connectors/table/jdbc.md | 136 +-
docs/content/docs/connectors/table/kinesis.md | 4 +-
docs/content/docs/deployment/cli.md | 2 +-
docs/content/docs/deployment/config.md | 2 +-
docs/content/docs/deployment/ha/kubernetes_ha.md | 6 +-
docs/content/docs/deployment/ha/zookeeper_ha.md | 6 +-
docs/content/docs/deployment/metric_reporters.md | 6 +-
docs/content/docs/deployment/overview.md | 2 +-
.../resource-providers/native_kubernetes.md | 10 +-
.../resource-providers/standalone/docker.md | 13 +
.../resource-providers/standalone/kubernetes.md | 8 +-
.../resource-providers/standalone/overview.md | 15 +-
.../docs/deployment/speculative_execution.md | 102 +
docs/content/docs/dev/datastream/execution_mode.md | 2 +-
.../datastream/fault-tolerance/broadcast_state.md | 129 +-
.../serialization/schema_evolution.md | 6 +
.../serialization/types_serialization.md | 1 +
.../docs/dev/datastream/operators/overview.md | 47 +
.../docs/dev/datastream/operators/windows.md | 127 +-
docs/content/docs/dev/datastream/sources.md | 71 +-
.../docs/dev/python/datastream/data_types.md | 2 +-
.../python/datastream/intro_to_datastream_api.md | 15 +-
.../dev/python/datastream/operators/windows.md | 564 +-
.../content/docs/dev/python/datastream_tutorial.md | 3 +-
.../docs/dev/python/python_execution_mode.md | 72 +-
.../docs/dev/python/table/table_environment.md | 4 +-
docs/content/docs/dev/table/catalogs.md | 4 +
.../content/docs/dev/table/concepts/determinism.md | 269 +
docs/content/docs/dev/table/concepts/overview.md | 1 +
docs/content/docs/dev/table/data_stream_api.md | 10 +-
docs/content/docs/dev/table/functions/udfs.md | 48 +-
.../docs/dev/table/hive-compatibility/_index.md | 23 +
.../hive-compatibility/hive-dialect/_index.md | 21 +
.../table/hive-compatibility/hive-dialect/add.md | 56 +
.../table/hive-compatibility/hive-dialect/alter.md | 324 ++
.../hive-compatibility/hive-dialect/create.md | 246 +
.../table/hive-compatibility/hive-dialect/drop.md | 144 +
.../hive-compatibility/hive-dialect/insert.md | 212 +
.../hive-compatibility/hive-dialect/load-data.md | 84 +
.../hive-compatibility/hive-dialect/overview.md | 112 +
.../hive-dialect/queries/_index.md | 21 +
.../hive-compatibility/hive-dialect/queries/cte.md | 67 +
.../hive-dialect/queries/group-by.md | 135 +
.../hive-dialect/queries/join.md | 105 +
.../hive-dialect/queries/lateral-view.md | 90 +
.../hive-dialect/queries/overview.md | 162 +
.../hive-dialect/queries/set-op.md | 95 +
.../queries/sort-cluster-distribute-by.md | 98 +
.../hive-dialect/queries/sub-queries.md | 69 +
.../hive-dialect/queries/table-sample.md | 49 +
.../hive-dialect/queries/transform.md | 135 +
.../hive-dialect/queries/window-functions.md | 105 +
.../table/hive-compatibility/hive-dialect/set.md | 65 +
.../table/hive-compatibility/hive-dialect/show.md | 116 +
.../dev/table/hive-compatibility/hiveserver2.md | 316 +
docs/content/docs/dev/table/overview.md | 1 +
docs/content/docs/dev/table/sourcesSinks.md | 24 +-
docs/content/docs/dev/table/sql-gateway/_index.md | 23 +
.../docs/dev/table/sql-gateway/hiveserver2.md | 34 +
.../content/docs/dev/table/sql-gateway/overview.md | 236 +
docs/content/docs/dev/table/sql-gateway/rest.md | 119 +
docs/content/docs/dev/table/sql/analyze.md | 382 ++
docs/content/docs/dev/table/sql/create.md | 53 +-
docs/content/docs/dev/table/sql/jar.md | 36 +-
docs/content/docs/dev/table/sql/overview.md | 3 +-
docs/content/docs/dev/table/sql/queries/hints.md | 539 ++
docs/content/docs/dev/table/sqlClient.md | 2 +-
docs/content/docs/internals/task_lifecycle.md | 2 +-
docs/content/docs/libs/cep.md | 6 +-
.../docs/ops/debugging/application_profiling.md | 10 +-
docs/content/docs/ops/metrics.md | 35 +-
docs/content/docs/ops/state/state_backends.md | 19 +-
.../docs/ops/state/task_failure_recovery.md | 10 +-
docs/content/docs/ops/upgrading.md | 74 +
docs/content/release-notes/flink-1.6.md | 4 +-
docs/data/sql_connectors.yml | 21 +-
docs/data/sql_functions.yml | 27 +-
docs/data/sql_functions_zh.yml | 17 +-
docs/layouts/shortcodes/check.html | 21 +
.../generated/all_jobmanager_section.html | 6 +
.../generated/checkpointing_configuration.html | 4 +-
.../generated/cleanup_configuration.html | 2 +-
.../common_high_availability_section.html | 2 +-
.../generated/common_state_backends_section.html | 6 +-
.../generated/deployment_configuration.html | 20 +-
.../generated/environment_configuration.html | 2 +-
.../execution_checkpointing_configuration.html | 4 +-
.../generated/execution_config_configuration.html | 12 +
.../generated/execution_configuration.html | 2 +-
.../generated/expert_scheduling_section.html | 6 +
...ntial_delay_cleanup_strategy_configuration.html | 6 +-
...ntial_delay_restart_strategy_configuration.html | 10 +-
...ailure_rate_restart_strategy_configuration.html | 6 +-
...fixed_delay_cleanup_strategy_configuration.html | 4 +-
...fixed_delay_restart_strategy_configuration.html | 4 +-
.../fs_state_changelog_configuration.html | 6 +
.../generated/high_availability_configuration.html | 12 +-
.../generated/job_manager_configuration.html | 6 +
.../generated/kubernetes_config_configuration.html | 34 +-
.../shortcodes/generated/metric_configuration.html | 4 +-
.../generated/optimizer_config_configuration.html | 18 +-
.../generated/pipeline_configuration.html | 6 +
.../generated/pulsar_consumer_configuration.html | 6 -
.../shortcodes/generated/rest_v1_dispatcher.html | 46 +
.../shortcodes/generated/rest_v1_sql_gateway.html | 783 +++
.../generated/restart_strategy_configuration.html | 2 +-
.../generated/sql_gateway_rest_configuration.html | 36 +
.../generated/state_backend_configuration.html | 12 +-
.../generated/table_config_configuration.html | 2 +-
docs/layouts/shortcodes/xmark.html | 21 +
docs/static/fig/apache_superset.png | Bin 0 -> 125404 bytes
docs/static/fig/dbeaver.png | Bin 0 -> 1638252 bytes
docs/static/fig/hint/hint_query_block_union.png | Bin 0 -> 36830 bytes
docs/static/fig/hint/hint_query_block_view.png | Bin 0 -> 52391 bytes
docs/static/fig/hint/hint_query_block_where.png | Bin 0 -> 35551 bytes
docs/static/fig/sql-gateway-architecture.png | Bin 0 -> 218739 bytes
docs/static/fig/sql-gateway-interactions.png | Bin 0 -> 71423 bytes
docs/static/generated/rest_v1_dispatcher.yml | 30 +
docs/static/generated/rest_v1_sql_gateway.yml | 502 ++
flink-annotations/pom.xml | 2 +-
.../main/java/org/apache/flink/FlinkVersion.java | 3 +-
.../flink-architecture-tests-base/pom.xml | 2 +-
.../b8900323-6aab-4e7e-9b17-f53b3c3dca46 | 12 +-
.../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 1 -
.../flink-architecture-tests-production/pom.xml | 17 +-
.../flink/architecture/rules/TableApiRules.java | 2 +
.../flink-architecture-tests-test/pom.xml | 2 +-
flink-architecture-tests/pom.xml | 23 +-
flink-clients/pom.xml | 2 +-
.../flink/client/FlinkPipelineTranslationUtil.java | 21 +-
.../apache/flink/client/StreamGraphTranslator.java | 8 +-
.../org/apache/flink/client/cli/CliFrontend.java | 4 +-
.../application/executors/EmbeddedExecutor.java | 3 +-
.../executors/AbstractJobClusterExecutor.java | 3 +-
.../executors/AbstractSessionClusterExecutor.java | 47 +-
.../client/deployment/executors/LocalExecutor.java | 7 +-
.../executors/PipelineExecutorUtils.java | 12 +-
.../apache/flink/client/program/ClusterClient.java | 22 +
.../flink/client/program/MiniClusterClient.java | 13 +
.../program/MutatedConfigurationException.java | 5 +-
.../client/program/StreamContextEnvironment.java | 196 +-
.../client/program/rest/RestClusterClient.java | 60 +
.../client/cli/CliFrontendPackageProgramTest.java | 3 +-
.../apache/flink/client/program/ClientTest.java | 12 +-
.../DefaultPackagedProgramRetrieverTest.java | 3 +-
.../program/StreamContextEnvironmentTest.java | 75 +-
.../client/program/rest/RestClusterClientTest.java | 206 +
flink-connectors/flink-connector-aws-base/pom.xml | 20 +-
.../flink/connector/aws/util/AWSGeneralUtil.java | 4 +-
.../connector/aws/util/AWSAsyncSinkUtilTest.java | 15 +
.../connector/aws/util/AWSGeneralUtilTest.java | 7 +-
.../flink-connector-aws-kinesis-firehose/pom.xml | 24 +-
.../sink/KinesisFirehoseSinkElementConverter.java | 30 +
.../firehose/sink/KinesisFirehoseSinkWriter.java | 15 +-
.../sink/testutils/KinesisFirehoseTestUtils.java | 6 +-
.../flink-connector-aws-kinesis-streams/pom.xml | 23 +-
.../sink/KinesisStreamsSinkElementConverter.java | 31 +
.../kinesis/sink/KinesisStreamsSinkWriter.java | 15 +-
.../kinesis/sink/examples/SinkIntoKinesis.java | 9 +-
flink-connectors/flink-connector-base/pom.xml | 10 +-
.../base/sink/writer/AIMDRateLimitingStrategy.java | 72 -
.../base/sink/writer/AsyncSinkWriter.java | 164 +-
.../config/AsyncSinkWriterConfiguration.java | 210 +
.../sink/writer/strategy/AIMDScalingStrategy.java | 85 +
.../sink/writer/strategy/BasicRequestInfo.java | 34 +
.../base/sink/writer/strategy/BasicResultInfo.java | 40 +
.../CongestionControlRateLimitingStrategy.java | 124 +
.../sink/writer/strategy/NoOpScalingStrategy.java | 31 +
.../sink/writer/strategy/RateLimitingStrategy.java | 60 +
.../base/sink/writer/strategy/RequestInfo.java | 27 +
.../base/sink/writer/strategy/ResultInfo.java | 30 +
.../base/sink/writer/strategy/ScalingStrategy.java | 39 +
.../source/hybrid/HybridSourceSplitEnumerator.java | 11 +-
.../base/source/hybrid/SwitchedSources.java | 8 +-
.../SingleThreadMultiplexSourceReaderBase.java | 2 +-
.../base/source/reader/SourceReaderBase.java | 10 +-
.../reader/fetcher/PauseOrResumeSplitsTask.java | 84 +
.../reader/fetcher/SingleThreadFetcherManager.java | 9 +-
.../base/source/reader/fetcher/SplitFetcher.java | 404 +-
.../source/reader/fetcher/SplitFetcherManager.java | 40 +-
.../source/reader/splitreader/SplitReader.java | 30 +
.../connector/base/sink/ArrayListAsyncSink.java | 17 +-
.../connector/base/sink/AsyncSinkBaseITCase.java | 2 +-
.../sink/writer/AIMDRateLimitingStrategyTest.java | 113 -
.../base/sink/writer/AsyncSinkWriterTest.java | 28 +-
.../writer/strategy/AIMDScalingStrategyTest.java | 132 +
.../CongestionControlRateLimitingStrategyTest.java | 184 +
.../writer/strategy/NoOpScalingStrategyTest.java | 43 +
.../hybrid/HybridSourceSplitEnumeratorTest.java | 21 +
.../base/source/reader/SourceReaderBaseTest.java | 12 +-
.../reader/fetcher/SplitFetcherManagerTest.java | 3 +-
.../SplitFetcherPauseResumeSplitReaderTest.java | 306 +
.../source/reader/fetcher/SplitFetcherTest.java | 24 +-
.../base/source/reader/mocks/MockSplitReader.java | 37 +-
flink-connectors/flink-connector-cassandra/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../cassandra/CassandraConnectorITCase.java | 127 +-
.../cassandra/CassandraSinkBaseTest.java | 122 +-
.../CassandraTupleWriteAheadSinkTest.java | 25 +-
.../org.junit.jupiter.api.extension.Extension | 0
.../dd583797-83e1-414c-a38d-330773978813 | 6 -
.../archunit-violations/stored.rules | 4 -
.../flink-connector-elasticsearch-base/pom.xml | 193 -
.../sink/BulkProcessorBuilderFactory.java | 36 -
.../elasticsearch/sink/BulkProcessorConfig.java | 72 -
.../sink/BulkRequestConsumerFactory.java | 35 -
.../elasticsearch/sink/ElasticsearchEmitter.java | 78 -
.../elasticsearch/sink/ElasticsearchSink.java | 97 -
.../sink/ElasticsearchSinkBuilderBase.java | 342 --
.../elasticsearch/sink/ElasticsearchWriter.java | 330 --
.../elasticsearch/sink/FlushBackoffType.java | 38 -
.../sink/MapElasticsearchEmitter.java | 81 -
.../elasticsearch/sink/NetworkClientConfig.java | 78 -
.../elasticsearch/sink/RequestIndexer.java | 56 -
.../table/AbstractTimeIndexGenerator.java | 41 -
.../table/ElasticsearchConfiguration.java | 158 -
.../table/ElasticsearchConnectorOptions.java | 148 -
.../table/ElasticsearchDynamicSink.java | 228 -
.../table/ElasticsearchDynamicSinkFactoryBase.java | 257 -
.../table/ElasticsearchSinkBuilderSupplier.java | 26 -
.../table/ElasticsearchValidationUtils.java | 92 -
.../elasticsearch/table/IndexGenerator.java | 39 -
.../elasticsearch/table/IndexGeneratorBase.java | 52 -
.../elasticsearch/table/IndexGeneratorFactory.java | 317 -
.../elasticsearch/table/KeyExtractor.java | 97 -
.../elasticsearch/table/LogicalTypeWithIndex.java | 31 -
.../table/RowElasticsearchEmitter.java | 107 -
.../elasticsearch/table/StaticIndexGenerator.java | 35 -
.../elasticsearch/ActionRequestFailureHandler.java | 82 -
.../elasticsearch/BufferingNoOpRequestIndexer.java | 75 -
.../elasticsearch/ElasticsearchApiCallBridge.java | 122 -
.../elasticsearch/ElasticsearchSinkBase.java | 525 --
.../elasticsearch/ElasticsearchSinkFunction.java | 83 -
.../connectors/elasticsearch/RequestIndexer.java | 84 -
.../table/AbstractTimeIndexGenerator.java | 41 -
.../table/ElasticsearchConfiguration.java | 169 -
.../table/ElasticsearchConnectorOptions.java | 165 -
.../table/ElasticsearchValidationUtils.java | 94 -
.../elasticsearch/table/IndexGenerator.java | 39 -
.../elasticsearch/table/IndexGeneratorBase.java | 52 -
.../elasticsearch/table/IndexGeneratorFactory.java | 314 -
.../elasticsearch/table/KeyExtractor.java | 130 -
.../elasticsearch/table/RequestFactory.java | 54 -
.../table/RowElasticsearchSinkFunction.java | 140 -
.../elasticsearch/table/StaticIndexGenerator.java | 35 -
.../elasticsearch/util/IgnoringFailureHandler.java | 38 -
.../elasticsearch/util/NoOpFailureHandler.java | 54 -
.../util/RetryRejectedExecutionFailureHandler.java | 59 -
.../architecture/TestCodeArchitectureTest.java | 43 -
.../connector/elasticsearch/ElasticsearchUtil.java | 92 -
.../sink/ElasticsearchSinkBaseITCase.java | 221 -
.../sink/ElasticsearchSinkBuilderBaseTest.java | 105 -
.../sink/ElasticsearchWriterITCase.java | 422 --
.../elasticsearch/sink/TestClientBase.java | 72 -
.../connector/elasticsearch/sink/TestEmitter.java | 78 -
.../table/ElasticsearchDynamicSinkBaseITCase.java | 358 --
.../ElasticsearchDynamicSinkFactoryBaseTest.java | 256 -
.../elasticsearch/table/IndexGeneratorTest.java | 370 --
.../elasticsearch/table/KeyExtractorTest.java | 148 -
.../connector/elasticsearch/table/TestContext.java | 72 -
.../elasticsearch/ElasticsearchSinkBaseTest.java | 688 ---
.../elasticsearch/ElasticsearchSinkTestBase.java | 190 -
.../EmbeddedElasticsearchNodeEnvironment.java | 54 -
.../elasticsearch/TestRequestIndexer.java | 78 -
.../table/IndexGeneratorFactoryTest.java | 296 -
.../elasticsearch/table/KeyExtractorTest.java | 132 -
.../elasticsearch/table/TestContext.java | 72 -
.../testutils/ElasticsearchResource.java | 106 -
.../testutils/SourceSinkDataTestKit.java | 156 -
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
.../25e52d29-fa7e-42fa-a571-b5c76235df52 | 0
.../db3972e4-f3a3-45b2-9643-27cba0cef09d | 12 -
.../archunit-violations/stored.rules | 4 -
.../flink-connector-elasticsearch6/pom.xml | 178 -
.../sink/Elasticsearch6SinkBuilder.java | 131 -
.../table/Elasticsearch6Configuration.java | 37 -
.../table/Elasticsearch6ConnectorOptions.java | 39 -
.../table/Elasticsearch6DynamicSinkFactory.java | 77 -
.../table/Elasticsearch6Configuration.java | 79 -
.../table/Elasticsearch6DynamicSink.java | 335 --
.../table/Elasticsearch6DynamicSinkFactory.java | 184 -
.../Elasticsearch6ApiCallBridge.java | 148 -
.../Elasticsearch6BulkProcessorIndexer.java | 85 -
.../elasticsearch6/ElasticsearchSink.java | 269 -
.../elasticsearch6/RestClientFactory.java | 42 -
.../org.apache.flink.table.factories.Factory | 16 -
.../architecture/TestCodeArchitectureTest.java | 57 -
.../sink/Elasticsearch6SinkBuilderTest.java | 37 -
.../sink/Elasticsearch6SinkITCase.java | 52 -
.../sink/Elasticsearch6TestClient.java | 36 -
.../Elasticsearch6DynamicSinkFactoryTest.java | 59 -
.../table/Elasticsearch6DynamicSinkITCase.java | 103 -
.../Elasticsearch6DynamicSinkFactoryTest.java | 250 -
.../table/Elasticsearch6DynamicSinkITCase.java | 400 --
.../table/Elasticsearch6DynamicSinkTest.java | 298 -
.../elasticsearch6/ElasticsearchSinkITCase.java | 133 -
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
.../1af7baaa-05dc-452a-9de7-653c8b3b324f | 0
.../e1f30f33-c61c-4707-8c78-a3a80479564e | 12 -
.../archunit-violations/stored.rules | 4 -
.../flink-connector-elasticsearch7/pom.xml | 175 -
.../sink/Elasticsearch7SinkBuilder.java | 133 -
.../table/Elasticsearch7DynamicSinkFactory.java | 33 -
.../table/Elasticsearch7Configuration.java | 70 -
.../table/Elasticsearch7DynamicSink.java | 335 --
.../table/Elasticsearch7DynamicSinkFactory.java | 184 -
.../Elasticsearch7ApiCallBridge.java | 152 -
.../Elasticsearch7BulkProcessorIndexer.java | 85 -
.../elasticsearch7/ElasticsearchSink.java | 269 -
.../elasticsearch7/RestClientFactory.java | 42 -
.../org.apache.flink.table.factories.Factory | 16 -
.../architecture/TestCodeArchitectureTest.java | 57 -
.../sink/Elasticsearch7SinkBuilderTest.java | 37 -
.../sink/Elasticsearch7SinkITCase.java | 53 -
.../sink/Elasticsearch7TestClient.java | 37 -
.../Elasticsearch7DynamicSinkFactoryTest.java | 57 -
.../table/Elasticsearch7DynamicSinkITCase.java | 97 -
.../Elasticsearch7DynamicSinkFactoryTest.java | 234 -
.../table/Elasticsearch7DynamicSinkITCase.java | 377 --
.../table/Elasticsearch7DynamicSinkTest.java | 298 -
.../elasticsearch7/ElasticsearchSinkITCase.java | 133 -
.../src/test/resources/archunit.properties | 31 -
.../src/test/resources/log4j2-test.properties | 28 -
flink-connectors/flink-connector-files/pom.xml | 2 +-
.../file/src/enumerate/DynamicFileEnumerator.java | 48 +
.../file/src/impl/DynamicFileSplitEnumerator.java | 207 +
.../connector/file/table/FileSystemCommitter.java | 21 +-
.../file/table/FileSystemOutputFormat.java | 47 +-
.../file/table/PartitionCommitPolicy.java | 45 -
.../file/table/PartitionCommitPolicyFactory.java | 83 +
.../connector/file/table/PartitionLoader.java | 89 +-
.../file/table/PartitionTempFileManager.java | 16 +-
.../file/table/TableMetaStoreFactory.java | 6 +
.../file/table/stream/PartitionCommitter.java | 11 +-
.../connector/file/table/stream/StreamingSink.java | 59 +-
.../src/impl/DynamicFileSplitEnumeratorTest.java | 190 +
.../file/table/FileSystemCommitterTest.java | 83 +-
.../flink-connector-gcp-pubsub/pom.xml | 2 +-
.../pubsub/DeserializationSchemaWrapperTest.java | 37 +-
.../connectors/gcp/pubsub/PubSubConsumingTest.java | 31 +-
.../connectors/gcp/pubsub/PubSubSourceTest.java | 61 +-
.../pubsub/common/AcknowledgeOnCheckpointTest.java | 67 +-
flink-connectors/flink-connector-hbase-1.4/pom.xml | 2 +-
.../hbase1/HBase1DynamicTableFactory.java | 31 +-
.../hbase1/source/HBaseDynamicTableSource.java | 34 +-
.../hbase1/HBaseDynamicTableFactoryTest.java | 66 +-
flink-connectors/flink-connector-hbase-2.2/pom.xml | 25 +-
.../hbase2/HBase2DynamicTableFactory.java | 39 +-
.../hbase2/source/HBaseDynamicTableSource.java | 66 +-
.../source/HBaseRowDataAsyncLookupFunction.java | 66 +-
.../hbase2/HBaseDynamicTableFactoryTest.java | 71 +-
.../HBaseRowDataAsyncLookupFunctionTest.java | 23 +-
.../flink-connector-hbase-base/pom.xml | 2 +-
.../hbase/options/HBaseLookupOptions.java | 113 -
.../source/AbstractHBaseDynamicTableSource.java | 37 +-
.../hbase/source/HBaseRowDataLookupFunction.java | 63 +-
.../hbase/table/HBaseConnectorOptions.java | 6 +
.../hbase/table/HBaseConnectorOptionsUtil.java | 12 -
.../connector/hbase/util/HBaseTableSchema.java | 33 +
flink-connectors/flink-connector-hive/pom.xml | 9 +-
.../hive/ContinuousHiveSplitEnumerator.java | 19 +-
.../hive/DynamicHiveSplitEnumerator.java | 35 +
.../apache/flink/connectors/hive/HiveOptions.java | 78 +
.../apache/flink/connectors/hive/HiveSource.java | 33 +-
.../flink/connectors/hive/HiveSourceBuilder.java | 42 +-
.../hive/HiveSourceDynamicFileEnumerator.java | 219 +
.../connectors/hive/HiveSourceFileEnumerator.java | 119 +-
.../connectors/hive/HiveTableMetaStoreFactory.java | 259 +-
.../flink/connectors/hive/HiveTableSink.java | 81 +-
.../flink/connectors/hive/HiveTableSource.java | 52 +-
.../connectors/hive/read/HiveInputFormat.java | 6 +-
.../connectors/hive/util/HivePartitionUtils.java | 22 +
.../flink/table/catalog/hive/HiveCatalog.java | 280 +-
.../hive/client/HiveMetastoreClientWrapper.java | 37 +
.../flink/table/catalog/hive/client/HiveShim.java | 13 +
.../table/catalog/hive/client/HiveShimV100.java | 75 +
.../table/catalog/hive/client/HiveShimV200.java | 62 +
.../table/catalog/hive/client/HiveShimV210.java | 74 +
.../table/catalog/hive/client/HiveShimV310.java | 133 +-
.../table/catalog/hive/util/HiveStatsUtil.java | 336 ++
.../table/endpoint/hive/HiveServer2Endpoint.java | 361 +-
.../hive/HiveServer2EndpointConfigOptions.java | 4 +-
.../endpoint/hive/HiveServer2EndpointFactory.java | 26 +-
.../table/endpoint/hive/HiveServer2Schemas.java | 176 +-
.../endpoint/hive/util/HiveJdbcParameterUtils.java | 44 +-
.../hive/util/OperationExecutorFactory.java | 551 +-
.../hive/util/ThriftObjectConversions.java | 85 +-
.../table/functions/hive/HiveGenericUDAF.java | 40 +-
.../table/functions/hive/HiveGenericUDTF.java | 2 +-
.../table/functions/hive/HiveScalarFunction.java | 2 +-
.../functions/hive/util/HiveFunctionUtil.java | 37 -
.../apache/flink/table/module/hive/HiveModule.java | 10 +-
.../hive/udf/generic/HiveGenericUDFToDecimal.java | 96 +
.../delegation/hive/HiveOperationExecutor.java | 227 +-
.../table/planner/delegation/hive/HiveParser.java | 247 +-
.../delegation/hive/HiveParserCalcitePlanner.java | 38 +-
.../delegation/hive/HiveParserDMLHelper.java | 26 +-
.../hive/HiveParserRexNodeConverter.java | 79 +-
.../hive/HiveParserTypeCheckProcFactory.java | 21 +
.../planner/delegation/hive/HiveParserUtils.java | 18 +-
.../planner/delegation/hive/HiveSessionState.java | 171 +
.../delegation/hive/HiveShowTableUtils.java | 295 +
.../delegation/hive/SqlFunctionConverter.java | 3 +-
.../delegation/hive/copy/HiveASTParseUtils.java | 3 +
.../delegation/hive/copy/HiveParserContext.java | 2 +-
.../hive/copy/HiveParserSqlFunctionConverter.java | 93 +-
.../delegation/hive/copy/HiveSetProcessor.java | 28 +-
.../hive/operations/HiveLoadDataOperation.java | 99 +
.../operations/HiveShowCreateTableOperation.java | 40 +
.../hive/parse/HiveParserDDLSemanticAnalyzer.java | 39 +-
.../hive/parse/HiveParserLoadSemanticAnalyzer.java | 294 +
.../hive/script/HiveScriptTransformOperator.java | 3 -
.../script/HiveScriptTransformOutReadThread.java | 4 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink/connectors/hive/HiveDialectITCase.java | 154 +-
.../connectors/hive/HiveDialectQueryITCase.java | 225 +-
.../hive/HiveDynamicPartitionPruningITCase.java | 234 +
.../hive/HiveDynamicTableFactoryTest.java | 2 +-
.../hive/HiveSourceDynamicFileEnumeratorTest.java | 230 +
.../hive/HiveSourceFileEnumeratorTest.java | 98 +
.../flink/connectors/hive/HiveTableSinkITCase.java | 241 +
.../connectors/hive/HiveTableSourceITCase.java | 151 +-
.../hive/HiveTableSourceStatisticsReportTest.java | 61 +-
.../connectors/hive/PartitionMonitorTest.java | 7 +-
.../catalog/hive/HiveCatalogHiveMetadataTest.java | 302 +
.../flink/table/catalog/hive/HiveTestUtils.java | 30 +-
.../hive/HiveServer2EndpointFactoryTest.java | 24 +-
.../endpoint/hive/HiveServer2EndpointITCase.java | 751 ++-
.../hive/HiveServer2EndpointStatementITCase.java | 4 +
.../hive/util/HiveServer2EndpointExtension.java | 8 +-
.../hive/util/ThriftObjectConversionsTest.java | 68 +-
.../table/functions/hive/HiveGenericUDAFTest.java | 36 +
.../flink/table/module/hive/HiveModuleTest.java | 4 +-
.../src/test/resources/endpoint/hive_catalog.q | 16 +-
.../explain/testDynamicPartitionSortDisabled.out | 14 +
.../explain/testDynamicPartitionSortEnabled.out | 16 +
.../testHiveTableSinkWithParallelismInBatch.out | 8 +-
.../src/test/resources/explain/testLoadData.out | 8 +
.../src/test/resources/orc/test.orc | Bin 0 -> 4591 bytes
.../src/test/resources/query-test/join.q | 6 +
.../src/test/resources/query-test/udaf.q | 3 +
.../src/test/resources/query-test/udf.q | 17 +
.../0f94f11b-9bc8-445a-8be8-e7dfd8a384b0} | 0
.../e3f99de4-2505-469a-8910-ce53aec7cd1d | 2 -
.../archunit-violations/stored.rules | 4 +-
flink-connectors/flink-connector-jdbc/pom.xml | 27 +-
.../jdbc/catalog/AbstractJdbcCatalog.java | 23 +-
.../flink/connector/jdbc/catalog/JdbcCatalog.java | 41 +-
.../connector/jdbc/catalog/JdbcCatalogUtils.java | 9 +-
.../flink/connector/jdbc/catalog/MySqlCatalog.java | 37 +-
.../connector/jdbc/catalog/PostgresCatalog.java | 3 +-
.../jdbc/catalog/factory/JdbcCatalogFactory.java | 1 +
.../jdbc/converter/AbstractJdbcRowConverter.java | 2 +-
.../flink/connector/jdbc/dialect/JdbcDialect.java | 12 +
.../connector/jdbc/dialect/JdbcDialectLoader.java | 6 +-
.../connector/jdbc/dialect/mysql/MySqlDialect.java | 18 +
.../jdbc/dialect/sqlserver/SqlServerDialect.java | 160 +
.../dialect/sqlserver/SqlServerDialectFactory.java | 37 +
.../internal/converter/PostgresRowConverter.java | 23 -
.../internal/converter/SqlServerRowConverter.java | 51 +
.../internal/options/JdbcConnectorOptions.java | 21 +-
.../jdbc/internal/options/JdbcLookupOptions.java | 111 -
.../connector/jdbc/table/JdbcConnectorOptions.java | 10 +-
.../jdbc/table/JdbcDynamicTableFactory.java | 80 +-
.../jdbc/table/JdbcDynamicTableSource.java | 42 +-
.../jdbc/table/JdbcRowDataLookupFunction.java | 88 +-
...flink.connector.jdbc.dialect.JdbcDialectFactory | 1 +
.../jdbc/catalog/MySqlCatalogTestBase.java | 1 +
.../jdbc/catalog/PostgresCatalogTestBase.java | 1 +
.../catalog/factory/JdbcCatalogFactoryTest.java | 1 +
.../jdbc/dialect/mysql/MySqlDialectTest.java | 41 +
.../oracle/OraclePreparedStatementTest.java | 4 +-
.../sqlserver/SqlServerPreparedStatementTest.java | 94 +
.../sqlserver/SqlServerTableSinkITCase.java | 492 ++
.../sqlserver/SqlServerTableSourceITCase.java | 229 +
.../converter/PostgresRowConverterTest.java | 92 -
.../FieldNamedPreparedStatementImplTest.java | 3 +-
.../jdbc/table/JdbcAppendOnlyWriterTest.java | 5 +
.../jdbc/table/JdbcDynamicTableFactoryTest.java | 79 +-
.../jdbc/table/JdbcDynamicTableSourceITCase.java | 181 +-
.../connector/jdbc/table/JdbcLookupTestBase.java | 11 +-
.../connector/jdbc/table/JdbcOutputFormatTest.java | 4 +-
.../jdbc/table/JdbcRowDataLookupFunctionTest.java | 131 +-
flink-connectors/flink-connector-kafka/pom.xml | 4 +-
.../kafka/sink/DefaultKafkaSinkContext.java | 2 +-
.../source/reader/KafkaPartitionSplitReader.java | 14 +
.../kafka/source/reader/KafkaSourceReader.java | 7 +
.../reader/fetcher/KafkaSourceFetcherManager.java | 3 +-
.../kafka/internals/AbstractFetcher.java | 2 +-
.../kafka/internals/KafkaConsumerThread.java | 20 +-
.../internals/metrics/KafkaMetricWrapper.java | 7 +-
.../JSONKeyValueDeserializationSchema.java | 10 +-
.../kafka/source/reader/KafkaSourceReaderTest.java | 46 +
.../KafkaRecordDeserializationSchemaTest.java | 12 +-
.../JSONKeyValueDeserializationSchemaTest.java | 36 +-
.../metrics/KafkaMetricMutableWrapperTest.java | 29 +-
flink-connectors/flink-connector-kinesis/pom.xml | 52 +-
.../connectors/kinesis/FlinkKinesisConsumer.java | 7 +-
.../kinesis/proxy/DynamoDBStreamsProxy.java | 6 +-
.../kinesis/proxy/KinesisProxyV2Factory.java | 10 +-
.../streaming/connectors/kinesis/util/AWSUtil.java | 12 +-
.../connectors/kinesis/util/KinesisConfigUtil.java | 13 +
.../src/main/resources/META-INF/NOTICE | 64 +-
.../kinesis/FlinkKinesisConsumerTest.java | 8 +
.../connectors/kinesis/util/AWSUtilTest.java | 7 +-
.../util/JobManagerWatermarkTrackerTest.java | 6 +-
.../kinesis/util/KinesisConfigUtilTest.java | 11 +
.../f4d91193-72ba-4ce4-ad83-98f780dce581 | 6 +
flink-connectors/flink-connector-pulsar/pom.xml | 2 +-
.../pulsar/common/schema/PulsarSchema.java | 12 +-
.../pulsar/common/utils/PulsarSerdeUtils.java | 5 +-
.../connector/pulsar/sink/writer/PulsarWriter.java | 2 +-
.../sink/writer/topic/TopicMetadataListener.java | 4 +-
.../connector/pulsar/source/PulsarSource.java | 12 +-
.../pulsar/source/PulsarSourceBuilder.java | 8 +-
.../pulsar/source/PulsarSourceOptions.java | 7 +
.../source/config/PulsarSourceConfigUtils.java | 3 -
.../pulsar/source/config/SourceConfiguration.java | 4 +
.../source/enumerator/PulsarSourceEnumState.java | 54 +-
.../PulsarSourceEnumStateSerializer.java | 51 +-
.../source/enumerator/PulsarSourceEnumerator.java | 194 +-
.../source/enumerator/SplitsAssignmentState.java | 239 -
.../assigner/NonSharedSplitAssigner.java | 112 +
.../enumerator/assigner/SharedSplitAssigner.java | 88 +
.../source/enumerator/assigner/SplitAssigner.java | 63 +
.../enumerator/assigner/SplitAssignerBase.java | 102 +
.../enumerator/assigner/SplitAssignerFactory.java | 60 +
.../source/enumerator/cursor/CursorPosition.java | 42 +-
.../source/enumerator/cursor/MessageIdUtils.java | 71 +
.../source/enumerator/cursor/StartCursor.java | 32 +-
.../source/enumerator/cursor/StopCursor.java | 96 +-
.../cursor/start/MessageIdStartCursor.java | 24 +-
.../cursor/start/TimestampStartCursor.java | 4 +-
.../cursor/stop/EventTimestampStopCursor.java | 9 +-
.../cursor/stop/LatestMessageStopCursor.java | 21 +-
.../cursor/stop/MessageIdStopCursor.java | 32 +-
.../enumerator/cursor/stop/NeverStopCursor.java | 4 +-
.../cursor/stop/PublishTimestampStopCursor.java | 9 +-
.../enumerator/subscriber/PulsarSubscriber.java | 2 +-
.../subscriber/impl/TopicPatternSubscriber.java | 3 +
.../source/enumerator/topic/TopicNameUtils.java | 52 +-
.../source/reader/PulsarSourceReaderFactory.java | 2 +-
.../reader/fetcher/PulsarFetcherManagerBase.java | 6 +-
.../fetcher/PulsarOrderedFetcherManager.java | 6 +-
.../fetcher/PulsarUnorderedFetcherManager.java | 22 +-
.../reader/source/PulsarOrderedSourceReader.java | 3 +-
.../reader/source/PulsarSourceReaderBase.java | 8 +
.../reader/source/PulsarUnorderedSourceReader.java | 71 +-
.../split/PulsarOrderedPartitionSplitReader.java | 42 +-
.../split/PulsarPartitionSplitReaderBase.java | 79 +-
.../split/PulsarUnorderedPartitionSplitReader.java | 23 +-
.../pulsar/source/split/PulsarPartitionSplit.java | 4 +-
.../pulsar/common/schema/PulsarSchemaTest.java | 28 +
.../writer/topic/TopicMetadataListenerTest.java | 6 +-
.../pulsar/source/PulsarSourceITCase.java | 28 +-
.../pulsar/source/PulsarUnorderedSourceITCase.java | 103 +
.../PulsarSourceEnumStateSerializerTest.java | 21 +-
.../enumerator/PulsarSourceEnumeratorTest.java | 205 +-
.../enumerator/SplitsAssignmentStateTest.java | 119 -
.../assigner/NonSharedSplitAssignerTest.java | 113 +
.../assigner/SharedSplitAssignerTest.java | 121 +
.../enumerator/assigner/SplitAssignerTestBase.java | 128 +
.../source/enumerator/cursor/StopCursorTest.java | 11 +-
.../enumerator/topic/TopicNameUtilsTest.java | 9 +
.../source/PulsarOrderedSourceReaderTest.java | 32 +
.../split/PulsarPartitionSplitReaderTestBase.java | 43 +-
.../pulsar/testutils/PulsarTestContext.java | 10 +-
.../cases/SharedSubscriptionConsumingContext.java | 58 +
.../testutils/runtime/PulsarRuntimeOperator.java | 187 +-
.../runtime/container/PulsarContainerRuntime.java | 1 -
.../runtime/embedded/PulsarEmbeddedRuntime.java | 1 -
.../testutils/runtime/mock/PulsarMockRuntime.java | 5 +-
flink-connectors/flink-connector-rabbitmq/pom.xml | 2 +-
flink-connectors/flink-file-sink-common/pom.xml | 2 +-
.../flink-hadoop-compatibility/pom.xml | 7 +-
.../flink/hadoopcompatibility/HadoopUtilsTest.java | 6 +-
flink-connectors/flink-hcatalog/pom.xml | 2 +-
.../pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 38 +-
.../pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 43 +-
.../flink-sql-connector-elasticsearch6/pom.xml | 149 -
.../src/main/resources/META-INF/NOTICE | 47 -
.../flink-sql-connector-elasticsearch7/pom.xml | 158 -
.../src/main/resources/META-INF/NOTICE | 47 -
.../flink-sql-connector-hbase-1.4/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink-sql-connector-hbase-2.2/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink-sql-connector-hive-2.3.9/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 22 +-
.../flink-sql-connector-hive-3.1.2/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-connectors/flink-sql-connector-kafka/pom.xml | 12 +-
.../src/main/resources/META-INF/NOTICE | 4 +-
.../flink/connectors/kafka/PackagingITCase.java | 40 +
.../flink-sql-connector-kinesis/pom.xml | 20 +-
.../src/main/resources/META-INF/NOTICE | 6 +-
.../flink/connectors/kinesis/PackagingITCase.java | 46 +
.../flink-sql-connector-pulsar/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink-sql-connector-rabbitmq/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-connectors/pom.xml | 7 +-
flink-container/pom.xml | 2 +-
flink-contrib/flink-connector-wikiedits/pom.xml | 2 +-
flink-contrib/pom.xml | 2 +-
flink-core/pom.xml | 19 +-
.../apache/flink/api/common/BatchShuffleMode.java | 27 +-
.../apache/flink/api/common/ExecutionConfig.java | 9 +
.../common/eventtime/CombinedWatermarkStatus.java | 11 +-
.../eventtime/IndexedCombinedWatermarkStatus.java | 3 +-
.../eventtime/WatermarkOutputMultiplexer.java | 11 +-
.../common/eventtime/WatermarksWithIdleness.java | 8 +-
.../functions/util/PrintSinkOutputWriter.java | 17 +-
.../flink/api/connector/source/ReaderOutput.java | 8 +-
.../flink/api/connector/source/SourceReader.java | 51 +-
.../api/connector/source/SourceReaderContext.java | 2 +-
.../flink/api/java/typeutils/TypeExtractor.java | 43 +-
.../flink/configuration/CheckpointingOptions.java | 16 +-
.../apache/flink/configuration/CleanupOptions.java | 13 +-
.../apache/flink/configuration/ConfigOptions.java | 2 +-
.../apache/flink/configuration/ConfigUtils.java | 28 -
.../apache/flink/configuration/CoreOptions.java | 5 +-
.../flink/configuration/DeploymentOptions.java | 51 +-
.../flink/configuration/ExecutionOptions.java | 11 +-
.../flink/configuration/GlobalConfiguration.java | 17 +-
.../configuration/HighAvailabilityOptions.java | 6 +-
.../flink/configuration/JobManagerOptions.java | 22 +-
.../apache/flink/configuration/MetricOptions.java | 6 +-
.../flink/configuration/PipelineOptions.java | 17 +
.../configuration/RestartStrategyOptions.java | 3 +-
.../flink/configuration/StateBackendOptions.java | 3 +-
.../execution/CacheSupportedPipelineExecutor.java | 55 +
.../flink/util/FlinkUserCodeClassLoaders.java | 12 +-
.../main/java/org/apache/flink/util/IOUtils.java | 17 +
.../flink/util/jackson/JacksonMapperFactory.java | 52 +
.../flink/api/common/ExecutionConfigTest.java | 2 +-
.../eventtime/WatermarkOutputMultiplexerTest.java | 24 +-
.../connector/source/mocks/MockSourceReader.java | 21 +-
.../util/jackson/JacksonMapperFactoryTest.java | 139 +
flink-dist-scala/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-dist/pom.xml | 3 +-
flink-dist/src/main/flink-bin/bin/config.sh | 12 +-
flink-dist/src/main/flink-bin/bin/jobmanager.sh | 6 +-
flink-dist/src/main/resources/META-INF/NOTICE | 2 +-
flink-dist/src/main/resources/flink-conf.yaml | 4 +-
flink-docs/README.md | 2 +-
flink-docs/pom.xml | 30 +-
.../configuration/ConfigOptionsDocGenerator.java | 251 +-
.../docs/configuration/OptionsClassLocation.java | 45 -
.../flink/docs/rest/OpenApiSpecGenerator.java | 38 +-
.../flink/docs/rest/RestAPIDocGenerator.java | 33 +-
.../docs/rest/RuntimeOpenApiSpecGenerator.java | 61 +
.../docs/rest/RuntimeRestAPIDocGenerator.java | 85 +
.../docs/rest/SqlGatewayOpenApiSpecGenerator.java | 61 +
.../docs/rest/SqlGatewayRestAPIDocGenerator.java | 85 +
.../docs/util/ConfigurationOptionLocator.java | 203 +
.../apache/flink/docs/util/OptionWithMetaInfo.java | 35 +
.../flink/docs/util/OptionsClassLocation.java | 45 +
.../ConfigOptionsDocGeneratorTest.java | 65 +-
.../ConfigOptionsDocsCompletenessITCase.java | 54 +-
.../configuration/ConfigOptionsYamlSpecTest.java | 68 +
flink-dstl/flink-dstl-dfs/pom.xml | 2 +-
.../fs/AbstractStateChangeFsUploader.java | 120 +
.../changelog/fs/ChangelogStreamHandleReader.java | 40 +
.../fs/ChangelogStreamHandleReaderWithCache.java | 221 +
.../flink/changelog/fs/ChangelogStreamWrapper.java | 62 +
.../fs/DuplicatingOutputStreamWithPos.java | 174 +
.../fs/DuplicatingStateChangeFsUploader.java | 111 +
.../changelog/fs/FsStateChangelogOptions.java | 8 +
.../changelog/fs/FsStateChangelogStorage.java | 51 +-
.../fs/FsStateChangelogStorageFactory.java | 13 +-
.../fs/FsStateChangelogStorageForRecovery.java | 17 +-
.../flink/changelog/fs/FsStateChangelogWriter.java | 111 +-
.../flink/changelog/fs/OutputStreamWithPos.java | 54 +-
.../flink/changelog/fs/StateChangeFormat.java | 45 +-
.../flink/changelog/fs/StateChangeFsUploader.java | 104 +-
.../changelog/fs/StateChangeIteratorImpl.java | 44 +
.../changelog/fs/StateChangeUploadScheduler.java | 34 +-
.../flink/changelog/fs/StateChangeUploader.java | 33 +-
.../apache/flink/changelog/fs/UploadResult.java | 41 +-
.../fs/BatchingStateChangeUploadSchedulerTest.java | 6 +-
.../changelog/fs/ChangelogStorageMetricsTest.java | 45 +-
.../changelog/fs/FsStateChangelogStorageTest.java | 7 +-
.../fs/FsStateChangelogWriterSqnTest.java | 6 +-
.../changelog/fs/FsStateChangelogWriterTest.java | 25 +-
flink-dstl/pom.xml | 2 +-
.../flink-batch-sql-test/pom.xml | 2 +-
.../flink/sql/tests/BatchSQLTestProgram.java | 25 +-
flink-end-to-end-tests/flink-cli-test/pom.xml | 2 +-
.../flink-confluent-schema-registry/pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-dataset-allround-test/pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-datastream-allround-test/pom.xml | 2 +-
.../flink-distributed-cache-via-blob-test/pom.xml | 2 +-
.../pom.xml | 24 +-
.../table/test/KinesisFirehoseTableITTest.java | 18 +-
.../pom.xml | 2 +-
.../table/test/KinesisStreamsTableApiIT.java | 16 +-
.../pom.xml | 88 -
.../flink/streaming/tests/ElasticsearchClient.java | 59 -
.../streaming/tests/ElasticsearchDataReader.java | 57 -
.../tests/ElasticsearchSinkE2ECaseBase.java | 101 -
.../ElasticsearchSinkExternalContextBase.java | 123 -
...lasticsearchSinkExternalContextFactoryBase.java | 59 -
.../streaming/tests/ElasticsearchTestEmitter.java | 51 -
.../org/apache/flink/streaming/tests/KeyValue.java | 92 -
.../apache/flink/streaming/tests/QueryParams.java | 174 -
.../streaming/tests/UpdateRequestFactory.java | 43 -
.../flink-end-to-end-tests-common-kafka/pom.xml | 8 +-
.../flink/tests/util/kafka/KafkaSinkE2ECase.java | 8 +-
.../flink/tests/util/kafka/KafkaSourceE2ECase.java | 10 +-
.../tests/util/kafka/SQLClientKafkaITCase.java | 10 +-
.../util/kafka/SQLClientSchemaRegistryITCase.java | 11 +-
.../flink/tests/util/kafka/SmokeKafkaITCase.java | 4 +-
.../flink-end-to-end-tests-common/pom.xml | 2 +-
.../org/apache/flink/tests/util/TestUtils.java | 56 -
.../flink/tests/util/flink/FlinkDistribution.java | 180 +-
.../flink-end-to-end-tests-elasticsearch6/pom.xml | 143 -
.../streaming/tests/Elasticsearch6Client.java | 149 -
.../streaming/tests/UpdateRequest6Factory.java | 48 -
.../streaming/tests/Elasticsearch6SinkE2ECase.java | 60 -
.../tests/Elasticsearch6SinkExternalContext.java | 68 -
.../Elasticsearch6SinkExternalContextFactory.java | 48 -
.../src/test/resources/log4j2-test.properties | 34 -
.../flink-end-to-end-tests-elasticsearch7/pom.xml | 144 -
.../streaming/tests/Elasticsearch7Client.java | 147 -
.../streaming/tests/UpdateRequest7Factory.java | 46 -
.../streaming/tests/Elasticsearch7SinkE2ECase.java | 60 -
.../tests/Elasticsearch7SinkExternalContext.java | 68 -
.../Elasticsearch7SinkExternalContextFactory.java | 48 -
.../src/test/resources/log4j2-test.properties | 35 -
.../flink-end-to-end-tests-hbase/pom.xml | 2 +-
.../tests/util/hbase/SQLClientHBaseITCase.java | 9 +-
.../flink-end-to-end-tests-pulsar/pom.xml | 2 +-
.../FlinkContainerWithPulsarEnvironment.java | 4 +-
.../flink-end-to-end-tests-scala/pom.xml | 2 +-
.../apache/flink/tests/scala/ScalaFreeITCase.java | 7 +-
.../flink-end-to-end-tests-sql/pom.xml | 151 +-
.../table/sql/codegen/CreateTableAsITCase.java | 68 +
.../table/sql/codegen/PlannerScalaFreeITCase.java | 195 +-
.../flink/table/sql/codegen/SqlITCaseBase.java | 186 +
.../table/sql/codegen/UsingRemoteJarITCase.java | 213 +
.../create_function_using_remote_jar_e2e.sql | 41 +
.../src/test/resources/create_table_as_e2e.sql | 36 +
.../resources/create_table_as_statementset_e2e.sql | 40 +
.../src/test/resources/remote_jar_e2e.sql | 41 +
.../src/test/resources/scalar_udf_e2e.sql | 37 +
.../flink-file-sink-test/pom.xml | 2 +-
.../flink-glue-schema-registry-avro-test/pom.xml | 99 +-
.../flink-glue-schema-registry-json-test/pom.xml | 83 +-
.../flink-heavy-deployment-stress-test/pom.xml | 2 +-
.../flink-high-parallelism-iterations-test/pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-metrics-availability-test/pom.xml | 2 +-
.../flink-metrics-reporter-prometheus-test/pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-plugins-test/another-dummy-fs/pom.xml | 2 +-
.../flink-plugins-test/dummy-fs/pom.xml | 2 +-
flink-end-to-end-tests/flink-plugins-test/pom.xml | 2 +-
flink-end-to-end-tests/flink-python-test/pom.xml | 2 +-
.../python/datastream/data_stream_job.py | 3 +-
.../flink-queryable-state-test/pom.xml | 2 +-
.../flink-quickstart-test-dummy-dependency/pom.xml | 33 +
.../apache/flink/quickstarts/test/utils/Utils.java | 26 +
.../flink-quickstart-test/pom.xml | 4 +-
.../test/Elasticsearch7SinkExample.java | 79 -
.../flink/quickstarts/test/QuickstartExample.java | 65 +
.../test/Elasticsearch7SinkExample.scala | 75 -
.../flink/quickstarts/test/QuickstartExample.scala | 58 +
.../pom.xml | 2 +-
.../flink-sql-client-test/pom.xml | 60 +-
.../src/test/java/SqlClientITCase.java | 294 +
.../src/test/resources/log4j2-test.properties | 34 +
.../flink-sql-gateway-test/pom.xml | 8 +-
.../flink/table/gateway/SqlGatewayE2ECase.java | 81 +-
.../src/test/resources/gateway_e2e.sql | 2 +
.../flink-state-evolution-test/pom.xml | 2 +-
.../flink-stream-sql-test/pom.xml | 2 +-
.../flink-stream-state-ttl-test/pom.xml | 2 +-
.../flink-stream-stateful-job-upgrade-test/pom.xml | 2 +-
.../flink-streaming-kafka-test-base/pom.xml | 2 +-
.../flink-streaming-kafka-test/pom.xml | 2 +-
.../flink-streaming-kinesis-test/pom.xml | 2 +-
.../kinesis/test/KinesisTableApiITCase.java | 15 +-
.../flink/streaming/kinesis/test/model/Order.java | 2 +-
flink-end-to-end-tests/flink-tpcds-test/pom.xml | 2 +-
flink-end-to-end-tests/flink-tpch-test/pom.xml | 2 +-
flink-end-to-end-tests/pom.xml | 7 +-
flink-end-to-end-tests/run-nightly-tests.sh | 6 +-
flink-end-to-end-tests/test-scripts/common.sh | 5 +-
.../test-scripts/common_docker.sh | 2 +-
.../test-scripts/elasticsearch-common.sh | 142 -
.../test-scripts/test-runner-common.sh | 2 +-
.../test-scripts/test_batch_sql.sh | 2 +-
.../test-scripts/test_confluent_schema_registry.sh | 2 +-
.../test-scripts/test_ha_dataset.sh | 2 +-
.../test-scripts/test_ha_datastream.sh | 2 +-
.../test-scripts/test_kubernetes_application.sh | 2 +-
.../test-scripts/test_kubernetes_application_ha.sh | 6 +-
.../test_kubernetes_pyflink_application.sh | 2 +-
.../test-scripts/test_kubernetes_session.sh | 2 +-
.../test-scripts/test_pyflink.sh | 2 +-
.../test-scripts/test_quickstarts.sh | 45 +-
.../test-scripts/test_sql_client.sh | 266 -
flink-end-to-end-tests/test-scripts/test_tpcds.sh | 4 +-
flink-examples/flink-examples-batch/pom.xml | 2 +-
.../flink-examples-streaming-gcp-pubsub/pom.xml | 2 +-
.../flink-examples-streaming-state-machine/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 4 +-
flink-examples/flink-examples-build-helper/pom.xml | 2 +-
flink-examples/flink-examples-streaming/pom.xml | 2 +-
flink-examples/flink-examples-table/pom.xml | 2 +-
.../java/basics/TemporalJoinSQLExample.java | 196 +
.../java/basics/TemporalJoinSQLExampleITCase.java | 44 +
flink-examples/pom.xml | 6 +-
.../flink-external-resource-gpu/pom.xml | 2 +-
flink-external-resources/pom.xml | 2 +-
flink-filesystems/flink-azure-fs-hadoop/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-filesystems/flink-fs-hadoop-shaded/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-filesystems/flink-gs-fs-hadoop/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-filesystems/flink-hadoop-fs/pom.xml | 2 +-
flink-filesystems/flink-oss-fs-hadoop/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-filesystems/flink-s3-fs-base/pom.xml | 3 +-
flink-filesystems/flink-s3-fs-hadoop/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-filesystems/flink-s3-fs-presto/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-filesystems/pom.xml | 2 +-
.../flink-avro-confluent-registry/pom.xml | 4 +-
.../flink-avro-glue-schema-registry/pom.xml | 62 +-
flink-formats/flink-avro/pom.xml | 2 +-
.../avro/typeutils/AvroTypeExtractionTest.java | 24 +-
flink-formats/flink-compress/pom.xml | 2 +-
flink-formats/flink-csv/pom.xml | 8 +-
.../apache/flink/formats/csv/CsvBulkWriter.java | 3 +-
.../flink/formats/csv/CsvFileFormatFactory.java | 5 +-
.../apache/flink/formats/csv/CsvReaderFormat.java | 5 +-
.../csv/CsvRowDataDeserializationSchema.java | 11 +-
.../formats/csv/CsvRowDataSerializationSchema.java | 38 +-
.../formats/csv/CsvRowDeserializationSchema.java | 11 +-
.../formats/csv/CsvRowSerializationSchema.java | 11 +-
.../flink/formats/csv/RowCsvInputFormat.java | 4 +-
.../formats/csv/CsvFilesystemBatchITCase.java | 2 +-
.../formats/csv/CsvFilesystemStreamITCase.java | 2 +-
.../formats/csv/CsvFilesystemStreamSinkITCase.java | 2 +-
.../flink/formats/csv/CsvFormatFactoryTest.java | 24 +-
.../formats/csv/CsvRowDataSerDeSchemaTest.java | 3 +
.../csv/CsvRowDeSerializationSchemaTest.java | 3 +
.../flink/formats/csv/DataStreamCsvITCase.java | 10 +-
flink-formats/flink-format-common/pom.xml | 2 +-
flink-formats/flink-hadoop-bulk/pom.xml | 2 +-
.../flink-json-glue-schema-registry/pom.xml | 75 +-
flink-formats/flink-json/pom.xml | 2 +-
.../formats/json/JsonDeserializationSchema.java | 5 +-
.../json/JsonRowDataDeserializationSchema.java | 18 +-
.../json/JsonRowDataSerializationSchema.java | 13 +-
.../formats/json/JsonRowDeserializationSchema.java | 13 +-
.../flink/formats/json/JsonRowSchemaConverter.java | 3 +-
.../formats/json/JsonRowSerializationSchema.java | 8 +-
.../json/canal/CanalJsonDeserializationSchema.java | 5 +
.../json/canal/CanalJsonSerializationSchema.java | 3 +-
.../DebeziumJsonDeserializationSchema.java | 5 +
.../debezium/DebeziumJsonSerializationSchema.java | 3 +-
.../maxwell/MaxwellJsonDeserializationSchema.java | 5 +
.../maxwell/MaxwellJsonSerializationSchema.java | 1 +
.../json/ogg/OggJsonDeserializationSchema.java | 5 +
.../json/ogg/OggJsonSerializationSchema.java | 3 +-
.../json/JsonNodeDeserializationSchemaTest.java | 3 +-
.../formats/json/JsonRowDataSerDeSchemaTest.java | 64 +-
.../json/JsonRowDeserializationSchemaTest.java | 21 +-
.../json/JsonRowSerializationSchemaTest.java | 6 +
.../json/canal/CanalJsonSerDeSchemaTest.java | 7 +-
.../json/debezium/DebeziumJsonSerDeSchemaTest.java | 5 +-
.../json/maxwell/MaxwellJsonSerDerTest.java | 5 +-
.../formats/json/ogg/OggJsonSerDeSchemaTest.java | 6 +-
.../utils/DeserializationSchemaMatcher.java | 2 +
.../formats/utils/SerializationSchemaMatcher.java | 3 +
flink-formats/flink-orc-nohive/pom.xml | 2 +-
flink-formats/flink-orc/pom.xml | 2 +-
flink-formats/flink-parquet/pom.xml | 2 +-
.../parquet/ParquetVectorizedInputFormat.java | 24 +-
.../parquet/protobuf/ParquetProtoWriters.java | 4 +-
.../formats/parquet/vector/ColumnBatchFactory.java | 2 +-
.../vector/ParquetColumnarRowSplitReader.java | 23 +-
.../parquet/vector/ParquetDecimalVector.java | 17 +-
.../parquet/vector/ParquetSplitReaderUtil.java | 180 +-
.../parquet/vector/reader/ArrayColumnReader.java | 483 ++
.../vector/reader/BaseVectorizedColumnReader.java | 290 +
.../parquet/vector/reader/MapColumnReader.java | 64 +
.../vector/reader/ParquetDataColumnReader.java | 127 +
.../reader/ParquetDataColumnReaderFactory.java | 234 +
.../parquet/vector/reader/RowColumnReader.java | 58 +
.../parquet/ParquetColumnarRowInputFormatTest.java | 382 +-
.../formats/parquet/utils/ParquetWriterUtil.java | 186 -
.../vector/ParquetColumnarRowSplitReaderTest.java | 425 +-
flink-formats/flink-protobuf/pom.xml | 4 +-
flink-formats/flink-sequence-file/pom.xml | 2 +-
.../flink-sql-avro-confluent-registry/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 4 +-
flink-formats/flink-sql-avro/pom.xml | 12 +-
.../src/main/resources/META-INF/NOTICE | 4 +-
.../apache/flink/formats/avro/PackagingITCase.java | 40 +
flink-formats/flink-sql-csv/pom.xml | 6 +-
flink-formats/flink-sql-json/pom.xml | 6 +-
flink-formats/flink-sql-orc/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-formats/flink-sql-parquet/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-formats/flink-sql-protobuf/pom.xml | 6 +-
flink-formats/pom.xml | 2 +-
flink-fs-tests/pom.xml | 2 +-
flink-java/pom.xml | 8 +-
.../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
flink-kubernetes/pom.xml | 8 +-
.../configuration/KubernetesConfigOptions.java | 123 +-
.../KubernetesStateHandleStore.java | 16 +-
.../decorators/CmdJobManagerDecorator.java | 6 +-
.../decorators/CmdTaskManagerDecorator.java | 4 +-
.../parameters/KubernetesJobManagerParameters.java | 4 +
.../KubernetesTaskManagerParameters.java | 5 +
.../flink/kubernetes/utils/KubernetesUtils.java | 18 +-
.../src/main/resources/META-INF/NOTICE | 44 +-
.../kubernetes/KubernetesPodTemplateTestUtils.java | 12 +
.../KubernetesStateHandleStoreTest.java | 77 +
.../kubeclient/KubernetesJobManagerTestBase.java | 3 +
.../kubeclient/KubernetesTaskManagerTestBase.java | 3 +
.../decorators/CmdJobManagerDecoratorTest.java | 6 +-
.../decorators/CmdTaskManagerDecoratorTest.java | 4 +-
.../kubernetes/utils/KubernetesUtilsTest.java | 11 +
.../resources/testing-nospec-pod-template.yaml | 28 +
flink-libraries/flink-cep-scala/pom.xml | 2 +-
.../cep/scala/CEPScalaAPICompletenessTest.scala | 2 +-
.../pattern/PatternScalaAPICompletenessTest.scala | 2 +-
flink-libraries/flink-cep/pom.xml | 2 +-
flink-libraries/flink-gelly-examples/pom.xml | 2 +-
flink-libraries/flink-gelly-scala/pom.xml | 2 +-
.../scala/test/GellyScalaAPICompletenessTest.scala | 2 +-
flink-libraries/flink-gelly/pom.xml | 2 +-
flink-libraries/flink-state-processing-api/pom.xml | 2 +-
.../flink/state/api/runtime/MutableConfig.java | 6 +-
.../api/runtime/SavepointTaskStateManager.java | 10 +
.../state/api/runtime/OperatorIDGeneratorTest.java | 3 +-
flink-libraries/pom.xml | 2 +-
flink-metrics/flink-metrics-core/pom.xml | 7 +-
flink-metrics/flink-metrics-datadog/pom.xml | 2 +-
.../flink/metrics/datadog/DatadogHttpReporter.java | 66 +-
.../datadog/DatadogHttpReporterFactory.java | 39 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-metrics/flink-metrics-dropwizard/pom.xml | 2 +-
flink-metrics/flink-metrics-graphite/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-metrics/flink-metrics-influxdb/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-metrics/flink-metrics-jmx/pom.xml | 2 +-
flink-metrics/flink-metrics-prometheus/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-metrics/flink-metrics-slf4j/pom.xml | 2 +-
flink-metrics/flink-metrics-statsd/pom.xml | 2 +-
flink-metrics/pom.xml | 2 +-
flink-optimizer/pom.xml | 2 +-
.../optimizer/plantranslate/JobGraphGenerator.java | 5 +-
flink-python/README.md | 2 +-
flink-python/dev/dev-requirements.txt | 6 +-
flink-python/dev/integration_test.sh | 40 +-
flink-python/docs/pyflink.datastream.rst | 84 +-
flink-python/pom.xml | 247 +-
flink-python/pyflink/common/__init__.py | 50 +-
flink-python/pyflink/common/io.py | 32 +
flink-python/pyflink/common/serialization.py | 345 +-
.../common/tests/test_serialization_schemas.py | 76 +-
flink-python/pyflink/common/typeinfo.py | 4 +-
flink-python/pyflink/common/types.py | 33 +-
flink-python/pyflink/common/utils.py | 25 +
flink-python/pyflink/datastream/__init__.py | 84 +-
.../pyflink/datastream/connectors/__init__.py | 145 +-
flink-python/pyflink/datastream/connectors/base.py | 28 +-
.../pyflink/datastream/connectors/cassandra.py | 15 +-
.../pyflink/datastream/connectors/file_system.py | 389 +-
.../pyflink/datastream/connectors/hybrid_source.py | 71 +
flink-python/pyflink/datastream/connectors/jdbc.py | 7 +
.../pyflink/datastream/connectors/kafka.py | 8 +-
.../pyflink/datastream/connectors/kinesis.py | 33 +-
.../pyflink/datastream/connectors/number_seq.py | 6 +-
.../pyflink/datastream/connectors/pulsar.py | 67 +-
.../pyflink/datastream/connectors/rabbitmq.py | 7 +
.../datastream/connectors/tests/test_cassandra.py | 49 +
.../datastream/connectors/tests/test_connectors.py | 700 ---
.../connectors/tests/test_elasticsearch.py | 133 +
.../connectors/tests/test_file_system.py | 1080 +---
.../datastream/connectors/tests/test_jdbc.py | 61 +
.../datastream/connectors/tests/test_kafka.py | 76 +-
.../datastream/connectors/tests/test_kinesis.py | 108 +
.../datastream/connectors/tests/test_pulsar.py | 237 +
.../datastream/connectors/tests/test_rabbitmq.py | 49 +
.../datastream/connectors/tests/test_seq_source.py | 36 +
flink-python/pyflink/datastream/data_stream.py | 81 +-
.../pyflink/datastream/formats/__init__.py | 17 -
flink-python/pyflink/datastream/formats/avro.py | 102 +-
flink-python/pyflink/datastream/formats/csv.py | 181 +-
flink-python/pyflink/datastream/formats/json.py | 150 +
flink-python/pyflink/datastream/formats/orc.py | 100 +
flink-python/pyflink/datastream/formats/parquet.py | 164 +-
.../formats}/tests/__init__.py | 0
.../pyflink/datastream/formats/tests/test_avro.py | 450 ++
.../pyflink/datastream/formats/tests/test_csv.py | 422 ++
.../pyflink/datastream/formats/tests/test_json.py | 57 +
.../pyflink/datastream/formats/tests/test_orc.py | 142 +
.../datastream/formats/tests/test_parquet.py | 420 ++
flink-python/pyflink/datastream/state_backend.py | 2 +-
.../datastream/stream_execution_environment.py | 16 +-
.../pyflink/datastream/tests/test_data_stream.py | 1506 +++--
.../tests/test_stream_execution_environment.py | 46 +-
...st_stream_execution_environment_completeness.py | 3 +-
.../pyflink/datastream/tests/test_window.py | 90 +-
flink-python/pyflink/datastream/utils.py | 19 +-
.../datastream/connectors/kafka_avro_format.py | 5 +-
.../datastream/connectors/kafka_csv_format.py | 6 +-
.../datastream/connectors/kafka_json_format.py | 5 +-
.../examples/datastream/connectors/pulsar.py | 6 +-
.../windowing/session_with_dynamic_gap_window.py | 2 +-
.../windowing/session_with_gap_window.py | 2 +-
.../datastream/windowing/sliding_time_window.py | 2 +-
.../datastream/windowing/tumbling_count_window.py | 2 +-
.../datastream/windowing/tumbling_time_window.py | 2 +-
.../pyflink/examples/datastream/word_count.py | 4 +-
.../pyflink/fn_execution/coder_impl_fast.pxd | 15 +
.../pyflink/fn_execution/coder_impl_fast.pyx | 77 +
.../pyflink/fn_execution/coder_impl_slow.py | 80 +
flink-python/pyflink/fn_execution/coders.py | 39 +-
.../fn_execution/datastream/embedded/operations.py | 218 +-
.../datastream/embedded/process_function.py | 180 +-
.../datastream/embedded/runtime_context.py | 41 +-
.../datastream/embedded/side_output_context.py | 47 +
.../fn_execution/datastream/embedded/state_impl.py | 184 +-
.../datastream/embedded/timerservice_impl.py | 45 +-
.../fn_execution/datastream/process/operations.py | 2 +-
.../datastream/process/timerservice_impl.py | 11 +-
.../datastream/window/window_operator.py | 14 +-
.../pyflink/fn_execution/embedded/converters.py | 50 +-
.../fn_execution/embedded/operation_utils.py | 16 +-
.../pyflink/fn_execution/embedded/operations.py | 20 +-
.../pyflink/fn_execution/embedded/state_impl.py | 87 +
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 3301 ++---------
.../pyflink/fn_execution/metrics}/__init__.py | 0
.../fn_execution/metrics/embedded}/__init__.py | 0
.../fn_execution/metrics/embedded/counter_impl.py | 41 +
.../metrics/embedded/distribution_impl.py | 29 +
.../fn_execution/metrics/embedded/meter_impl.py | 36 +
.../fn_execution/metrics/embedded/metric_impl.py | 61 +
.../fn_execution/metrics/process}/__init__.py | 0
.../fn_execution/metrics/process/counter_impl.py | 49 +
.../metrics/process/distribution_impl.py | 31 +
.../fn_execution/metrics/process/meter_impl.py | 42 +
.../fn_execution/metrics/process/metric_impl.py | 103 +
.../fn_execution/metrics/tests}/__init__.py | 0
.../fn_execution/metrics/tests/test_metric.py | 97 +
.../pyflink/fn_execution/table/operations.py | 2 +-
.../fn_execution/table/window_aggregate_fast.pyx | 4 +-
.../fn_execution/table/window_aggregate_slow.py | 4 +-
flink-python/pyflink/gen_protos.py | 9 +-
flink-python/pyflink/metrics/metricbase.py | 161 +-
flink-python/pyflink/metrics/tests/test_metric.py | 98 -
.../pyflink/proto/flink-fn-execution.proto | 4 +
flink-python/pyflink/pyflink_gateway_server.py | 18 +-
flink-python/pyflink/table/catalog.py | 34 +
flink-python/pyflink/table/tests/test_calc.py | 4 +-
flink-python/pyflink/table/tests/test_correlate.py | 4 +-
.../pyflink/table/tests/test_dependency.py | 48 +-
.../table/tests/test_environment_settings.py | 4 +-
.../pyflink/table/tests/test_pandas_udaf.py | 444 +-
.../pyflink/table/tests/test_pandas_udf.py | 17 +-
.../table/tests/test_row_based_operation.py | 44 +-
.../pyflink/table/tests/test_set_operation.py | 9 +-
flink-python/pyflink/table/tests/test_sql.py | 11 +-
.../table/tests/test_table_environment_api.py | 243 +-
flink-python/pyflink/table/tests/test_udaf.py | 239 +-
flink-python/pyflink/table/tests/test_udf.py | 100 +-
flink-python/pyflink/table/tests/test_udtf.py | 35 +-
flink-python/pyflink/table/tests/test_window.py | 10 +-
flink-python/pyflink/table/types.py | 11 +-
flink-python/pyflink/table/utils.py | 2 +-
flink-python/pyflink/testing/test_case_utils.py | 175 +-
flink-python/pyflink/util/java_utils.py | 3 +-
flink-python/pyflink/version.py | 2 +-
flink-python/setup.py | 5 +-
.../chain/PythonOperatorChainingOptimizer.java | 49 +-
.../flink/python/metric/FlinkMetricContainer.java | 279 -
.../python/metric/embedded/MetricDistribution.java | 38 +
.../flink/python/metric/embedded/MetricGauge.java | 40 +
.../metric/process/FlinkMetricContainer.java | 282 +
.../apache/flink/python/util/PythonConfigUtil.java | 35 +-
.../python/AbstractPythonFunctionOperator.java | 2 +-
.../python/DataStreamPythonFunctionOperator.java | 9 +
...ctEmbeddedDataStreamPythonFunctionOperator.java | 71 +
...ractOneInputEmbeddedPythonFunctionOperator.java | 8 +-
...ractTwoInputEmbeddedPythonFunctionOperator.java | 8 +-
...eddedPythonBatchCoBroadcastProcessOperator.java | 82 +
...PythonBatchKeyedCoBroadcastProcessOperator.java | 80 +
.../embedded/EmbeddedPythonCoProcessOperator.java | 2 +-
.../EmbeddedPythonKeyedCoProcessOperator.java | 2 +-
.../EmbeddedPythonKeyedProcessOperator.java | 2 +-
.../embedded/EmbeddedPythonProcessOperator.java | 2 +-
.../embedded/EmbeddedPythonWindowOperator.java | 211 +
...ctExternalDataStreamPythonFunctionOperator.java | 8 +-
.../beam/BeamDataStreamPythonFunctionRunner.java | 2 +-
.../python/beam/BeamPythonFunctionRunner.java | 2 +-
.../flink/streaming/api/utils/PythonTypeUtils.java | 425 +-
...thonBroadcastStateTransformationTranslator.java | 68 +-
...eyedBroadcastStateTransformationTranslator.java | 68 +-
.../flink/table/runtime/arrow/ArrowReader.java | 4 +-
.../python/beam/BeamTablePythonFunctionRunner.java | 2 +-
flink-python/src/main/resources/META-INF/NOTICE | 63 +-
.../META-INF/licenses/LICENSE.bouncycastle | 17 -
.../main/resources/META-INF/licenses/LICENSE.jzlib | 25 -
.../python/metric/FlinkMetricContainerTest.java | 199 -
.../metric/process/FlinkMetricContainerTest.java | 199 +
.../streaming/api/utils/PythonTypeUtilsTest.java | 63 +
.../PassThroughPythonAggregateFunctionRunner.java | 2 +-
.../PassThroughPythonScalarFunctionRunner.java | 2 +-
.../PassThroughPythonTableFunctionRunner.java | 2 +-
...ThroughStreamAggregatePythonFunctionRunner.java | 2 +-
...amGroupWindowAggregatePythonFunctionRunner.java | 2 +-
...ghStreamTableAggregatePythonFunctionRunner.java | 2 +-
.../flink/table/runtime/utils/PythonTestUtils.java | 2 +-
flink-python/tox.ini | 4 -
.../flink-queryable-state-client-java/pom.xml | 2 +-
.../flink-queryable-state-runtime/pom.xml | 2 +-
.../KVStateRequestSerializerRocksDBTest.java | 2 +-
.../network/KvStateRequestSerializerTest.java | 2 +-
flink-queryable-state/pom.xml | 2 +-
flink-quickstart/flink-quickstart-java/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 1 +
flink-quickstart/flink-quickstart-scala/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 1 +
flink-quickstart/pom.xml | 2 +-
flink-rpc/flink-rpc-akka-loader/pom.xml | 2 +-
flink-rpc/flink-rpc-akka/pom.xml | 2 +-
.../runtime/rpc/akka/AkkaInvocationHandler.java | 62 +-
.../flink/runtime/rpc/akka/AkkaRpcService.java | 77 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink/runtime/rpc/akka/AkkaRpcServiceTest.java | 96 +-
.../rpc/akka/ContextClassLoadingSettingTest.java | 103 +-
flink-rpc/flink-rpc-core/pom.xml | 2 +-
.../org/apache/flink/runtime/rpc/RpcEndpoint.java | 29 +-
.../apache/flink/runtime/rpc/RpcGatewayUtils.java | 87 +
.../org/apache/flink/runtime/rpc/RpcService.java | 74 +-
flink-rpc/pom.xml | 2 +-
flink-runtime-web/pom.xml | 10 +-
.../runtime/webmonitor/history/HistoryServer.java | 3 +-
.../history/HistoryServerArchiveFetcher.java | 3 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../rest/compatibility/CompatibilityRoutines.java | 298 -
.../rest/compatibility/RestAPIStabilityTest.java | 270 -
.../compatibility/RuntimeRestAPIStabilityTest.java | 64 +
.../runtime/webmonitor/WebFrontendITCase.java | 17 +-
.../webmonitor/history/HistoryServerTest.java | 4 +-
.../src/test/resources/rest_api_v1.snapshot | 5 +-
.../web-dashboard/src/app/app.interceptor.ts | 2 +-
.../src/app/interfaces/job-checkpoint.ts | 1 +
.../job/checkpoints/job-checkpoints.component.html | 10 +-
.../job-overview-drawer-subtasks.component.html | 12 +-
.../customize/job-list/job-list.component.html | 2 +-
.../share/customize/job-list/job-list.component.ts | 1 +
flink-runtime/pom.xml | 10 +-
.../runtime/checkpoint/CheckpointCoordinator.java | 14 +-
.../checkpoint/CheckpointFailureManager.java | 3 +-
.../runtime/checkpoint/DefaultCheckpointPlan.java | 5 +-
.../checkpoint/FinishedTaskStateProvider.java | 23 +-
.../OperatorCoordinatorCheckpointContext.java | 2 -
.../checkpoint/OperatorCoordinatorCheckpoints.java | 2 +-
.../TaskDeploymentDescriptorFactory.java | 15 +-
.../dispatcher/ConfigurationNotAllowedMessage.java | 5 +-
.../DefaultJobManagerRunnerRegistry.java | 6 +-
.../JobDispatcherLeaderProcessFactoryFactory.java | 10 +-
.../runner/SessionDispatcherLeaderProcess.java | 4 +
.../runtime/entrypoint/ClusterEntrypoint.java | 6 +
.../entrypoint/parser/CommandLineOptions.java | 4 +
.../executiongraph/AccessExecutionGraph.java | 8 +
.../executiongraph/ArchivedExecutionGraph.java | 14 +
.../executiongraph/DefaultExecutionGraph.java | 30 +-
.../flink/runtime/executiongraph/EdgeManager.java | 24 +-
.../executiongraph/EdgeManagerBuildUtil.java | 21 +-
.../flink/runtime/executiongraph/Execution.java | 65 +-
.../runtime/executiongraph/IntermediateResult.java | 70 +-
.../IntermediateResultPartition.java | 58 +-
.../RestartPipelinedRegionFailoverStrategy.java | 43 +-
.../SchedulingPipelinedRegionComputeUtil.java | 32 +-
.../highavailability/FileSystemJobResultStore.java | 3 +-
.../flink/runtime/history/FsJobArchivist.java | 3 +-
.../io/disk/BatchShuffleReadBufferPool.java | 5 +-
.../io/network/NettyShuffleEnvironment.java | 44 +-
.../io/network/NettyShuffleServiceFactory.java | 6 +-
.../runtime/io/network/buffer/CompositeBuffer.java | 233 +
.../runtime/io/network/buffer/NetworkBuffer.java | 6 +-
.../buffer/ReadOnlySlicedNetworkBuffer.java | 20 +-
.../runtime/io/network/netty/NettyMessage.java | 7 +-
.../io/network/partition/DataSetMetaInfo.java | 8 +-
.../partition/JobMasterPartitionTracker.java | 27 +-
.../partition/JobMasterPartitionTrackerImpl.java | 89 +-
.../network/partition/PartitionedFileReader.java | 166 +-
.../network/partition/ResultPartitionFactory.java | 15 +-
.../io/network/partition/ResultPartitionType.java | 41 +-
.../partition/SortMergeResultPartition.java | 27 +-
.../SortMergeResultPartitionReadScheduler.java | 89 +-
.../partition/SortMergeSubpartitionReader.java | 24 +-
.../TaskExecutorPartitionTrackerImpl.java | 10 +
.../partition/consumer/LocalInputChannel.java | 7 +-
.../network/partition/hybrid/HsFileDataIndex.java | 8 +-
.../partition/hybrid/HsFileDataIndexImpl.java | 26 +-
.../partition/hybrid/HsFileDataManager.java | 42 +-
.../partition/hybrid/HsFullSpillingStrategy.java | 32 +-
.../partition/hybrid/HsMemoryDataManager.java | 65 +-
.../hybrid/HsMemoryDataManagerOperation.java | 6 +-
.../partition/hybrid/HsMemoryDataSpiller.java | 35 +-
.../network/partition/hybrid/HsOutputMetrics.java | 40 +
.../partition/hybrid/HsResultPartition.java | 27 +-
.../hybrid/HsSelectiveSpillingStrategy.java | 2 +-
.../partition/hybrid/HsSpillingStrategy.java | 2 +-
.../partition/hybrid/HsSubpartitionFileReader.java | 4 +-
.../hybrid/HsSubpartitionFileReaderImpl.java | 26 +-
.../hybrid/HsSubpartitionMemoryDataManager.java | 56 +-
.../partition/hybrid/HsSubpartitionView.java | 26 +-
.../HsSubpartitionViewInternalOperations.java | 11 +-
.../hybrid/HybridShuffleConfiguration.java | 53 +-
.../runtime/jobgraph/IntermediateDataSet.java | 40 +-
.../org/apache/flink/runtime/jobgraph/JobEdge.java | 48 +-
.../apache/flink/runtime/jobgraph/JobGraph.java | 5 +-
.../apache/flink/runtime/jobgraph/JobVertex.java | 41 +-
.../DefaultSlotPoolServiceSchedulerFactory.java | 14 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 50 +-
.../runtime/jobmaster/RpcTaskManagerGateway.java | 3 +-
.../runtime/messages/webmonitor/JobDetails.java | 96 +-
.../metrics/groups/InternalCacheMetricGroup.java | 2 +
.../flink/runtime/minicluster/MiniCluster.java | 25 +
.../coordination/AcknowledgeCheckpointEvent.java | 37 +
.../operators/coordination/CoordinatorStore.java | 4 +
.../coordination/CoordinatorStoreImpl.java | 5 +
.../operators/coordination/EventSender.java | 37 -
.../coordination/OperatorCoordinatorHolder.java | 152 +-
.../operators/coordination/OperatorEventValve.java | 202 -
.../operators/coordination/SubtaskAccess.java | 6 +-
.../operators/coordination/SubtaskGatewayImpl.java | 192 +-
.../runtime/registration/RetryingRegistration.java | 19 +-
.../flink/runtime/rest/HttpMethodWrapper.java | 3 +-
.../flink/runtime/rest/RestServerEndpoint.java | 3 +
.../dataset/ClusterDataSetDeleteHandlers.java | 2 +-
.../handler/job/JobVertexBackPressureHandler.java | 34 +-
.../job/checkpoints/CheckpointConfigHandler.java | 6 +
.../rest/handler/legacy/metrics/MetricStore.java | 49 +-
.../messages/checkpoints/CheckpointConfigInfo.java | 9 +
.../rest/messages/dataset/ClusterDataSetEntry.java | 2 +-
.../flink/runtime/rest/util/RestMapperUtils.java | 4 +-
...achedIntermediateDataSetCorruptedException.java | 44 -
.../ClusterDatasetCorruptedException.java | 43 +
.../flink/runtime/scheduler/DefaultScheduler.java | 7 +-
.../runtime/scheduler/DefaultSchedulerFactory.java | 2 +-
.../SsgNetworkMemoryCalculationUtils.java | 44 +-
.../adapter/DefaultExecutionTopology.java | 10 +-
.../scheduler/adapter/DefaultResultPartition.java | 11 +-
.../adapter/DefaultSchedulingPipelinedRegion.java | 18 +-
.../scheduler/strategy/ConsumedPartitionGroup.java | 19 +-
.../PipelinedRegionSchedulingStrategy.java | 205 +-
.../strategy/SchedulingPipelinedRegion.java | 2 +-
.../strategy/SchedulingResultPartition.java | 7 +-
.../strategy/VertexwiseSchedulingStrategy.java | 10 +-
.../flink/runtime/shuffle/NettyShuffleMaster.java | 2 +-
.../shuffle/TaskInputsOutputsDescriptor.java | 13 +-
.../source/coordinator/SourceCoordinator.java | 46 +-
.../coordinator/SourceCoordinatorProvider.java | 8 +-
.../state/ChangelogTaskLocalStateStore.java | 33 +-
.../runtime/state/HeapPriorityQueuesManager.java | 22 +-
.../flink/runtime/state/KeyedStateFactory.java | 39 +-
.../runtime/state/PriorityQueueSetFactory.java | 24 +
.../RegisteredBroadcastStateBackendMetaInfo.java | 6 +
.../RegisteredKeyValueStateBackendMetaInfo.java | 6 +
.../RegisteredOperatorStateBackendMetaInfo.java | 6 +
...egisteredPriorityQueueStateBackendMetaInfo.java | 6 +
.../runtime/state/RegisteredStateMetaInfoBase.java | 9 +
.../apache/flink/runtime/state/StateBackend.java | 9 +
.../flink/runtime/state/StateBackendLoader.java | 2 +-
.../TaskExecutorStateChangelogStoragesManager.java | 101 +-
.../flink/runtime/state/TaskStateManager.java | 10 +
.../flink/runtime/state/TaskStateManagerImpl.java | 26 +
.../changelog/ChangelogStateBackendHandle.java | 61 +-
.../state/changelog/LocalChangelogRegistry.java | 64 +
.../changelog/LocalChangelogRegistryImpl.java | 118 +
.../changelog/StateChangelogStorageFactory.java | 8 +-
.../changelog/StateChangelogStorageLoader.java | 13 +-
.../state/changelog/StateChangelogWriter.java | 21 +-
.../InMemoryStateChangelogStorageFactory.java | 8 +-
.../inmemory/InMemoryStateChangelogWriter.java | 15 +-
.../state/delegate/DelegatingStateBackend.java | 5 +
.../filesystem/FsCheckpointStorageAccess.java | 10 +-
.../runtime/state/filesystem/FsStateBackend.java | 2 +-
.../runtime/state/heap/AbstractHeapState.java | 22 +-
.../runtime/state/heap/HeapAggregatingState.java | 20 +-
.../runtime/state/heap/HeapKeyedStateBackend.java | 120 +-
.../flink/runtime/state/heap/HeapListState.java | 11 +
.../flink/runtime/state/heap/HeapMapState.java | 11 +
.../HeapPriorityQueueSnapshotRestoreWrapper.java | 18 +
.../runtime/state/heap/HeapReducingState.java | 19 +-
.../flink/runtime/state/heap/HeapValueState.java | 10 +
.../runtime/state/memory/MemoryStateBackend.java | 2 +-
.../flink/runtime/state/ttl/TtlStateFactory.java | 4 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 41 +-
.../runtime/taskexecutor/TaskExecutorGateway.java | 20 +-
.../TaskExecutorGatewayDecoratorBase.java | 13 +-
.../org/apache/flink/runtime/taskmanager/Task.java | 36 +-
.../CheckpointCoordinatorTestingUtils.java | 24 +-
.../checkpoint/CheckpointFailureManagerTest.java | 5 +-
.../TaskDeploymentDescriptorFactoryTest.java | 4 +-
.../DefaultJobManagerRunnerRegistryTest.java | 42 +-
.../runner/SessionDispatcherLeaderProcessTest.java | 2 +-
.../BlockingResultPartitionReleaseTest.java | 151 +
.../DefaultExecutionGraphConstructionTest.java | 270 +-
.../executiongraph/EdgeManagerBuildUtilTest.java | 30 +-
.../runtime/executiongraph/EdgeManagerTest.java | 112 +-
.../executiongraph/ExecutionGraphTestUtils.java | 19 +
.../executiongraph/ExecutionJobVertexTest.java | 130 +-
.../IntermediateResultPartitionTest.java | 186 +-
.../RemoveCachedShuffleDescriptorTest.java | 215 +-
...RestartPipelinedRegionFailoverStrategyTest.java | 81 +-
...FileSystemJobResultStoreFileOperationsTest.java | 255 +
.../FileSystemJobResultStoreTestInternal.java | 254 -
.../network/buffer/ReadOnlySlicedBufferTest.java | 20 +-
.../JobMasterPartitionTrackerImplTest.java | 239 +-
.../partition/NoOpJobMasterPartitionTracker.java | 12 +-
.../partition/PartitionedFileWriteReadTest.java | 156 +-
.../network/partition/ResultPartitionBuilder.java | 9 +-
.../partition/ResultPartitionFactoryTest.java | 30 +-
.../SortMergeResultPartitionReadSchedulerTest.java | 156 +-
.../partition/SortMergeResultPartitionTest.java | 34 +-
.../partition/SortMergeSubpartitionReaderTest.java | 158 +-
.../TestingJobMasterPartitionTracker.java | 31 +-
.../partition/hybrid/HsFileDataIndexImplTest.java | 34 +-
.../partition/hybrid/HsFileDataManagerTest.java | 80 +-
.../hybrid/HsFullSpillingStrategyTest.java | 20 +-
.../partition/hybrid/HsMemoryDataManagerTest.java | 78 +-
.../partition/hybrid/HsMemoryDataSpillerTest.java | 46 +-
.../partition/hybrid/HsResultPartitionTest.java | 75 +-
.../hybrid/HsSelectiveSpillingStrategyTest.java | 2 +-
.../hybrid/HsSubpartitionFileReaderImplTest.java | 46 +-
.../HsSubpartitionMemoryDataManagerTest.java | 166 +-
.../partition/hybrid/HsSubpartitionViewTest.java | 87 +-
.../partition/hybrid/HybridShuffleTestUtils.java | 5 +
.../partition/hybrid/TestingFileDataIndex.java | 23 +-
.../hybrid/TestingMemoryDataManagerOperation.java | 2 +-
.../partition/hybrid/TestingSpillingStrategy.java | 14 +-
.../TestingSubpartitionViewInternalOperation.java | 2 +-
.../flink/runtime/jobgraph/JobTaskVertexTest.java | 195 +-
.../jobgraph/jsonplan/JsonGeneratorTest.java | 3 +-
.../jobmanager/HighAvailabilityModeTest.java | 2 +-
...DefaultSlotPoolServiceSchedulerFactoryTest.java | 2 +-
.../jobmaster/JobIntermediateDatasetReuseTest.java | 64 +-
.../jobmaster/JobMasterPartitionReleaseTest.java | 19 +-
.../runtime/jobmaster/JobMasterSchedulerTest.java | 2 +-
...rMultipleComponentLeaderElectionDriverTest.java | 18 +
.../messages/webmonitor/JobDetailsTest.java | 31 -
.../runtime/metrics/util/MetricUtilsTest.java | 7 +-
.../coordination/ComponentClosingUtilsTest.java | 64 +-
.../CoordinatorEventsExactlyOnceITCase.java | 164 +-
.../coordination/EventReceivingTasks.java | 56 +-
.../OperatorCoordinatorHolderTest.java | 141 +-
.../OperatorCoordinatorSchedulerTest.java | 221 +-
.../coordination/OperatorEventValveTest.java | 133 -
.../RecreateOnResetOperatorCoordinatorTest.java | 86 +-
.../coordination/SubtaskGatewayImplTest.java | 175 +
.../coordination/TestingOperatorCoordinator.java | 7 +
.../util/IncompleteFuturesTrackerTest.java | 29 +-
.../registration/RetryingRegistrationTest.java | 10 -
.../resourcemanager/ResourceManagerTest.java | 2 +-
.../runtime/rest/compatibility/Compatibility.java | 0
.../compatibility/CompatibilityCheckResult.java | 0
.../rest/compatibility/CompatibilityRoutine.java | 0
.../rest/compatibility/CompatibilityRoutines.java | 299 +
.../compatibility/RestAPIStabilityTestUtils.java | 253 +
.../job/JobVertexBackPressureHandlerTest.java | 12 +-
.../handler/legacy/metrics/MetricStoreTest.java | 114 +-
.../utils/ArchivedExecutionGraphBuilder.java | 2 +
.../taskmanager/TaskManagerDetailsHandlerTest.java | 3 +-
.../checkpoints/CheckpointConfigInfoTest.java | 1 +
.../messages/json/JobResultDeserializerTest.java | 3 +-
.../json/SerializedThrowableSerializerTest.java | 5 +-
.../json/SerializedValueSerializerTest.java | 3 +-
.../util/DocumentingDispatcherRestEndpoint.java | 6 +-
.../flink/runtime/rpc/RpcConnectionTest.java | 51 +-
.../apache/flink/runtime/rpc/RpcEndpointTest.java | 29 +-
.../flink/runtime/rpc/TestingRpcService.java | 31 +-
.../runtime/scheduler/SchedulerTestingUtils.java | 137 +
.../SsgNetworkMemoryCalculationUtilsTest.java | 83 +-
.../scheduler/TestingSchedulerNGFactory.java | 2 +-
.../adapter/DefaultExecutionTopologyTest.java | 143 +-
.../adapter/DefaultExecutionVertexTest.java | 26 +-
.../adapter/DefaultResultPartitionTest.java | 43 +-
.../DefaultSchedulingPipelinedRegionTest.java | 7 +-
.../adaptive/StateTrackingMockExecutionGraph.java | 6 +
.../adaptivebatch/AdaptiveBatchSchedulerTest.java | 40 +-
.../forwardgroup/ForwardGroupComputeUtilTest.java | 49 +-
...hedulingDownstreamTasksInBatchJobBenchmark.java | 28 +-
.../PipelinedRegionSchedulingStrategyTest.java | 273 +-
.../scheduler/strategy/StrategyTestUtil.java | 13 +-
.../strategy/TestingSchedulingExecutionVertex.java | 7 +-
.../strategy/TestingSchedulingPipelinedRegion.java | 2 +-
.../strategy/TestingSchedulingResultPartition.java | 9 +-
.../strategy/TestingSchedulingTopology.java | 1 +
.../coordinator/SourceCoordinatorProviderTest.java | 3 +-
.../source/coordinator/SourceCoordinatorTest.java | 34 +-
.../coordinator/SourceCoordinatorTestBase.java | 3 +-
.../state/ChangelogTaskLocalStateStoreTest.java | 2 +
.../state/StateBackendMigrationTestBase.java | 113 +-
.../flink/runtime/state/StateBackendTestBase.java | 10 +-
.../flink/runtime/state/StateBackendTestUtils.java | 4 +-
.../state/StateSnapshotCompressionTest.java | 4 +-
.../state/StateSnapshotTransformerTest.java | 6 +-
...kExecutorStateChangelogStoragesManagerTest.java | 65 +-
.../runtime/state/TaskStateManagerImplTest.java | 4 +
.../flink/runtime/state/TestTaskStateManager.java | 25 +-
.../runtime/state/TestTaskStateManagerBuilder.java | 7 +-
.../changelog/LocalChangelogRegistryTest.java | 56 +
.../inmemory/StateChangelogStorageLoaderTest.java | 19 +-
.../inmemory/StateChangelogStorageTest.java | 7 +-
...HeapKeyedStateBackendSnapshotMigrationTest.java | 2 +-
.../flink/runtime/state/ttl/TtlStateTestBase.java | 6 +-
.../state/ttl/mock/MockKeyedStateBackend.java | 2 +-
...cutorExecutionDeploymentReconciliationTest.java | 14 +-
.../TaskExecutorPartitionLifecycleTest.java | 28 +-
.../taskexecutor/TaskExecutorSlotLifetimeTest.java | 14 +
.../taskexecutor/TestingTaskExecutorGateway.java | 27 +-
.../TestingTaskExecutorGatewayBuilder.java | 30 +-
.../runtime/testutils/MiniClusterResource.java | 6 +
.../runtime/util/JvmExitOnFatalErrorTest.java | 2 +
flink-scala/pom.xml | 8 +-
.../BatchScalaAPICompletenessTest.scala | 2 +-
.../ScalaAPICompletenessTestBase.scala | 10 +-
.../flink-statebackend-changelog/pom.xml | 8 +-
.../state/changelog/AbstractChangelogState.java | 12 +-
.../state/changelog/AbstractStateChangeLogger.java | 8 +-
.../ChangelogKeyGroupedPriorityQueue.java | 12 +-
.../changelog/ChangelogKeyedStateBackend.java | 205 +-
.../ChangelogMaterializationMetricGroup.java | 65 -
.../flink/state/changelog/ChangelogState.java | 2 +
.../state/changelog/ChangelogStateBackend.java | 4 +
.../state/changelog/ChangelogTruncateHelper.java | 1 +
.../DeactivatedChangelogStateBackend.java | 3 +
.../state/changelog/KvStateChangeLoggerImpl.java | 31 +-
.../changelog/PeriodicMaterializationManager.java | 327 --
.../PriorityQueueStateChangeLoggerImpl.java | 14 +-
.../restore/ChangelogBackendLogApplier.java | 1 -
.../restore/ChangelogBackendRestoreOperation.java | 17 +-
.../restore/ChangelogMigrationRestoreTarget.java | 58 +-
.../changelog/ChangelogKeyedStateBackendTest.java | 2 +-
.../state/changelog/ChangelogMetricGroupTest.java | 8 +-
.../ChangelogStateBackendMigrationTest.java | 65 +
.../changelog/ChangelogStateBackendTestUtils.java | 6 +-
.../state/changelog/ChangelogStateDiscardTest.java | 22 +-
.../state/changelog/StateChangeLoggerTestBase.java | 7 +-
.../flink-statebackend-common/pom.xml | 77 +
.../ChangelogMaterializationMetricGroup.java | 67 +
.../common/PeriodicMaterializationManager.java | 391 ++
.../common/PeriodicMaterializationManagerTest.java | 67 +
.../flink-statebackend-heap-spillable/pom.xml | 2 +-
.../flink-statebackend-rocksdb/pom.xml | 2 +-
.../streaming/state/AbstractRocksDBState.java | 22 +-
.../streaming/state/RocksDBAggregatingState.java | 23 +-
.../streaming/state/RocksDBKeyedStateBackend.java | 154 +-
.../state/RocksDBKeyedStateBackendBuilder.java | 17 +-
.../contrib/streaming/state/RocksDBListState.java | 24 +-
.../contrib/streaming/state/RocksDBMapState.java | 29 +-
.../state/RocksDBPriorityQueueSetFactory.java | 36 +-
.../streaming/state/RocksDBReducingState.java | 21 +-
.../contrib/streaming/state/RocksDBValueState.java | 13 +
.../snapshot/RocksDBSnapshotStrategyBase.java | 318 +-
.../state/snapshot/RocksFullSnapshotStrategy.java | 169 -
.../snapshot/RocksIncrementalSnapshotStrategy.java | 323 +-
.../snapshot/RocksNativeFullSnapshotStrategy.java | 255 +
.../state/snapshot/RocksSnapshotUtil.java | 13 +
.../state/EmbeddedRocksDBStateBackendTest.java | 14 +-
.../RocksIncrementalSnapshotStrategyTest.java | 2 +-
.../state/ttl/FullSnapshotRocksDbTtlStateTest.java | 5 +
.../state/ttl/IncSnapshotRocksDbTtlStateTest.java | 2 +-
flink-state-backends/pom.xml | 3 +-
flink-streaming-java/pom.xml | 21 +-
.../streaming/api/datastream/CachedDataStream.java | 61 +
.../streaming/api/datastream/KeyedStream.java | 28 +
.../api/datastream/SideOutputDataStream.java | 56 +
.../api/datastream/SingleOutputStreamOperator.java | 22 +-
.../api/environment/CheckpointConfig.java | 9 +
.../environment/ExecutionCheckpointingOptions.java | 3 +-
.../environment/StreamExecutionEnvironment.java | 181 +-
.../streaming/api/functions/sink/PrintSink.java | 97 +
.../api/graph/GlobalStreamExchangeMode.java | 7 +-
.../flink/streaming/api/graph/JSONGenerator.java | 3 +-
.../streaming/api/graph/NonChainedOutput.java | 146 +
.../flink/streaming/api/graph/StreamConfig.java | 56 +-
.../flink/streaming/api/graph/StreamEdge.java | 20 +-
.../flink/streaming/api/graph/StreamGraph.java | 37 +-
.../streaming/api/graph/StreamGraphGenerator.java | 9 +-
.../flink/streaming/api/graph/StreamNode.java | 13 +
.../api/graph/StreamingJobGraphGenerator.java | 198 +-
.../streaming/api/operators/SourceOperator.java | 85 +-
.../api/operators/SourceOperatorFactory.java | 11 +-
.../api/operators/async/AsyncWaitOperator.java | 8 +-
.../api/operators/co/IntervalJoinOperator.java | 21 +-
.../state/BatchExecutionKeyedStateBackend.java | 2 +-
.../source/ProgressiveTimestampsAndWatermarks.java | 86 +-
.../operators/source/TimestampsAndWatermarks.java | 3 +
.../operators/source/WatermarkToDataOutput.java | 10 +-
.../api/transformations/CacheTransformation.java | 89 +
.../api/transformations/SourceTransformation.java | 12 +
.../api/transformations/StreamExchangeMode.java | 11 +-
.../partitioner/CustomPartitionerWrapper.java | 20 +
.../runtime/tasks/FinishedOperatorChain.java | 1 +
.../streaming/runtime/tasks/OperatorChain.java | 87 +-
.../runtime/tasks/OperatorEventDispatcherImpl.java | 5 +
.../runtime/tasks/RegularOperatorChain.java | 1 +
.../flink/streaming/runtime/tasks/StreamTask.java | 25 +-
.../translators/CacheTransformationTranslator.java | 207 +
.../SourceTransformationTranslator.java | 1 +
.../CheckpointConfigFromConfigurationTest.java | 2 +-
...ecutionEnvironmentComplexConfigurationTest.java | 21 -
.../streaming/api/functions/PrintSinkTest.java | 232 +
.../StreamGraphGeneratorBatchExecutionTest.java | 9 +-
.../api/graph/StreamGraphGeneratorTest.java | 273 +-
.../api/graph/StreamingJobGraphGeneratorTest.java | 847 ++-
.../SourceOperatorSplitWatermarkAlignmentTest.java | 155 +
.../StateInitializationContextImplTest.java | 2 +
.../api/operators/async/AsyncWaitOperatorTest.java | 20 +-
.../api/operators/co/IntervalJoinOperatorTest.java | 10 +
.../source/SourceOperatorEventTimeTest.java | 155 +-
.../operators/GenericWriteAheadSinkTest.java | 57 +-
.../runtime/operators/WriteAheadSinkTestBase.java | 19 +-
.../ForwardForConsecutiveHashPartitionerTest.java | 26 +-
.../ForwardForUnspecifiedPartitionerTest.java | 25 +-
...ToStreamOperatorRecipientExactlyOnceITCase.java | 733 +++
.../runtime/tasks/LocalStateForwardingTest.java | 2 +
.../runtime/tasks/StreamConfigChainer.java | 69 +-
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 25 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 60 +
.../runtime/tasks/StreamTaskTestHarness.java | 30 +-
.../tasks/SubtaskCheckpointCoordinatorTest.java | 1 +
.../streaming/runtime/tasks/TestStateBackend.java | 2 +-
.../flink/streaming/util/MockStreamConfig.java | 29 +-
flink-streaming-scala/pom.xml | 13 +-
.../streaming/api/scala/CachedDataStream.scala | 29 +
.../flink/streaming/api/scala/DataStream.scala | 8 +
.../api/scala/StreamExecutionEnvironment.scala | 10 +-
.../scala/StreamingScalaAPICompletenessTest.scala | 8 +-
flink-table/flink-sql-client/pom.xml | 2 +-
.../apache/flink/table/client/cli/CliClient.java | 51 +-
.../apache/flink/table/client/cli/CliStrings.java | 3 -
.../flink/table/client/gateway/Executor.java | 6 -
.../client/gateway/context/SessionContext.java | 75 +-
.../table/client/gateway/local/LocalExecutor.java | 12 -
.../client/resource/ClientResourceManager.java | 13 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink/table/client/cli/CliClientITCase.java | 20 +-
.../flink/table/client/cli/CliClientTest.java | 47 +-
.../flink/table/client/cli/CliResultViewTest.java | 10 -
.../flink/table/client/cli/TestingExecutor.java | 10 -
.../table/client/cli/utils/SqlParserHelper.java | 23 +-
.../client/gateway/context/SessionContextTest.java | 64 +-
.../src/test/resources/sql/function.q | 16 +-
.../flink-sql-client/src/test/resources/sql/set.q | 94 +-
flink-table/flink-sql-gateway-api/pom.xml | 14 +-
.../flink/table/gateway/api/SqlGatewayService.java | 84 +-
.../table/gateway/api/operation/OperationType.java | 37 -
.../table/gateway/api/results/FunctionInfo.java | 83 +
.../table/gateway/api/results/GatewayInfo.java | 38 +
.../table/gateway/api/results/OperationInfo.java | 22 +-
.../flink/table/gateway/api/results/ResultSet.java | 9 +-
.../flink/table/gateway/api/results/TableInfo.java | 75 +
.../gateway/api/session/SessionEnvironment.java | 16 -
.../SqlGatewayEndpointFactoryUtilsTest.java | 2 +-
.../api/session/SessionEnvironmentTest.java | 2 -
.../gateway/api/utils/MockedSqlGatewayService.java | 56 +-
flink-table/flink-sql-gateway/pom.xml | 7 +-
.../table/gateway/cli/SqlGatewayOptionsParser.java | 2 +-
.../table/gateway/rest/SqlGatewayRestEndpoint.java | 69 +
.../rest/SqlGatewayRestEndpointFactory.java | 101 +
.../operation/AbstractOperationHandler.java | 82 +
.../handler/operation/CancelOperationHandler.java | 49 +
.../handler/operation/CloseOperationHandler.java | 55 +
.../operation/GetOperationStatusHandler.java | 42 +
.../handler/statement/ExecuteStatementHandler.java | 77 +
.../handler/statement/FetchResultsHandler.java | 91 +
.../rest/handler/util/GetApiVersionHandler.java | 62 +
.../gateway/rest/handler/util/GetInfoHandler.java | 59 +
.../header/operation/AbstactOperationHeaders.java | 52 +
.../header/operation/CancelOperationHeaders.java | 60 +
.../header/operation/CloseOperationHeaders.java | 60 +
.../operation/GetOperationStatusHeaders.java | 60 +
.../rest/header/session/CloseSessionHeaders.java | 5 +
.../header/session/GetSessionConfigHeaders.java | 5 +
.../rest/header/session/OpenSessionHeaders.java | 5 +
.../session/TriggerSessionHeartbeatHeaders.java | 5 +
.../header/statement/ExecuteStatementHeaders.java | 85 +
.../rest/header/statement/FetchResultsHeaders.java | 105 +
.../rest/header/util/GetApiVersionHeaders.java | 82 +
.../gateway/rest/header/util/GetInfoHeaders.java | 82 +
.../operation/OperationHandleIdPathParameter.java | 49 +
.../operation/OperationMessageParameters.java | 60 +
.../operation/OperationStatusResponseBody.java | 42 +
.../message/session/OpenSessionRequestBody.java | 2 +-
.../message/session/OpenSessionResponseBody.java | 2 +-
.../statement/ExecuteStatementRequestBody.java | 72 +
.../statement/ExecuteStatementResponseBody.java | 43 +
.../statement/FetchResultsResponseBody.java | 72 +
.../statement/FetchResultsTokenParameters.java | 68 +
.../statement/FetchResultsTokenPathParameter.java | 46 +
.../message/util/GetApiVersionResponseBody.java | 44 +
.../rest/message/util/GetInfoResponseBody.java | 53 +
.../flink/table/gateway/rest/serde/ColumnInfo.java | 111 +
.../rest/serde/JsonResultSetDeserializer.java | 130 +
.../rest/serde/JsonResultSetSerializer.java | 127 +
.../rest/serde/LogicalTypeJsonDeserializer.java | 251 +
.../rest/serde/LogicalTypeJsonSerializer.java | 243 +
.../table/gateway/rest/serde/RowDataInfo.java | 59 +
.../rest/util/SqlGatewayRestEndpointFactory.java | 99 -
.../gateway/rest/util/SqlGatewayRestOptions.java | 18 +-
.../gateway/service/SqlGatewayServiceImpl.java | 91 +-
.../gateway/service/context/SessionContext.java | 177 +-
.../service/operation/OperationExecutor.java | 140 +-
.../service/operation/OperationManager.java | 28 +-
.../gateway/service/session/SessionManager.java | 12 +-
.../org.apache.flink.table.factories.Factory | 16 -
.../org.apache.flink.table.factories.Factory | 16 +
.../gateway/AbstractSqlGatewayStatementITCase.java | 3 +
.../table/gateway/rest/OperationCaseITTest.java | 170 +
.../SqlGatewayRestEndpointStatementITCase.java | 251 +
.../gateway/rest/SqlGatewayRestEndpointTest.java | 3 +-
.../flink/table/gateway/rest/UtilCaseITTest.java | 74 +
.../SqlGatewayRestAPIStabilityTest.java | 63 +
.../gateway/rest/serde/JsonResultSetSerDeTest.java | 273 +
.../rest/serde/LogicalTypeJsonSerDeTest.java | 233 +
.../util/DocumentingSqlGatewayRestEndpoint.java | 58 +
.../table/gateway/rest/util/RestConfigUtils.java | 4 +-
.../rest/util/SqlGatewayRestEndpointExtension.java | 89 +
.../gateway/service/SqlGatewayServiceITCase.java | 191 +-
.../service/context/SessionContextTest.java | 20 +-
.../org.apache.flink.table.factories.Factory | 16 -
.../src/test/resources/sql/insert.q | 53 +
.../resources/sql_gateway_rest_api_v1.snapshot | 318 ++
flink-table/flink-sql-parser-hive/pom.xml | 2 +-
.../apache/flink/sql/parser/hive/package-info.java | 13 +-
flink-table/flink-sql-parser/pom.xml | 2 +-
.../org/apache/flink/sql/parser/package-info.java | 13 +-
.../flink/sql/parser/CreateTableLikeTest.java | 9 +-
.../flink/sql/parser/FlinkDDLDataTypeTest.java | 15 +-
flink-table/flink-table-api-bridge-base/pom.xml | 2 +-
.../AbstractStreamTableEnvironmentImpl.java | 2 +
flink-table/flink-table-api-java-bridge/pom.xml | 2 +-
.../flink/table/connector/ProviderContext.java | 4 +-
flink-table/flink-table-api-java-uber/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-table/flink-table-api-java/pom.xml | 2 +-
.../org/apache/flink/table/api/TableConfig.java | 24 +-
.../apache/flink/table/api/TableEnvironment.java | 105 +-
.../table/api/config/ExecutionConfigOptions.java | 86 +-
.../table/api/config/OptimizerConfigOptions.java | 50 +
.../flink/table/api/config/TableConfigOptions.java | 4 +-
.../flink/table/api/internal/AnalyzeTableUtil.java | 32 +-
.../table/api/internal/TableEnvironmentImpl.java | 110 +-
.../flink/table/catalog/ConnectorCatalogTable.java | 4 +
.../flink/table/catalog/FunctionCatalog.java | 195 +-
.../table/operations/CreateTableASOperation.java | 89 +
.../table/operations/ModifyOperationVisitor.java | 2 +
.../operations/ddl/CreateTableASOperation.java | 82 -
.../flink/table/resource/ResourceManager.java | 85 +-
.../table/catalog/GenericInMemoryCatalogTest.java | 72 +
.../flink/table/resource/ResourceManagerTest.java | 5 +-
.../flink/table/utils/TableEnvironmentMock.java | 1 -
flink-table/flink-table-api-scala-bridge/pom.xml | 2 +-
flink-table/flink-table-api-scala/pom.xml | 2 +-
flink-table/flink-table-code-splitter/pom.xml | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-table/flink-table-common/pom.xml | 2 +-
.../org/apache/flink/table/catalog/Catalog.java | 53 +
.../table/catalog/ResolvedCatalogBaseTable.java | 2 +
.../stats/CatalogColumnStatisticsDataBinary.java | 7 +-
.../stats/CatalogColumnStatisticsDataBoolean.java | 7 +-
.../stats/CatalogColumnStatisticsDataDate.java | 7 +-
.../stats/CatalogColumnStatisticsDataDouble.java | 7 +-
.../stats/CatalogColumnStatisticsDataLong.java | 7 +-
.../stats/CatalogColumnStatisticsDataString.java | 7 +-
.../catalog/stats/CatalogTableStatistics.java | 1 +
.../connector/source/DynamicFilteringData.java | 198 +
.../connector/source/DynamicFilteringEvent.java | 45 +
.../source/abilities/SupportsDynamicFiltering.java | 18 +-
.../source/lookup/cache/DefaultLookupCache.java | 19 +
.../columnar/vector/heap/AbstractHeapVector.java | 7 +
.../data/columnar/vector/heap/HeapArrayVector.java | 89 +
.../data/columnar/vector/heap/HeapMapVector.java | 77 +
.../data/columnar/vector/heap/HeapRowVector.java | 57 +
.../apache/flink/table/factories/FactoryUtil.java | 2 +-
.../flink/table/functions/AsyncLookupFunction.java | 5 +-
.../flink/table/functions/FunctionIdentifier.java | 8 +
.../flink/table/functions/LookupFunction.java | 3 +
.../apache/flink/table/plan/stats/ColumnStats.java | 16 +-
.../apache/flink/table/plan/stats/TableStats.java | 30 +-
.../table/connector/source/CompactPartitions.java | 3 +-
.../lookup/cache/DefaultLookupCacheTest.java | 49 -
.../lookup/cache/InterceptingCacheMetricGroup.java | 71 +
.../flink/table/factories/TestCatalogFactory.java | 17 +-
.../flink/table/plan/stats/TableStatsTest.java | 93 +-
.../table/test/lookup/cache/LookupCacheAssert.java | 97 +
.../flink-table-planner-loader-bundle/pom.xml | 6 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
flink-table/flink-table-planner-loader/pom.xml | 2 +-
flink-table/flink-table-planner/pom.xml | 2 +-
.../org/apache/calcite/rel/core/Correlate.java | 278 +
.../java/org/apache/calcite/rel/core/Filter.java | 201 +
.../org/apache/calcite/rel/core/Intersect.java | 72 +
.../java/org/apache/calcite/rel/core/Minus.java | 69 +
.../java/org/apache/calcite/rel/core/SetOp.java | 158 +
.../java/org/apache/calcite/rel/core/Sort.java | 232 +
.../java/org/apache/calcite/rel/core/Union.java | 79 +
.../java/org/apache/calcite/rel/core/Values.java | 249 +
.../java/org/apache/calcite/rel/core/Window.java | 471 ++
.../apache/calcite/rel/hint/HintPredicates.java | 133 +
.../calcite/rel/hint/NodeTypeHintPredicate.java | 107 +
.../calcite/rel/logical/LogicalCorrelate.java | 188 +
.../apache/calcite/rel/logical/LogicalFilter.java | 175 +
.../calcite/rel/logical/LogicalIntersect.java | 97 +
.../apache/calcite/rel/logical/LogicalMinus.java | 101 +
.../apache/calcite/rel/logical/LogicalSort.java | 109 +
.../apache/calcite/rel/logical/LogicalUnion.java | 100 +
.../apache/calcite/rel/logical/LogicalValues.java | 169 +
.../apache/calcite/rel/logical/LogicalWindow.java | 399 ++
.../apache/calcite/sql2rel/RelDecorrelator.java | 15 +
.../apache/calcite/sql2rel/SqlToRelConverter.java | 6037 ++++++++++++++++++++
...ClearJoinHintWithInvalidPropagationShuttle.java | 179 +
.../planner/calcite/RelTimeIndicatorConverter.java | 3 +-
.../table/planner/delegation/PlannerContext.java | 2 +-
.../planner/expressions/ExpressionBuilder.java | 5 +
.../functions/aggfunctions/NTILEAggFunction.java | 112 +
.../functions/aggfunctions/SumAggFunction.java | 5 +-
.../functions/sql/FlinkSqlOperatorTable.java | 45 +-
.../table/planner/hint/FlinkHintStrategies.java | 144 +
.../flink/table/planner/hint/FlinkHints.java | 143 +
.../flink/table/planner/hint/JoinStrategy.java | 96 +
.../table/planner/hint/LookupJoinHintOptions.java | 134 +
.../operations/SqlCreateTableConverter.java | 2 +-
.../table/planner/plan/nodes/exec/ExecEdge.java | 8 +
.../table/planner/plan/nodes/exec/ExecNode.java | 6 +
.../planner/plan/nodes/exec/ExecNodeBase.java | 56 +-
.../planner/plan/nodes/exec/ExecNodeConfig.java | 43 +-
.../planner/plan/nodes/exec/ExecNodeContext.java | 20 +-
.../plan/nodes/exec/ExecNodeGraphGenerator.java | 10 +-
.../plan/nodes/exec/ExecNodeTranslator.java | 2 +-
.../BatchExecDynamicFilteringDataCollector.java | 107 +
.../plan/nodes/exec/batch/BatchExecHashJoin.java | 60 +-
.../plan/nodes/exec/batch/BatchExecLookupJoin.java | 19 +-
.../exec/batch/BatchExecOverAggregateBase.java | 5 +-
.../exec/batch/BatchExecPythonGroupAggregate.java | 9 +-
.../batch/BatchExecPythonGroupWindowAggregate.java | 8 +-
.../exec/batch/BatchExecPythonOverAggregate.java | 8 +-
.../plan/nodes/exec/batch/BatchExecSink.java | 3 +-
.../nodes/exec/batch/BatchExecSortMergeJoin.java | 61 +-
.../nodes/exec/batch/BatchExecTableSourceScan.java | 97 +-
.../nodes/exec/common/CommonExecLookupJoin.java | 368 +-
.../plan/nodes/exec/common/CommonExecMatch.java | 2 +-
.../nodes/exec/common/CommonExecPythonCalc.java | 30 +-
.../exec/common/CommonExecPythonCorrelate.java | 36 +-
.../plan/nodes/exec/common/CommonExecSink.java | 45 +-
.../exec/common/CommonExecTableSourceScan.java | 14 +-
.../DynamicFilteringDependencyProcessor.java | 207 +
.../processor/ResetTransformationProcessor.java | 46 +
.../utils/InputPriorityConflictResolver.java | 24 +-
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 17 +-
.../nodes/exec/stream/StreamExecIntervalJoin.java | 15 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 35 +-
.../nodes/exec/stream/StreamExecLookupJoin.java | 53 +-
.../plan/nodes/exec/stream/StreamExecMatch.java | 3 +-
.../nodes/exec/stream/StreamExecOverAggregate.java | 4 +-
.../stream/StreamExecPythonGroupAggregate.java | 11 +-
.../StreamExecPythonGroupTableAggregate.java | 12 +-
.../StreamExecPythonGroupWindowAggregate.java | 31 +-
.../exec/stream/StreamExecPythonOverAggregate.java | 10 +-
.../plan/nodes/exec/stream/StreamExecSink.java | 12 +-
.../exec/stream/StreamExecTableSourceScan.java | 11 +-
.../plan/nodes/exec/utils/CommonPythonUtil.java | 53 +-
.../optimize/ClearQueryBlockAliasResolver.java | 71 +
.../planner/plan/optimize/JoinHintResolver.java | 344 ++
...StreamNonDeterministicPhysicalPlanResolver.java | 193 +
.../StreamNonDeterministicUpdatePlanVisitor.java | 981 ++++
.../plan/rules/logical/FlinkFilterJoinRule.java | 510 ++
.../rules/logical/FlinkJoinToMultiJoinRule.java | 555 ++
.../logical/ProjectSnapshotTransposeRule.java | 77 +
.../plan/rules/logical/SubQueryDecorrelator.java | 22 +-
.../batch/DynamicPartitionPruningRule.java | 297 +-
.../physical/common/CommonPhysicalMatchRule.java | 3 +-
.../table/planner/plan/utils/KeySelectorUtil.java | 29 +-
.../table/planner/plan/utils/LookupJoinUtil.java | 539 +-
.../plan/utils/SorMergeJoinOperatorUtil.java | 83 +
.../table/planner/plan/utils/UpsertKeyUtil.java | 66 +
.../table/planner/typeutils/RowTypeUtils.java | 35 +
.../utils/CatalogTableStatisticsConverter.java | 27 +
.../utils/DynamicPartitionPruningUtils.java | 377 ++
.../src/main/resources/META-INF/NOTICE | 2 +-
.../planner/calcite/FlinkLogicalRelFactories.scala | 2 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 65 +-
.../planner/codegen/CodeGeneratorContext.scala | 4 +-
.../table/planner/codegen/ExpressionReducer.scala | 26 +-
.../planner/codegen/LongHashJoinGenerator.scala | 112 +-
.../planner/codegen/LookupJoinCodeGenerator.scala | 28 +-
.../planner/codegen/ProjectionCodeGenerator.scala | 17 +
.../codegen/agg/batch/AggCodeGenHelper.scala | 4 -
.../codegen/agg/batch/HashAggCodeGenerator.scala | 3 +-
.../codegen/agg/batch/SortAggCodeGenerator.scala | 3 +-
.../codegen/agg/batch/WindowCodeGenerator.scala | 3 +-
.../table/planner/delegation/BatchPlanner.scala | 11 +-
.../table/planner/delegation/PlannerBase.scala | 24 +-
.../table/planner/delegation/StreamPlanner.scala | 11 +-
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 6 +-
.../planner/plan/metadata/FlinkRelMdRowCount.scala | 19 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 40 +-
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 28 +-
.../table/planner/plan/nodes/calcite/Sink.scala | 2 +-
.../plan/nodes/logical/FlinkLogicalJoin.scala | 21 +-
.../plan/nodes/physical/FlinkPhysicalRel.scala | 16 +
...atchPhysicalDynamicFilteringDataCollector.scala | 13 +-
...chPhysicalDynamicFilteringTableSourceScan.scala | 3 +-
.../physical/batch/BatchPhysicalLookupJoin.scala | 4 +-
.../nodes/physical/common/CommonPhysicalJoin.scala | 11 +
.../physical/common/CommonPhysicalLookupJoin.scala | 168 +-
.../stream/StreamPhysicalCorrelateBase.scala | 6 +-
.../StreamPhysicalGlobalGroupAggregate.scala | 6 +-
.../StreamPhysicalGlobalWindowAggregate.scala | 16 +-
.../stream/StreamPhysicalGroupAggregate.scala | 6 +-
.../stream/StreamPhysicalGroupAggregateBase.scala | 6 +-
.../StreamPhysicalGroupTableAggregateBase.scala | 8 +-
.../StreamPhysicalGroupWindowAggregateBase.scala | 16 +-
.../StreamPhysicalIncrementalGroupAggregate.scala | 11 +-
.../nodes/physical/stream/StreamPhysicalJoin.scala | 23 +-
.../stream/StreamPhysicalLocalGroupAggregate.scala | 6 +-
.../StreamPhysicalLocalWindowAggregate.scala | 8 +-
.../physical/stream/StreamPhysicalLookupJoin.scala | 45 +-
.../stream/StreamPhysicalOverAggregate.scala | 2 +-
.../stream/StreamPhysicalOverAggregateBase.scala | 2 +-
.../StreamPhysicalPythonGroupAggregate.scala | 6 +-
.../nodes/physical/stream/StreamPhysicalRank.scala | 2 +-
.../nodes/physical/stream/StreamPhysicalSink.scala | 30 +-
.../stream/StreamPhysicalWindowAggregate.scala | 16 +-
.../stream/StreamPhysicalWindowAggregateBase.scala | 35 +
.../stream/StreamPhysicalWindowDeduplicate.scala | 4 +-
.../BatchCommonSubGraphBasedOptimizer.scala | 3 +-
.../optimize/CommonSubGraphBasedOptimizer.scala | 11 +-
.../StreamCommonSubGraphBasedOptimizer.scala | 3 +
.../program/FlinkRecomputeStatisticsProgram.java | 65 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 11 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 9 +-
.../rules/logical/FlinkSubQueryRemoveRule.scala | 13 +-
...ushPartitionIntoLegacyTableSourceScanRule.scala | 6 +-
.../logical/SplitPythonConditionFromJoinRule.scala | 1 +
.../TemporalJoinRewriteWithUniqueKeyRule.scala | 7 +-
.../physical/batch/BatchPhysicalHashJoinRule.scala | 111 +-
.../physical/batch/BatchPhysicalJoinRuleBase.scala | 258 +-
.../batch/BatchPhysicalNestedLoopJoinRule.scala | 53 +-
.../batch/BatchPhysicalOverAggregateRule.scala | 80 +-
.../batch/BatchPhysicalSingleRowJoinRule.scala | 23 +-
.../batch/BatchPhysicalSortMergeJoinRule.scala | 12 +-
.../physical/batch/BatchPhysicalSortRule.scala | 1 -
.../stream/StreamPhysicalLookupJoinRule.scala | 18 +-
.../planner/plan/utils/AggFunctionFactory.scala | 11 +
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 12 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 49 +
.../planner/plan/utils/RelTreeWriterImpl.scala | 54 +-
.../flink/table/planner/plan/utils/SortUtil.scala | 12 +
.../file/table/FileSystemStatisticsReportTest.java | 128 +-
.../source/DynamicFilteringValuesSource.java | 129 +
.../source/DynamicFilteringValuesSourceReader.java | 185 +
.../flink/connector/source/ValuesSource.java | 120 +
.../flink/connector/source/ValuesSourceReader.java | 147 +
.../DynamicFilteringValuesSourceEnumerator.java | 149 +
.../connector/source/enumerator/NoOpEnumState.java | 22 +
.../source/enumerator/NoOpEnumStateSerializer.java | 41 +
.../source/enumerator/ValuesSourceEnumerator.java | 81 +
.../source/split/ValuesSourcePartitionSplit.java | 48 +
.../ValuesSourcePartitionSplitSerializer.java | 76 +
.../connector/source/split/ValuesSourceSplit.java | 41 +
.../source/split/ValuesSourceSplitSerializer.java | 55 +
.../apache/flink/table/api/CompiledPlanITCase.java | 24 +
.../table/api/internal/CompiledPlanUtils.java | 4 +-
...rJoinHintWithInvalidPropagationShuttleTest.java | 148 +
...nHintWithInvalidPropagationShuttleTestBase.java | 128 +
...pJoinHintWithInvalidPropagationShuttleTest.java | 149 +
.../planner/catalog/CatalogStatisticsTest.java | 22 +-
.../codegen/LongAdaptiveHashJoinGeneratorTest.java | 133 +
.../planner/codegen/LongHashJoinGeneratorTest.java | 58 +-
.../factories/TestValuesRuntimeFunctions.java | 285 +-
.../planner/factories/TestValuesTableFactory.java | 326 +-
.../planner/functions/JsonFunctionsITCase.java | 15 +-
.../plan/batch/sql/DynamicFilteringTest.java | 190 +
.../plan/hints/batch/BroadcastJoinHintTest.java | 35 +
.../planner/plan/hints/batch/JoinHintTestBase.java | 904 +++
.../plan/hints/batch/NestLoopJoinHintTest.java | 35 +
.../plan/hints/batch/ShuffleHashJoinHintTest.java | 35 +
.../plan/hints/batch/ShuffleMergeJoinHintTest.java | 35 +
.../plan/nodes/exec/TestingBatchExecNode.java | 5 +
.../plan/nodes/exec/TransformationsTest.java | 162 +-
.../MultipleInputNodeCreationProcessorTest.java | 3 +-
.../utils/InputPriorityConflictResolverTest.java | 54 +
.../nodes/exec/serde/AsyncLookupOptionsTest.java | 138 +
.../nodes/exec/serde/LogicalTypeJsonSerdeTest.java | 6 +-
.../nodes/exec/serde/PartitionSpecSerdeTest.java | 13 +-
.../exec/serde/RankProcessStrategySerdeTest.java | 3 +-
.../plan/nodes/exec/serde/RankRangeSerdeTest.java | 3 +-
.../plan/nodes/exec/serde/RankTypeSerdeTest.java | 3 +-
.../nodes/exec/serde/RetryLookupOptionsTest.java | 80 +
.../plan/nodes/exec/serde/SortSpecSerdeTest.java | 12 +-
.../nodes/exec/spec/LookupJoinHintTestUtil.java | 67 +
.../nodes/exec/stream/LookupJoinJsonPlanTest.java | 88 +
.../nodes/exec/stream/TableSinkJsonPlanTest.java | 36 +
.../optimize/ClearQueryBlockAliasResolverTest.java | 104 +
.../plan/optimize/JoinHintResolverTest.java | 101 +
.../rules/logical/FlinkFilterJoinRuleTest.java | 313 +
.../logical/ProjectSnapshotTransposeRuleTest.java | 136 +
.../batch/DynamicPartitionPruningRuleTest.java | 351 +-
.../planner/plan/utils/UpsertKeyUtilTest.java | 52 +
.../runtime/batch/sql/AnalyzeTableITCase.java | 92 +
.../runtime/batch/sql/DynamicFilteringITCase.java | 289 +
.../planner/runtime/batch/sql/FunctionITCase.java | 48 +-
.../batch/sql/join/AdaptiveHashJoinITCase.java | 186 +
.../runtime/stream/sql/DataStreamJavaITCase.java | 94 +-
.../planner/runtime/stream/sql/FunctionITCase.java | 118 +-
.../utils/JavaUserDefinedScalarFunctions.java | 4 +
.../table/planner/typeutils/RowTypeUtilsTest.java | 46 +
.../planner/utils/InternalConfigOptionsTest.java | 3 +-
.../flink/table/planner/utils/JsonTestUtils.java | 24 +-
...ggAndAllConstantLookupKeyWithTryResolveMode.out | 106 +
...nstantLookupKeyWithTryResolveMode_newSource.out | 106 +
.../src/test/resources/json/json-value.json | 3 +-
...arJoinHintWithInvalidPropagationShuttleTest.xml | 150 +
...upJoinHintWithInvalidPropagationShuttleTest.xml | 127 +
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 17 +-
.../plan/batch/sql/DynamicFilteringTest.xml | 1413 +++++
.../plan/batch/sql/MultipleInputCreationTest.xml | 18 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 61 +-
.../table/planner/plan/batch/sql/UnnestTest.xml | 36 +
.../plan/batch/sql/agg/OverAggregateTest.xml | 29 +
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 297 +-
.../plan/batch/sql/join/JoinReorderTest.xml | 307 +-
.../planner/plan/batch/sql/join/LookupJoinTest.xml | 34 +-
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 319 +-
.../plan/batch/sql/join/ShuffledHashJoinTest.xml | 394 +-
.../plan/batch/sql/join/SortMergeJoinTest.xml | 268 +-
.../plan/hints/batch/BroadcastJoinHintTest.xml | 1694 ++++++
.../plan/hints/batch/NestLoopJoinHintTest.xml | 1690 ++++++
.../plan/hints/batch/ShuffleHashJoinHintTest.xml | 1732 ++++++
.../plan/hints/batch/ShuffleMergeJoinHintTest.xml | 1732 ++++++
.../nodes/exec/operator/BatchOperatorNameTest.xml | 246 +-
.../nodes/exec/operator/StreamOperatorNameTest.xml | 18 +-
.../testChangelogSource.out | 1 +
.../testUpsertSource.out | 1 +
.../testDeduplication.out | 1 +
.../ExpandJsonPlanTest_jsonplan/testExpand.out | 1 +
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 1 +
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 1 +
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 1 +
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 1 +
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 1 +
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 1 +
.../testEventTimeTumbleWindow.out | 1 +
.../testProcTimeTumbleWindow.out | 1 +
.../testIncrementalAggregate.out | 1 +
...lAggregateWithSumCountDistinctAndRetraction.out | 1 +
.../JoinJsonPlanTest_jsonplan/testInnerJoin.out | 2 -
.../testInnerJoinWithEqualPk.out | 5 +-
.../testInnerJoinWithPk.out | 4 +-
.../testLeftJoinNonEqui.out | 2 -
.../testAggAndLeftJoinWithTryResolveMode.out | 454 ++
.../testJoinTemporalTable.out | 5 +-
.../testJoinTemporalTableWithAsyncHint.out | 476 ++
.../testJoinTemporalTableWithAsyncHint2.out | 476 ++
.../testJoinTemporalTableWithAsyncRetryHint.out | 482 ++
.../testJoinTemporalTableWithAsyncRetryHint2.out | 482 ++
...testJoinTemporalTableWithProjectionPushDown.out | 24 +-
.../testJoinTemporalTableWithRetryHint.out | 482 ++
...WithNonDeterministicFuncSinkWithDifferentPk.out | 147 +
.../optimize/ClearQueryBlockAliasResolverTest.xml | 954 ++++
.../planner/plan/optimize/JoinHintResolverTest.xml | 954 ++++
.../rules/logical/ExpressionReductionRulesTest.xml | 17 +
.../plan/rules/logical/FlinkFilterJoinRuleTest.xml | 637 ++-
.../rules/logical/FlinkJoinToMultiJoinRuleTest.xml | 672 ++-
.../plan/rules/logical/JoinToMultiJoinRuleTest.xml | 56 +
.../plan/rules/logical/LogicalUnnestRuleTest.xml | 42 +
.../logical/ProjectSnapshotTransposeRuleTest.xml | 257 +
.../batch/DynamicPartitionPruningRuleTest.xml | 256 +-
.../plan/stream/sql/NonDeterministicDagTest.xml | 3105 ++++++++++
.../table/planner/plan/stream/sql/RankTest.xml | 8 +-
.../planner/plan/stream/sql/SubplanReuseTest.xml | 33 +-
.../table/planner/plan/stream/sql/UnnestTest.xml | 36 +
.../planner/plan/stream/sql/agg/AggregateTest.xml | 4 +-
.../plan/stream/sql/join/JoinReorderTest.xml | 291 +
.../planner/plan/stream/sql/join/JoinTest.xml | 368 +-
.../plan/stream/sql/join/LookupJoinTest.xml | 1488 ++++-
.../plan/stream/sql/join/TemporalJoinTest.xml | 8 +-
.../flink/table/api/TableEnvironmentTest.scala | 54 +-
.../expressions/NonDeterministicTests.scala | 9 +
.../planner/expressions/ScalarFunctionsTest.scala | 7 +-
.../planner/expressions/SqlExpressionTest.scala | 1 +
.../utils/userDefinedScalarFunctions.scala | 53 +-
.../plan/batch/sql/agg/OverAggregateTest.scala | 12 +
.../batch/sql/join/BroadcastHashJoinTest.scala | 1 -
.../planner/plan/batch/sql/join/JoinTestBase.scala | 66 +
.../plan/batch/sql/join/ShuffledHashJoinTest.scala | 12 +-
.../planner/plan/common/JoinReorderTestBase.scala | 88 +-
.../table/planner/plan/common/UnnestTestBase.scala | 17 +
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 16 +-
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 15 +
.../plan/metadata/FlinkRelMdUpsertKeysTest.scala | 14 +
.../logical/ExpressionReductionRulesTest.scala | 6 +
.../rules/logical/FlinkFilterJoinRuleTest.scala | 158 -
.../logical/FlinkJoinToMultiJoinRuleTest.scala | 211 +-
.../rules/logical/subquery/SubQueryTestBase.scala | 4 +-
.../plan/stream/sql/NonDeterministicDagTest.scala | 1622 ++++++
.../planner/plan/stream/sql/TableSinkTest.scala | 4 +-
.../planner/plan/stream/sql/join/JoinTest.scala | 73 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 434 +-
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 50 +-
.../runtime/batch/sql/OverAggregateITCase.scala | 48 +
.../runtime/batch/sql/TableSinkITCase.scala | 16 +
.../runtime/batch/sql/join/JoinITCase.scala | 351 ++
.../runtime/batch/sql/join/LookupJoinITCase.scala | 131 +-
.../runtime/harness/OverAggregateHarnessTest.scala | 7 +-
.../runtime/stream/sql/AsyncLookupJoinITCase.scala | 278 +-
.../planner/runtime/stream/sql/JoinITCase.scala | 179 +
.../runtime/stream/sql/LookupJoinITCase.scala | 309 +-
.../runtime/stream/sql/TableSinkITCase.scala | 79 +
.../planner/runtime/stream/sql/UnnestITCase.scala | 31 +
.../table/planner/runtime/utils/TestData.scala | 16 +
.../flink/table/planner/utils/TableTestBase.scala | 83 +-
flink-table/flink-table-runtime/pom.xml | 2 +-
.../runtime/collector/ListenableCollector.java | 48 +
.../table/runtime/functions/JsonPathCache.java | 43 +
.../table/runtime/functions/SqlJsonUtils.java | 5 +
.../table/lookup/CachingAsyncLookupFunction.java | 134 +
.../table/lookup/CachingLookupFunction.java | 185 +
.../functions/table/lookup/LookupCacheManager.java | 174 +
.../table/lookup/fullcache/CacheLoader.java | 142 +
.../table/lookup/fullcache/LookupFullCache.java | 115 +
.../lookup/fullcache/ReloadTriggerContext.java | 59 +
.../inputformat/InputFormatCacheLoader.java | 161 +
.../inputformat/InputSplitCacheLoadTask.java | 128 +
.../runtime/hashtable/BaseHybridHashTable.java | 40 +-
.../runtime/hashtable/BinaryHashBucketArea.java | 2 +-
.../runtime/hashtable/BinaryHashPartition.java | 12 +-
.../table/runtime/hashtable/BinaryHashTable.java | 122 +-
.../table/runtime/hashtable/LongHashPartition.java | 4 +-
.../runtime/hashtable/LongHybridHashTable.java | 123 +-
.../io/BinaryRowChannelInputViewIterator.java | 6 +-
...ashPartitionChannelReaderInputViewIterator.java | 56 +
.../keyselector/GenericRowDataKeySelector.java | 69 +
.../DynamicFilteringDataCollectorOperator.java | 178 +
...cFilteringDataCollectorOperatorCoordinator.java | 180 +
...namicFilteringDataCollectorOperatorFactory.java | 100 +
.../ExecutionOrderEnforcerOperator.java | 71 +
.../ExecutionOrderEnforcerOperatorFactory.java | 47 +
.../runtime/operators/join/HashJoinOperator.java | 115 +-
.../operators/join/SortMergeJoinFunction.java | 560 ++
.../operators/join/SortMergeJoinOperator.java | 501 +-
.../join/lookup/KeyedLookupJoinWrapper.java | 235 +
.../operators/join/lookup/LookupJoinRunner.java | 29 +-
.../join/lookup/LookupJoinWithCalcRunner.java | 4 +-
.../operators/join/lookup/ResultRetryStrategy.java | 71 +
.../RetryableAsyncLookupFunctionDelegator.java | 102 +
.../lookup/RetryableLookupFunctionDelegator.java | 83 +
.../over/ProcTimeUnboundedPrecedingFunction.java | 34 +-
.../operators/over/frame/InsensitiveOverFrame.java | 2 +-
.../operators/sink/SinkUpsertMaterializer.java | 125 +-
.../runtime/partitioner/BinaryHashPartitioner.java | 20 +
.../src/main/resources/META-INF/NOTICE | 2 +-
.../table/CachingAsyncLookupFunctionTest.java | 129 +
.../functions/table/CachingLookupFunctionTest.java | 103 +
.../table/fullcache/LookupFullCacheTest.java | 226 +
.../functions/table/fullcache/TestCacheLoader.java | 78 +
.../fullcache/TestManualCacheReloadTrigger.java | 49 +
.../inputformat/FullCacheTestInputFormat.java | 187 +
.../inputformat/InputFormatCacheLoaderTest.java | 230 +
.../runtime/hashtable/BinaryHashTableTest.java | 61 +-
.../table/runtime/hashtable/LongHashTableTest.java | 61 +-
...teringDataCollectorOperatorCoordinatorTest.java | 113 +
.../DynamicFilteringDataCollectorOperatorTest.java | 123 +
.../dynamicfiltering/DynamicFilteringDataTest.java | 138 +
.../join/Int2AdaptiveHashJoinOperatorTest.java | 450 ++
.../operators/join/Int2HashJoinOperatorTest.java | 287 +-
.../join/Int2HashJoinOperatorTestBase.java | 387 ++
.../join/Int2SortMergeJoinOperatorTest.java | 8 +-
.../operators/join/KeyedLookupJoinHarnessTest.java | 498 ++
.../operators/join/LookupJoinHarnessTest.java | 9 +-
.../RetryableAsyncLookupFunctionDelegatorTest.java | 168 +
.../join/RetryableLookupFunctionDelegatorTest.java | 103 +
.../operators/join/SortMergeJoinIteratorTest.java | 2 +-
.../join/String2HashJoinOperatorTest.java | 98 +-
.../join/String2SortMergeJoinOperatorTest.java | 108 +-
.../ProcTimeUnboundedPrecedingFunctionTest.java | 117 +
.../operators/sink/SinkUpsertMaterializerTest.java | 102 +-
.../apache/flink/table/runtime/util/JoinUtil.java | 43 +
.../runtime/util/UniformBinaryRowGenerator.java | 2 +-
flink-table/flink-table-test-utils/pom.xml | 2 +-
flink-table/pom.xml | 2 +-
.../flink-connector-test-utils/pom.xml | 2 +-
.../testframe/container/FlinkContainers.java | 5 +
.../testframe/testsuites/SourceTestSuiteBase.java | 43 +-
.../testframe/utils/CollectIteratorAssertions.java | 11 +-
.../utils/UnorderedCollectIteratorAssert.java | 140 +
.../testutils/formats/SchemaTestUtils.java | 53 +
.../flink-test-utils-junit/pom.xml | 2 +-
.../org/apache/flink/util/DockerImageVersions.java | 6 -
.../org/apache/flink/util/TestLoggerExtension.java | 13 +-
flink-test-utils-parent/flink-test-utils/pom.xml | 2 +-
.../connector/upserttest/sink/UpsertTestSink.java | 8 +
.../upserttest/sink/UpsertTestSinkWriter.java | 6 +
.../apache/flink/packaging/PackagingTestUtils.java | 104 +
.../streaming/util/TestStreamEnvironment.java | 3 +-
.../flink/test/resources/ResourceTestUtils.java | 84 +
.../MiniClusterPipelineExecutorServiceLoader.java | 23 +-
.../apache/flink/test/util/SQLJobSubmission.java | 27 +-
.../java/org/apache/flink/types/PojoTestUtils.java | 36 +
.../flink/packaging/PackagingTestUtilsTest.java | 134 +
.../org/apache/flink/types/PojoTestUtilsTest.java | 25 +
flink-test-utils-parent/pom.xml | 2 +-
flink-tests/pom.xml | 2 +-
.../sink/UpsertTestSinkWriterITCase.java | 3 +-
.../OperatorEventSendingCheckpointITCase.java | 34 +-
.../validation/TestJobDataFlowValidator.java | 34 +-
.../ChangelogLocalRecoveryITCase.java | 15 +-
.../ChangelogPeriodicMaterializationITCase.java | 217 -
...ngelogPeriodicMaterializationRescaleITCase.java | 56 -
...ogPeriodicMaterializationSwitchEnvTestBase.java | 145 -
...dicMaterializationSwitchStateBackendITCase.java | 171 -
.../ChangelogPeriodicMaterializationTestBase.java | 441 --
.../checkpointing/ChangelogRecoveryITCase.java | 216 +
.../checkpointing/ChangelogRecoveryITCaseBase.java | 447 ++
.../ChangelogRecoveryRescaleITCase.java | 54 +
.../ChangelogRecoverySwitchEnvTestBase.java | 155 +
.../ChangelogRecoverySwitchStateBackendITCase.java | 181 +
.../CheckpointFailureManagerITCase.java | 79 +-
.../RescaleCheckpointManuallyITCase.java | 180 +-
.../ResumeCheckpointManuallyITCase.java | 91 +-
.../test/checkpointing/SavepointFormatITCase.java | 9 +-
.../jsonplan/JsonJobGraphGenerationTest.java | 6 +-
.../flink/test/runtime/BatchShuffleITCaseBase.java | 196 +
.../flink/test/runtime/BlockingShuffleITCase.java | 156 +-
.../flink/test/runtime/HybridShuffleITCase.java | 72 +
.../PipelinedRegionSchedulingITCase.java | 2 +-
.../test/state/ChangelogRecoveryCachingITCase.java | 253 +
.../state/SavepointStateBackendSwitchTestBase.java | 17 +-
.../flink/test/streaming/runtime/CacheITCase.java | 289 +
.../test/streaming/runtime/IntervalJoinITCase.java | 125 +
.../flink-walkthrough-common/pom.xml | 2 +-
.../flink-walkthrough-datastream-java/pom.xml | 2 +-
.../flink-walkthrough-datastream-scala/pom.xml | 2 +-
flink-walkthroughs/pom.xml | 2 +-
flink-yarn-tests/pom.xml | 20 +-
flink-yarn/pom.xml | 2 +-
pom.xml | 38 +-
tools/azure-pipelines/build_properties.sh | 18 +
tools/azure-pipelines/cache_docker_images.sh | 2 +-
tools/ci/compile.sh | 4 -
tools/ci/flink-ci-tools/pom.xml | 72 +
.../tools/ci/licensecheck/JarFileChecker.java | 0
.../tools/ci/licensecheck/LicenseChecker.java | 0
.../tools/ci/licensecheck/NoticeFileChecker.java | 379 ++
.../tools/ci/suffixcheck/ScalaSuffixChecker.java | 0
.../ci/utils/dependency/DependencyParser.java | 0
.../flink/tools/ci/utils/shared/Dependency.java | 0
.../src/main/resources/log4j2.properties | 0
...modules-defining-excess-dependencies.modulelist | 0
.../tools/ci/licensecheck/JarFileCheckerTest.java | 0
.../utils/dependency/DependencyParserCopyTest.java | 0
.../utils/dependency/DependencyParserTreeTest.java | 0
.../org.junit.jupiter.api.extension.Extension | 0
tools/ci/java-ci-tools/pom.xml | 81 -
.../tools/ci/licensecheck/NoticeFileChecker.java | 330 --
.../modules-skipping-deployment.modulelist | 43 -
tools/ci/license_check.sh | 2 +-
tools/ci/shade.sh | 26 -
tools/ci/stage.sh | 5 -
tools/ci/verify_scala_suffixes.sh | 2 +-
tools/releasing/NOTICE-binary_PREAMBLE.txt | 2 +-
tools/releasing/create_snapshot_branch.sh | 2 +-
tools/releasing/update_japicmp_configuration.sh | 11 +
2395 files changed, 131662 insertions(+), 54239 deletions(-)
delete mode 100644 docs/content.zh/docs/connectors/table/hive/hive_dialect.md
create mode 100644 docs/content.zh/docs/deployment/speculative_execution.md
create mode 100644 docs/content.zh/docs/dev/table/concepts/determinism.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/_index.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/_index.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/add.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/alter.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/create.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/drop.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/insert.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/load-data.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/overview.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/_index.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/cte.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/group-by.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/join.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/lateral-view.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/overview.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/set-op.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/sort-cluster-distribute-by.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/sub-queries.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/table-sample.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/transform.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/queries/window-functions.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/set.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hive-dialect/show.md
create mode 100644 docs/content.zh/docs/dev/table/hive-compatibility/hiveserver2.md
create mode 100644 docs/content.zh/docs/dev/table/sql-gateway/_index.md
create mode 100644 docs/content.zh/docs/dev/table/sql-gateway/hiveserver2.md
create mode 100644 docs/content.zh/docs/dev/table/sql-gateway/overview.md
create mode 100644 docs/content.zh/docs/dev/table/sql-gateway/rest.md
create mode 100644 docs/content.zh/docs/dev/table/sql/analyze.md
copy docs/{content => content.zh}/release-notes/flink-1.15.md (100%)
delete mode 100644 docs/content/docs/connectors/table/hive/hive_dialect.md
create mode 100644 docs/content/docs/deployment/speculative_execution.md
create mode 100644 docs/content/docs/dev/table/concepts/determinism.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/_index.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/_index.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/add.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/alter.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/create.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/drop.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/insert.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/load-data.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/overview.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/_index.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/cte.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/group-by.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/join.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/lateral-view.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/overview.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/set-op.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/sort-cluster-distribute-by.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/sub-queries.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/table-sample.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/transform.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/queries/window-functions.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/set.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hive-dialect/show.md
create mode 100644 docs/content/docs/dev/table/hive-compatibility/hiveserver2.md
create mode 100644 docs/content/docs/dev/table/sql-gateway/_index.md
create mode 100644 docs/content/docs/dev/table/sql-gateway/hiveserver2.md
create mode 100644 docs/content/docs/dev/table/sql-gateway/overview.md
create mode 100644 docs/content/docs/dev/table/sql-gateway/rest.md
create mode 100644 docs/content/docs/dev/table/sql/analyze.md
create mode 100644 docs/layouts/shortcodes/check.html
create mode 100644 docs/layouts/shortcodes/generated/rest_v1_sql_gateway.html
create mode 100644 docs/layouts/shortcodes/generated/sql_gateway_rest_configuration.html
create mode 100644 docs/layouts/shortcodes/xmark.html
create mode 100644 docs/static/fig/apache_superset.png
create mode 100644 docs/static/fig/dbeaver.png
create mode 100644 docs/static/fig/hint/hint_query_block_union.png
create mode 100644 docs/static/fig/hint/hint_query_block_view.png
create mode 100644 docs/static/fig/hint/hint_query_block_where.png
create mode 100644 docs/static/fig/sql-gateway-architecture.png
create mode 100644 docs/static/fig/sql-gateway-interactions.png
create mode 100644 docs/static/generated/rest_v1_sql_gateway.yml
delete mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AIMDRateLimitingStrategy.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/config/AsyncSinkWriterConfiguration.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/AIMDScalingStrategy.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/BasicRequestInfo.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/BasicResultInfo.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/CongestionControlRateLimitingStrategy.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/NoOpScalingStrategy.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RateLimitingStrategy.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RequestInfo.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/ResultInfo.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/ScalingStrategy.java
create mode 100644 flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java
delete mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AIMDRateLimitingStrategyTest.java
create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/strategy/AIMDScalingStrategyTest.java
create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/strategy/CongestionControlRateLimitingStrategyTest.java
create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/strategy/NoOpScalingStrategyTest.java
create mode 100644 flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherPauseResumeSplitReaderTest.java
rename {tools/ci/java-ci-tools => flink-connectors/flink-connector-cassandra}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension (100%)
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/archunit-violations/dd583797-83e1-414c-a38d-330773978813
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/pom.xml
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorBuilderFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkRequestConsumerFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/FlushBackoffType.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/MapElasticsearchEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/NetworkClientConfig.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/RequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/AbstractTimeIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConfiguration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkFactoryBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchSinkBuilderSupplier.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchValidationUtils.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/KeyExtractor.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/LogicalTypeWithIndex.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/RowElasticsearchEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/StaticIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BufferingNoOpRequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/AbstractTimeIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchValidationUtils.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RequestFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/StaticIndexGenerator.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/IgnoringFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/ElasticsearchUtil.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilderBaseTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriterITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestClientBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestEmitter.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkBaseITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSinkFactoryBaseTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/KeyExtractorTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/table/TestContext.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBaseTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkTestBase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/EmbeddedElasticsearchNodeEnvironment.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/TestRequestIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractorTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/TestContext.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/testutils/ElasticsearchResource.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/testutils/SourceSinkDataTestKit.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch-base/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/archunit-violations/25e52d29-fa7e-42fa-a571-b5c76235df52
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/archunit-violations/db3972e4-f3a3-45b2-9643-27cba0cef09d
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/pom.xml
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkBuilder.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6Configuration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6ConnectorOptions.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/RestClientFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkBuilderTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6SinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch6TestClient.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch6/src/test/resources/log4j2-test.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/archunit-violations/1af7baaa-05dc-452a-9de7-653c8b3b324f
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/archunit-violations/e1f30f33-c61c-4707-8c78-a3a80479564e
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/archunit-violations/stored.rules
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/pom.xml
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkBuilder.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/RestClientFactory.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkBuilderTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7SinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch7TestClient.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactoryTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkTest.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSinkITCase.java
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/resources/archunit.properties
delete mode 100644 flink-connectors/flink-connector-elasticsearch7/src/test/resources/log4j2-test.properties
create mode 100644 flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/enumerate/DynamicFileEnumerator.java
create mode 100644 flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/DynamicFileSplitEnumerator.java
create mode 100644 flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/PartitionCommitPolicyFactory.java
create mode 100644 flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/impl/DynamicFileSplitEnumeratorTest.java
delete mode 100644 flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/options/HBaseLookupOptions.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/DynamicHiveSplitEnumerator.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumerator.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/udf/generic/HiveGenericUDFToDecimal.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveSessionState.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveShowTableUtils.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/operations/HiveLoadDataOperation.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/operations/HiveShowCreateTableOperation.java
create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/parse/HiveParserLoadSemanticAnalyzer.java
create mode 100644 flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDynamicPartitionPruningITCase.java
create mode 100644 flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumeratorTest.java
create mode 100644 flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceFileEnumeratorTest.java
create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/explain/testDynamicPartitionSortDisabled.out
create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/explain/testDynamicPartitionSortEnabled.out
create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/explain/testLoadData.out
create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/orc/test.orc
create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/query-test/udf.q
rename flink-connectors/{flink-connector-elasticsearch-base/archunit-violations/de342dd1-c974-42c9-8f64-ef182ba8c56d => flink-connector-jdbc/archunit-violations/0f94f11b-9bc8-445a-8be8-e7dfd8a384b0} (100%)
delete mode 100644 flink-connectors/flink-connector-jdbc/archunit-violations/e3f99de4-2505-469a-8910-ce53aec7cd1d
create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerDialect.java
create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerDialectFactory.java
create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/SqlServerRowConverter.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcLookupOptions.java
create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlDialectTest.java
create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerPreparedStatementTest.java
create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerTableSinkITCase.java
create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerTableSourceITCase.java
delete mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverterTest.java
delete mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/SplitsAssignmentState.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/NonSharedSplitAssigner.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SharedSplitAssigner.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssigner.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssignerBase.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssignerFactory.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/MessageIdUtils.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarUnorderedSourceITCase.java
delete mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/SplitsAssignmentStateTest.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/NonSharedSplitAssignerTest.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SharedSplitAssignerTest.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssignerTestBase.java
create mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/cases/SharedSubscriptionConsumingContext.java
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch6/pom.xml
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch6/src/main/resources/META-INF/NOTICE
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch7/pom.xml
delete mode 100644 flink-connectors/flink-sql-connector-elasticsearch7/src/main/resources/META-INF/NOTICE
create mode 100644 flink-connectors/flink-sql-connector-kafka/src/test/java/org/apache/flink/connectors/kafka/PackagingITCase.java
create mode 100644 flink-connectors/flink-sql-connector-kinesis/src/test/java/org/apache/flink/connectors/kinesis/PackagingITCase.java
create mode 100644 flink-core/src/main/java/org/apache/flink/core/execution/CacheSupportedPipelineExecutor.java
create mode 100644 flink-core/src/main/java/org/apache/flink/util/jackson/JacksonMapperFactory.java
create mode 100644 flink-core/src/test/java/org/apache/flink/util/jackson/JacksonMapperFactoryTest.java
delete mode 100644 flink-docs/src/main/java/org/apache/flink/docs/configuration/OptionsClassLocation.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/rest/RuntimeOpenApiSpecGenerator.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/rest/RuntimeRestAPIDocGenerator.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/rest/SqlGatewayOpenApiSpecGenerator.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/rest/SqlGatewayRestAPIDocGenerator.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/util/ConfigurationOptionLocator.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/util/OptionWithMetaInfo.java
create mode 100644 flink-docs/src/main/java/org/apache/flink/docs/util/OptionsClassLocation.java
create mode 100644 flink-docs/src/test/java/org/apache/flink/docs/configuration/ConfigOptionsYamlSpecTest.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/AbstractStateChangeFsUploader.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReader.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamHandleReaderWithCache.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/ChangelogStreamWrapper.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/DuplicatingOutputStreamWithPos.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/DuplicatingStateChangeFsUploader.java
create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeIteratorImpl.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchClient.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchDataReader.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkE2ECaseBase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkExternalContextBase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchSinkExternalContextFactoryBase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchTestEmitter.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/KeyValue.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/QueryParams.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/UpdateRequestFactory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/main/java/org/apache/flink/streaming/tests/Elasticsearch6Client.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/main/java/org/apache/flink/streaming/tests/UpdateRequest6Factory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkE2ECase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkExternalContext.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/java/org/apache/flink/streaming/tests/Elasticsearch6SinkExternalContextFactory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch6/src/test/resources/log4j2-test.properties
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/pom.xml
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/main/java/org/apache/flink/streaming/tests/Elasticsearch7Client.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/main/java/org/apache/flink/streaming/tests/UpdateRequest7Factory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkE2ECase.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkExternalContext.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/java/org/apache/flink/streaming/tests/Elasticsearch7SinkExternalContextFactory.java
delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-elasticsearch7/src/test/resources/log4j2-test.properties
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CreateTableAsITCase.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/SqlITCaseBase.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/UsingRemoteJarITCase.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/resources/create_function_using_remote_jar_e2e.sql
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/resources/create_table_as_e2e.sql
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/resources/create_table_as_statementset_e2e.sql
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/resources/remote_jar_e2e.sql
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/resources/scalar_udf_e2e.sql
create mode 100644 flink-end-to-end-tests/flink-quickstart-test-dummy-dependency/pom.xml
create mode 100644 flink-end-to-end-tests/flink-quickstart-test-dummy-dependency/src/main/java/org/apache/flink/quickstarts/test/utils/Utils.java
delete mode 100644 flink-end-to-end-tests/flink-quickstart-test/src/main/java/org/apache/flink/quickstarts/test/Elasticsearch7SinkExample.java
create mode 100644 flink-end-to-end-tests/flink-quickstart-test/src/main/java/org/apache/flink/quickstarts/test/QuickstartExample.java
delete mode 100644 flink-end-to-end-tests/flink-quickstart-test/src/main/scala/org/apache/flink/quickstarts/test/Elasticsearch7SinkExample.scala
create mode 100644 flink-end-to-end-tests/flink-quickstart-test/src/main/scala/org/apache/flink/quickstarts/test/QuickstartExample.scala
create mode 100644 flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
create mode 100644 flink-end-to-end-tests/flink-sql-client-test/src/test/resources/log4j2-test.properties
delete mode 100644 flink-end-to-end-tests/test-scripts/elasticsearch-common.sh
delete mode 100755 flink-end-to-end-tests/test-scripts/test_sql_client.sh
create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/TemporalJoinSQLExample.java
create mode 100644 flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/java/basics/TemporalJoinSQLExampleITCase.java
create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ArrayColumnReader.java
create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/BaseVectorizedColumnReader.java
create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/MapColumnReader.java
create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ParquetDataColumnReader.java
create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ParquetDataColumnReaderFactory.java
create mode 100644 flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/RowColumnReader.java
delete mode 100644 flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/ParquetWriterUtil.java
create mode 100644 flink-formats/flink-sql-avro/src/test/java/org/apache/flink/formats/avro/PackagingITCase.java
copy {flink-clients => flink-java}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension (100%)
create mode 100644 flink-kubernetes/src/test/resources/testing-nospec-pod-template.yaml
create mode 100644 flink-python/pyflink/common/io.py
create mode 100644 flink-python/pyflink/common/utils.py
create mode 100644 flink-python/pyflink/datastream/connectors/hybrid_source.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_cassandra.py
delete mode 100644 flink-python/pyflink/datastream/connectors/tests/test_connectors.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_elasticsearch.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_jdbc.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_kinesis.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_pulsar.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_rabbitmq.py
create mode 100644 flink-python/pyflink/datastream/connectors/tests/test_seq_source.py
create mode 100644 flink-python/pyflink/datastream/formats/json.py
create mode 100644 flink-python/pyflink/datastream/formats/orc.py
rename flink-python/pyflink/{metrics => datastream/formats}/tests/__init__.py (100%)
create mode 100644 flink-python/pyflink/datastream/formats/tests/test_avro.py
create mode 100644 flink-python/pyflink/datastream/formats/tests/test_csv.py
create mode 100644 flink-python/pyflink/datastream/formats/tests/test_json.py
create mode 100644 flink-python/pyflink/datastream/formats/tests/test_orc.py
create mode 100644 flink-python/pyflink/datastream/formats/tests/test_parquet.py
create mode 100644 flink-python/pyflink/fn_execution/datastream/embedded/side_output_context.py
create mode 100644 flink-python/pyflink/fn_execution/embedded/state_impl.py
copy {flink-end-to-end-tests/flink-python-test/python/datastream => flink-python/pyflink/fn_execution/metrics}/__init__.py (100%)
copy {flink-end-to-end-tests/flink-python-test/python/datastream => flink-python/pyflink/fn_execution/metrics/embedded}/__init__.py (100%)
create mode 100644 flink-python/pyflink/fn_execution/metrics/embedded/counter_impl.py
create mode 100644 flink-python/pyflink/fn_execution/metrics/embedded/distribution_impl.py
create mode 100644 flink-python/pyflink/fn_execution/metrics/embedded/meter_impl.py
create mode 100644 flink-python/pyflink/fn_execution/metrics/embedded/metric_impl.py
copy {flink-end-to-end-tests/flink-python-test/python/datastream => flink-python/pyflink/fn_execution/metrics/process}/__init__.py (100%)
create mode 100644 flink-python/pyflink/fn_execution/metrics/process/counter_impl.py
create mode 100644 flink-python/pyflink/fn_execution/metrics/process/distribution_impl.py
create mode 100644 flink-python/pyflink/fn_execution/metrics/process/meter_impl.py
create mode 100644 flink-python/pyflink/fn_execution/metrics/process/metric_impl.py
copy {flink-end-to-end-tests/flink-python-test/python/datastream => flink-python/pyflink/fn_execution/metrics/tests}/__init__.py (100%)
create mode 100644 flink-python/pyflink/fn_execution/metrics/tests/test_metric.py
delete mode 100644 flink-python/pyflink/metrics/tests/test_metric.py
delete mode 100644 flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java
create mode 100644 flink-python/src/main/java/org/apache/flink/python/metric/embedded/MetricDistribution.java
create mode 100644 flink-python/src/main/java/org/apache/flink/python/metric/embedded/MetricGauge.java
create mode 100644 flink-python/src/main/java/org/apache/flink/python/metric/process/FlinkMetricContainer.java
create mode 100644 flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/EmbeddedPythonBatchCoBroadcastProcessOperator.java
create mode 100644 flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/EmbeddedPythonBatchKeyedCoBroadcastProcessOperator.java
create mode 100644 flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/EmbeddedPythonWindowOperator.java
delete mode 100644 flink-python/src/main/resources/META-INF/licenses/LICENSE.bouncycastle
delete mode 100644 flink-python/src/main/resources/META-INF/licenses/LICENSE.jzlib
delete mode 100644 flink-python/src/test/java/org/apache/flink/python/metric/FlinkMetricContainerTest.java
create mode 100644 flink-python/src/test/java/org/apache/flink/python/metric/process/FlinkMetricContainerTest.java
create mode 100644 flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcGatewayUtils.java
delete mode 100644 flink-runtime-web/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutines.java
delete mode 100644 flink-runtime-web/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTest.java
create mode 100644 flink-runtime-web/src/test/java/org/apache/flink/runtime/rest/compatibility/RuntimeRestAPIStabilityTest.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/CompositeBuffer.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsOutputMetrics.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/AcknowledgeCheckpointEvent.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/EventSender.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorEventValve.java
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/CachedIntermediateDataSetCorruptedException.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ClusterDatasetCorruptedException.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistry.java
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistryImpl.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/BlockingResultPartitionReleaseTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreFileOperationsTest.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreTestInternal.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/OperatorEventValveTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImplTest.java
rename {flink-runtime-web => flink-runtime}/src/test/java/org/apache/flink/runtime/rest/compatibility/Compatibility.java (100%)
rename {flink-runtime-web => flink-runtime}/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityCheckResult.java (100%)
rename {flink-runtime-web => flink-runtime}/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java (100%)
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutines.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTestUtils.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistryTest.java
delete mode 100644 flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMaterializationMetricGroup.java
delete mode 100644 flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java
create mode 100644 flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendMigrationTest.java
create mode 100644 flink-state-backends/flink-statebackend-common/pom.xml
create mode 100644 flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/ChangelogMaterializationMetricGroup.java
create mode 100644 flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java
create mode 100644 flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java
delete mode 100644 flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksFullSnapshotStrategy.java
create mode 100644 flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksNativeFullSnapshotStrategy.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CachedDataStream.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SideOutputDataStream.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSink.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/NonChainedOutput.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/CacheTransformation.java
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/CacheTransformationTranslator.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkTest.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorSplitWatermarkAlignmentTest.java
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.java
create mode 100644 flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/CachedDataStream.scala
delete mode 100644 flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/operation/OperationType.java
create mode 100644 flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/FunctionInfo.java
create mode 100644 flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/GatewayInfo.java
create mode 100644 flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/TableInfo.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointFactory.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/AbstractOperationHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/CancelOperationHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/CloseOperationHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/GetOperationStatusHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/statement/ExecuteStatementHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/statement/FetchResultsHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/util/GetApiVersionHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/util/GetInfoHandler.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/AbstactOperationHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/CancelOperationHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/CloseOperationHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/GetOperationStatusHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/statement/ExecuteStatementHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/statement/FetchResultsHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/GetApiVersionHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/GetInfoHeaders.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/operation/OperationHandleIdPathParameter.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/operation/OperationMessageParameters.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/operation/OperationStatusResponseBody.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/ExecuteStatementRequestBody.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/ExecuteStatementResponseBody.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsResponseBody.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsTokenParameters.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsTokenPathParameter.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/util/GetApiVersionResponseBody.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/util/GetInfoResponseBody.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/ColumnInfo.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/JsonResultSetDeserializer.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/JsonResultSetSerializer.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/LogicalTypeJsonDeserializer.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/LogicalTypeJsonSerializer.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/serde/RowDataInfo.java
delete mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestEndpointFactory.java
delete mode 100644 flink-table/flink-sql-gateway/src/main/resources/META-INF.services/org.apache.flink.table.factories.Factory
create mode 100644 flink-table/flink-sql-gateway/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/OperationCaseITTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointStatementITCase.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/UtilCaseITTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/compatibility/SqlGatewayRestAPIStabilityTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/serde/JsonResultSetSerDeTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/serde/LogicalTypeJsonSerDeTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/util/DocumentingSqlGatewayRestEndpoint.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestEndpointExtension.java
delete mode 100644 flink-table/flink-sql-gateway/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 flink-table/flink-sql-gateway/src/test/resources/sql_gateway_rest_api_v1.snapshot
create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/CreateTableASOperation.java
delete mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/CreateTableASOperation.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringData.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/DynamicFilteringEvent.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/columnar/vector/heap/HeapArrayVector.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/columnar/vector/heap/HeapMapVector.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/columnar/vector/heap/HeapRowVector.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/lookup/cache/InterceptingCacheMetricGroup.java
create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/test/lookup/cache/LookupCacheAssert.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Correlate.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Filter.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Intersect.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Minus.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/SetOp.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Sort.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Union.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Values.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/core/Window.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/hint/HintPredicates.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/hint/NodeTypeHintPredicate.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalCorrelate.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalFilter.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalIntersect.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalMinus.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalSort.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalUnion.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalValues.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalWindow.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/alias/ClearJoinHintWithInvalidPropagationShuttle.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/NTILEAggFunction.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/JoinStrategy.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/LookupJoinHintOptions.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecDynamicFilteringDataCollector.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/DynamicFilteringDependencyProcessor.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/ResetTransformationProcessor.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolver.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/JoinHintResolver.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/StreamNonDeterministicPhysicalPlanResolver.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/StreamNonDeterministicUpdatePlanVisitor.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinToMultiJoinRule.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/ProjectSnapshotTransposeRule.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/SorMergeJoinOperatorUtil.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/UpsertKeyUtil.java
create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java
create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalWindowAggregateBase.scala
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/DynamicFilteringValuesSource.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/DynamicFilteringValuesSourceReader.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/ValuesSource.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/ValuesSourceReader.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/enumerator/DynamicFilteringValuesSourceEnumerator.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/enumerator/NoOpEnumState.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/enumerator/NoOpEnumStateSerializer.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/enumerator/ValuesSourceEnumerator.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/split/ValuesSourcePartitionSplit.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/split/ValuesSourcePartitionSplitSerializer.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/split/ValuesSourceSplit.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/source/split/ValuesSourceSplitSerializer.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/alias/ClearJoinHintWithInvalidPropagationShuttleTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/alias/ClearJoinHintWithInvalidPropagationShuttleTestBase.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/alias/ClearLookupJoinHintWithInvalidPropagationShuttleTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/codegen/LongAdaptiveHashJoinGeneratorTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/DynamicFilteringTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/batch/BroadcastJoinHintTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/batch/JoinHintTestBase.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/batch/NestLoopJoinHintTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/batch/ShuffleHashJoinHintTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/batch/ShuffleMergeJoinHintTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/AsyncLookupOptionsTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RetryLookupOptionsTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/spec/LookupJoinHintTestUtil.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolverTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/JoinHintResolverTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRuleTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/ProjectSnapshotTransposeRuleTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/utils/UpsertKeyUtilTest.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/DynamicFilteringITCase.java
create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/join/AdaptiveHashJoinITCase.java
create mode 100644 flink-table/flink-table-planner/src/test/resources/explain/stream/join/lookup/testAggAndAllConstantLookupKeyWithTryResolveMode.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/explain/stream/join/lookup/testAggAndAllConstantLookupKeyWithTryResolveMode_newSource.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/alias/ClearJoinHintWithInvalidPropagationShuttleTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/alias/ClearLookupJoinHintWithInvalidPropagationShuttleTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/DynamicFilteringTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/BroadcastJoinHintTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/NestLoopJoinHintTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/ShuffleHashJoinHintTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/ShuffleMergeJoinHintTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testAggAndLeftJoinWithTryResolveMode.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncHint.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncHint2.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncRetryHint.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithAsyncRetryHint2.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithRetryHint.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/TableSinkJsonPlanTest_jsonplan/testCdcWithNonDeterministicFuncSinkWithDifferentPk.out
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolverTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/optimize/JoinHintResolverTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/JoinToMultiJoinRuleTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/ProjectSnapshotTransposeRuleTest.xml
create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/NonDeterministicDagTest.xml
delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRuleTest.scala
create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/NonDeterministicDagTest.scala
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/collector/ListenableCollector.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/JsonPathCache.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/CachingAsyncLookupFunction.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/CachingLookupFunction.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/LookupCacheManager.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/CacheLoader.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/LookupFullCache.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/ReloadTriggerContext.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/inputformat/InputFormatCacheLoader.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/inputformat/InputSplitCacheLoadTask.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/io/LongHashPartitionChannelReaderInputViewIterator.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/keyselector/GenericRowDataKeySelector.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperator.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperatorCoordinator.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperatorFactory.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/ExecutionOrderEnforcerOperator.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/dynamicfiltering/ExecutionOrderEnforcerOperatorFactory.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/SortMergeJoinFunction.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/KeyedLookupJoinWrapper.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/ResultRetryStrategy.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/RetryableAsyncLookupFunctionDelegator.java
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/RetryableLookupFunctionDelegator.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/CachingAsyncLookupFunctionTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/CachingLookupFunctionTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/fullcache/LookupFullCacheTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/fullcache/TestCacheLoader.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/fullcache/TestManualCacheReloadTrigger.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/fullcache/inputformat/FullCacheTestInputFormat.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/functions/table/fullcache/inputformat/InputFormatCacheLoaderTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperatorCoordinatorTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataCollectorOperatorTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/dynamicfiltering/DynamicFilteringDataTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/Int2AdaptiveHashJoinOperatorTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/Int2HashJoinOperatorTestBase.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/KeyedLookupJoinHarnessTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/RetryableAsyncLookupFunctionDelegatorTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/RetryableLookupFunctionDelegatorTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/over/ProcTimeUnboundedPrecedingFunctionTest.java
create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/util/JoinUtil.java
create mode 100644 flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/UnorderedCollectIteratorAssert.java
create mode 100644 flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testutils/formats/SchemaTestUtils.java
create mode 100644 flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/packaging/PackagingTestUtils.java
create mode 100644 flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/resources/ResourceTestUtils.java
create mode 100644 flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/packaging/PackagingTestUtilsTest.java
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationRescaleITCase.java
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationSwitchEnvTestBase.java
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationSwitchStateBackendITCase.java
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationTestBase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogRecoveryITCase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogRecoveryITCaseBase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogRecoveryRescaleITCase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogRecoverySwitchEnvTestBase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogRecoverySwitchStateBackendITCase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/runtime/BatchShuffleITCaseBase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/runtime/HybridShuffleITCase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/state/ChangelogRecoveryCachingITCase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/CacheITCase.java
create mode 100644 tools/ci/flink-ci-tools/pom.xml
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/java/org/apache/flink/tools/ci/licensecheck/JarFileChecker.java (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/java/org/apache/flink/tools/ci/licensecheck/LicenseChecker.java (100%)
create mode 100644 tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/NoticeFileChecker.java
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/java/org/apache/flink/tools/ci/suffixcheck/ScalaSuffixChecker.java (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/java/org/apache/flink/tools/ci/utils/dependency/DependencyParser.java (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/java/org/apache/flink/tools/ci/utils/shared/Dependency.java (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/resources/log4j2.properties (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/main/resources/modules-defining-excess-dependencies.modulelist (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/test/java/org/apache/flink/tools/ci/licensecheck/JarFileCheckerTest.java (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/test/java/org/apache/flink/tools/ci/utils/dependency/DependencyParserCopyTest.java (100%)
rename tools/ci/{java-ci-tools => flink-ci-tools}/src/test/java/org/apache/flink/tools/ci/utils/dependency/DependencyParserTreeTest.java (100%)
copy {flink-connectors/flink-connector-aws-base => tools/ci/flink-ci-tools}/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension (100%)
delete mode 100644 tools/ci/java-ci-tools/pom.xml
delete mode 100644 tools/ci/java-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/NoticeFileChecker.java
delete mode 100644 tools/ci/java-ci-tools/src/main/resources/modules-skipping-deployment.modulelist