This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
from 96888b2ce [FLINK-34577] Add IssueNavigationLink for IDEA git log
(#3096)
new eeb4bab92 [FLINK-34184][cdc][license] Update Copyright from Ververica
to Apache
new f1461f2b4 [hotfix][cdc][docs] Update LICENSE file
new a6c1b06e1 [FLINK-34184][cdc][docs] Add license for all document files
This closes #3092.
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/labeler.yml | 18 +++----
.github/workflows/build_docs.yml | 18 +++----
.github/workflows/flink_cdc.yml | 14 +++---
.github/workflows/label.yml | 18 +++----
LICENSE | 2 +-
docs/README.md | 19 ++++++++
docs/_static/theme_overrides.css | 29 ++++++------
docs/_templates/breadcrumbs.html | 27 ++++++-----
docs/_templates/versions.html | 27 ++++++-----
docs/build_docs.sh | 23 ++++-----
docs/conf.py | 16 ++++---
docs/content/connectors/db2-cdc.md | 19 ++++++++
docs/content/connectors/index.md | 19 ++++++++
docs/content/connectors/mongodb-cdc(ZH).md | 19 ++++++++
docs/content/connectors/mongodb-cdc.md | 19 ++++++++
docs/content/connectors/mysql-cdc(ZH).md | 19 ++++++++
docs/content/connectors/mysql-cdc.md | 19 ++++++++
docs/content/connectors/oceanbase-cdc(ZH).md | 19 ++++++++
docs/content/connectors/oceanbase-cdc.md | 19 ++++++++
docs/content/connectors/oracle-cdc.md | 19 ++++++++
docs/content/connectors/postgres-cdc.md | 19 ++++++++
docs/content/connectors/sqlserver-cdc.md | 19 ++++++++
docs/content/connectors/tidb-cdc.md | 19 ++++++++
docs/content/connectors/vitess-cdc.md | 19 ++++++++
docs/content/downloads.md | 19 ++++++++
docs/content/formats/changelog-json.md | 19 ++++++++
docs/content/formats/index.md | 19 ++++++++
docs/content/githublink.md | 19 ++++++++
docs/content/overview/cdc-connectors.md | 19 ++++++++
docs/content/overview/cdc-pipeline.md | 19 ++++++++
docs/content/overview/index.md | 19 ++++++++
docs/content/pipelines/doris-pipeline(ZH).md | 19 ++++++++
docs/content/pipelines/doris-pipeline.md | 19 ++++++++
docs/content/pipelines/index.md | 19 ++++++++
docs/content/pipelines/mysql-pipeline(ZH).md | 19 ++++++++
docs/content/pipelines/mysql-pipeline.md | 19 ++++++++
docs/content/pipelines/starrocks-pipeline(ZH).md | 19 ++++++++
docs/content/pipelines/starrocks-pipeline.md | 19 ++++++++
.../build-real-time-data-lake-tutorial.md | 19 ++++++++
.../quickstart/datastream-api-package-guidance.md | 19 ++++++++
docs/content/quickstart/db2-tutorial.md | 19 ++++++++
docs/content/quickstart/index.md | 19 ++++++++
docs/content/quickstart/mongodb-tutorial.md | 19 ++++++++
.../quickstart/mysql-doris-pipeline-tutorial.md | 19 ++++++++
docs/content/quickstart/mysql-postgres-tutorial.md | 19 ++++++++
.../mysql-starrocks-pipeline-tutorial.md | 19 ++++++++
docs/content/quickstart/oceanbase-tutorial.md | 19 ++++++++
docs/content/quickstart/oracle-tutorial.md | 19 ++++++++
docs/content/quickstart/polardbx-tutorial.md | 19 ++++++++
docs/content/quickstart/sqlserver-tutorial.md | 19 ++++++++
docs/content/quickstart/tidb-tutorial.md | 19 ++++++++
.../build-real-time-data-lake-tutorial-zh.md" | 19 ++++++++
.../datastream-api-package-guidance-zh.md" | 19 ++++++++
.../index.md" | 19 ++++++++
.../mongodb-tutorial-zh.md" | 19 ++++++++
.../mysql-doris-pipeline-tutorial-zh.md" | 19 ++++++++
.../mysql-postgres-tutorial-zh.md" | 19 ++++++++
.../mysql-starrocks-pipeline-tutorial-zh.md" | 19 ++++++++
.../oceanbase-tutorial-zh.md" | 19 ++++++++
.../oracle-tutorial-zh.md" | 19 ++++++++
.../polardbx-tutorial-zh.md" | 19 ++++++++
.../sqlserver-tutorial-zh.md" | 19 ++++++++
.../tidb-tutorial-zh.md" | 19 ++++++++
docs/docs_site.sh | 23 ++++-----
flink-cdc-cli/pom.xml | 26 +++++-----
.../java/com/ververica/cdc/cli/CliExecutor.java | 13 ++---
.../java/com/ververica/cdc/cli/CliFrontend.java | 13 ++---
.../com/ververica/cdc/cli/CliFrontendOptions.java | 13 ++---
.../cdc/cli/parser/PipelineDefinitionParser.java | 13 ++---
.../cli/parser/YamlPipelineDefinitionParser.java | 13 ++---
.../cdc/cli/utils/ConfigurationUtils.java | 13 ++---
.../cdc/cli/utils/FlinkEnvironmentUtils.java | 13 ++---
.../com/ververica/cdc/cli/CliFrontendTest.java | 13 ++---
.../parser/YamlPipelineDefinitionParserTest.java | 13 ++---
.../definitions/pipeline-definition-full.yaml | 16 ++++---
.../definitions/pipeline-definition-minimized.yaml | 16 ++++---
.../pipeline-definition-with-optional.yaml | 16 ++++---
.../resources/global-config/global-config.yaml | 16 ++++---
.../src/test/resources/log4j2-test.properties | 17 +++----
flink-cdc-common/pom.xml | 24 +++++-----
.../cdc/common/annotation/Experimental.java | 13 ++---
.../ververica/cdc/common/annotation/Internal.java | 13 ++---
.../ververica/cdc/common/annotation/Public.java | 13 ++---
.../cdc/common/annotation/PublicEvolving.java | 13 ++---
.../cdc/common/annotation/VisibleForTesting.java | 13 ++---
.../cdc/common/configuration/ConfigOption.java | 13 ++---
.../cdc/common/configuration/ConfigOptions.java | 13 ++---
.../cdc/common/configuration/Configuration.java | 13 ++---
.../common/configuration/ConfigurationUtils.java | 13 ++---
.../cdc/common/configuration/FallbackKey.java | 13 ++---
.../configuration/StructuredOptionsSplitter.java | 13 ++---
.../configuration/description/BlockElement.java | 13 ++---
.../configuration/description/Description.java | 13 ++---
.../description/DescriptionElement.java | 13 ++---
.../configuration/description/Formatter.java | 13 ++---
.../configuration/description/HtmlFormatter.java | 13 ++---
.../configuration/description/InlineElement.java | 13 ++---
.../description/LineBreakElement.java | 13 ++---
.../configuration/description/LinkElement.java | 13 ++---
.../configuration/description/ListElement.java | 13 ++---
.../configuration/description/TextElement.java | 13 ++---
.../com/ververica/cdc/common/data/ArrayData.java | 13 ++---
.../com/ververica/cdc/common/data/DecimalData.java | 13 ++---
.../cdc/common/data/GenericArrayData.java | 13 ++---
.../ververica/cdc/common/data/GenericMapData.java | 13 ++---
.../cdc/common/data/LocalZonedTimestampData.java | 13 ++---
.../com/ververica/cdc/common/data/MapData.java | 13 ++---
.../com/ververica/cdc/common/data/RecordData.java | 13 ++---
.../com/ververica/cdc/common/data/StringData.java | 13 ++---
.../ververica/cdc/common/data/TimestampData.java | 13 ++---
.../cdc/common/data/ZonedTimestampData.java | 13 ++---
.../cdc/common/data/binary/BinaryFormat.java | 13 ++---
.../cdc/common/data/binary/BinaryRecordData.java | 13 ++---
.../cdc/common/data/binary/BinarySection.java | 13 ++---
.../cdc/common/data/binary/BinarySegmentUtils.java | 13 ++---
.../cdc/common/data/binary/BinaryStringData.java | 13 ++---
.../cdc/common/data/binary/LazyBinaryFormat.java | 13 ++---
.../cdc/common/data/binary/MurmurHashUtils.java | 13 ++---
.../cdc/common/data/binary/NullAwareGetters.java | 13 ++---
.../ververica/cdc/common/event/AddColumnEvent.java | 13 ++---
.../cdc/common/event/AlterColumnTypeEvent.java | 13 ++---
.../ververica/cdc/common/event/ChangeEvent.java | 13 ++---
.../cdc/common/event/CreateTableEvent.java | 13 ++---
.../cdc/common/event/DataChangeEvent.java | 13 ++---
.../cdc/common/event/DropColumnEvent.java | 13 ++---
.../java/com/ververica/cdc/common/event/Event.java | 13 ++---
.../cdc/common/event/EventDeserializer.java | 13 ++---
.../com/ververica/cdc/common/event/FlushEvent.java | 13 ++---
.../ververica/cdc/common/event/OperationType.java | 13 ++---
.../cdc/common/event/RenameColumnEvent.java | 13 ++---
.../cdc/common/event/SchemaChangeEvent.java | 13 ++---
.../com/ververica/cdc/common/event/TableId.java | 13 ++---
.../cdc/common/factories/DataSinkFactory.java | 13 ++---
.../cdc/common/factories/DataSourceFactory.java | 13 ++---
.../ververica/cdc/common/factories/Factory.java | 13 ++---
.../cdc/common/factories/FactoryHelper.java | 13 ++---
.../cdc/common/pipeline/PipelineOptions.java | 13 ++---
.../cdc/common/pipeline/SchemaChangeBehavior.java | 13 ++---
.../com/ververica/cdc/common/schema/Column.java | 13 ++---
.../cdc/common/schema/MetadataColumn.java | 13 ++---
.../cdc/common/schema/PhysicalColumn.java | 13 ++---
.../com/ververica/cdc/common/schema/Schema.java | 13 ++---
.../com/ververica/cdc/common/schema/Selectors.java | 13 ++---
.../ververica/cdc/common/schema/TableFilter.java | 13 ++---
.../com/ververica/cdc/common/sink/DataSink.java | 13 ++---
.../cdc/common/sink/EventSinkProvider.java | 13 ++---
.../cdc/common/sink/FlinkSinkFunctionProvider.java | 13 ++---
.../cdc/common/sink/FlinkSinkProvider.java | 13 ++---
.../ververica/cdc/common/sink/MetadataApplier.java | 13 ++---
.../ververica/cdc/common/source/DataSource.java | 13 ++---
.../cdc/common/source/EventSourceProvider.java | 13 ++---
.../common/source/FlinkSourceFunctionProvider.java | 13 ++---
.../cdc/common/source/FlinkSourceProvider.java | 13 ++---
.../cdc/common/source/MetadataAccessor.java | 13 ++---
.../cdc/common/text/ParsingException.java | 13 ++---
.../com/ververica/cdc/common/text/Position.java | 13 ++---
.../com/ververica/cdc/common/text/TokenStream.java | 13 ++---
.../com/ververica/cdc/common/types/ArrayType.java | 13 ++---
.../com/ververica/cdc/common/types/BigIntType.java | 13 ++---
.../com/ververica/cdc/common/types/BinaryType.java | 13 ++---
.../ververica/cdc/common/types/BooleanType.java | 13 ++---
.../com/ververica/cdc/common/types/CharType.java | 13 ++---
.../com/ververica/cdc/common/types/DataField.java | 13 ++---
.../com/ververica/cdc/common/types/DataType.java | 13 ++---
.../ververica/cdc/common/types/DataTypeChecks.java | 13 ++---
.../cdc/common/types/DataTypeDefaultVisitor.java | 13 ++---
.../ververica/cdc/common/types/DataTypeFamily.java | 13 ++---
.../ververica/cdc/common/types/DataTypeRoot.java | 13 ++---
.../cdc/common/types/DataTypeVisitor.java | 13 ++---
.../com/ververica/cdc/common/types/DataTypes.java | 13 ++---
.../com/ververica/cdc/common/types/DateType.java | 13 ++---
.../ververica/cdc/common/types/DecimalType.java | 13 ++---
.../com/ververica/cdc/common/types/DoubleType.java | 13 ++---
.../com/ververica/cdc/common/types/FloatType.java | 13 ++---
.../com/ververica/cdc/common/types/IntType.java | 13 ++---
.../cdc/common/types/LocalZonedTimestampType.java | 13 ++---
.../com/ververica/cdc/common/types/MapType.java | 13 ++---
.../com/ververica/cdc/common/types/RowType.java | 13 ++---
.../ververica/cdc/common/types/SmallIntType.java | 13 ++---
.../com/ververica/cdc/common/types/TimeType.java | 13 ++---
.../ververica/cdc/common/types/TimestampType.java | 13 ++---
.../ververica/cdc/common/types/TinyIntType.java | 13 ++---
.../ververica/cdc/common/types/VarBinaryType.java | 13 ++---
.../ververica/cdc/common/types/VarCharType.java | 13 ++---
.../cdc/common/types/ZonedTimestampType.java | 13 ++---
.../cdc/common/types/utils/DataTypeUtils.java | 13 ++---
.../types/utils/runtime/DataInputViewStream.java | 13 ++---
.../types/utils/runtime/DataOutputViewStream.java | 13 ++---
.../ververica/cdc/common/utils/EncodingUtils.java | 13 ++---
.../cdc/common/utils/InstantiationUtil.java | 13 ++---
.../ververica/cdc/common/utils/Preconditions.java | 13 ++---
.../com/ververica/cdc/common/utils/Predicates.java | 13 ++---
.../ververica/cdc/common/utils/SchemaUtils.java | 13 ++---
.../cdc/common/utils/StringUtf8Utils.java | 13 ++---
.../ververica/cdc/common/utils/StringUtils.java | 13 ++---
.../com/ververica/cdc/common/utils/TimeUtils.java | 13 ++---
.../ververica/cdc/common/utils/TypeCheckUtils.java | 13 ++---
.../ververica/cdc/common/schema/SelectorsTest.java | 13 ++---
.../testutils/assertions/AddColumnEventAssert.java | 13 ++---
.../assertions/AlterColumnTypeEventAssert.java | 13 ++---
.../testutils/assertions/ChangeEventAssert.java | 13 ++---
.../assertions/CreateTableEventAssert.java | 13 ++---
.../assertions/DataChangeEventAssert.java | 13 ++---
.../assertions/DropColumnEventAssert.java | 13 ++---
.../common/testutils/assertions/EventAssert.java | 13 ++---
.../testutils/assertions/EventAssertions.java | 13 ++---
.../testutils/assertions/RecordDataAssert.java | 13 ++---
.../assertions/RecordDataWithSchemaAssert.java | 13 ++---
.../assertions/RenameColumnEventAssert.java | 13 ++---
.../assertions/SchemaChangeEventAssert.java | 13 ++---
.../cdc/common/utils/SchemaUtilsTest.java | 13 ++---
.../src/test/resources/log4j2-test.properties | 21 ++++-----
flink-cdc-composer/pom.xml | 24 +++++-----
.../ververica/cdc/composer/PipelineComposer.java | 13 ++---
.../ververica/cdc/composer/PipelineExecution.java | 13 ++---
.../cdc/composer/definition/PipelineDef.java | 13 ++---
.../cdc/composer/definition/RouteDef.java | 13 ++---
.../ververica/cdc/composer/definition/SinkDef.java | 13 ++---
.../cdc/composer/definition/SourceDef.java | 13 ++---
.../cdc/composer/definition/TransformDef.java | 13 ++---
.../cdc/composer/flink/FlinkEnvironmentUtils.java | 13 ++---
.../cdc/composer/flink/FlinkPipelineComposer.java | 13 ++---
.../cdc/composer/flink/FlinkPipelineExecution.java | 13 ++---
.../flink/coordination/OperatorIDGenerator.java | 13 ++---
.../flink/translator/DataSinkTranslator.java | 13 ++---
.../flink/translator/DataSourceTranslator.java | 13 ++---
.../flink/translator/PartitioningTranslator.java | 13 ++---
.../composer/flink/translator/RouteTranslator.java | 13 ++---
.../flink/translator/SchemaOperatorTranslator.java | 13 ++---
.../cdc/composer/utils/FactoryDiscoveryUtils.java | 13 ++---
.../flink/FlinkPipelineComposerITCase.java | 13 ++---
.../composer/flink/FlinkPipelineComposerTest.java | 13 ++---
.../flink/translator/DataSourceTranslatorTest.java | 13 ++---
.../composer/utils/FactoryDiscoveryUtilsTest.java | 13 ++---
.../composer/utils/factory/DataSinkFactory1.java | 13 ++---
.../composer/utils/factory/DataSinkFactory2.java | 13 ++---
.../composer/utils/factory/DataSourceFactory1.java | 13 ++---
.../composer/utils/factory/DataSourceFactory2.java | 13 ++---
.../cdc/composer/utils/factory/TestOptions.java | 13 ++---
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-cdc-pipeline-connector-doris/pom.xml | 24 +++++-----
.../doris/factory/DorisDataSinkFactory.java | 13 ++---
.../cdc/connectors/doris/sink/DorisDataSink.java | 13 ++---
.../doris/sink/DorisDataSinkOptions.java | 13 ++---
.../doris/sink/DorisEventSerializer.java | 13 ++---
.../doris/sink/DorisMetadataApplier.java | 13 ++---
.../connectors/doris/sink/DorisRowConverter.java | 13 ++---
.../doris/sink/DorisRowConverterTest.java | 13 ++---
.../flink-cdc-pipeline-connector-mysql/pom.xml | 29 ++++++------
.../mysql/factory/MySqlDataSourceFactory.java | 13 ++---
.../connectors/mysql/source/MySqlDataSource.java | 13 ++---
.../mysql/source/MySqlDataSourceOptions.java | 13 ++---
.../mysql/source/MySqlEventDeserializer.java | 13 ++---
.../mysql/source/MySqlMetadataAccessor.java | 13 ++---
.../mysql/source/MySqlSchemaDataTypeInference.java | 13 ++---
.../parser/CustomAlterTableParserListener.java | 13 ++---
.../CustomColumnDefinitionParserListener.java | 13 ++---
.../source/parser/CustomMySqlAntlrDdlParser.java | 13 ++---
.../parser/CustomMySqlAntlrDdlParserListener.java | 13 ++---
.../source/reader/MySqlPipelineRecordEmitter.java | 13 ++---
.../connectors/mysql/utils/MySqlSchemaUtils.java | 13 ++---
.../cdc/connectors/mysql/utils/MySqlTypeUtils.java | 13 ++---
.../com.ververica.cdc.common.factories.Factory | 17 +++----
.../mysql/source/MySqlDataSourceFactoryTest.java | 13 ++---
.../mysql/source/MySqlFullTypesITCase.java | 13 ++---
.../mysql/source/MySqlMetadataAccessorITCase.java | 13 ++---
.../mysql/source/MySqlPipelineITCase.java | 13 ++---
.../mysql/testutils/MySqSourceTestUtils.java | 13 ++---
.../mysql/testutils/RecordDataTestUtils.java | 13 ++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../test/resources/ddl/column_type_test_mysql8.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../docker/server-gtids/expire-seconds/my.cnf | 22 ++++-----
.../src/test/resources/docker/server-gtids/my.cnf | 22 ++++-----
.../src/test/resources/docker/server/my.cnf | 22 ++++-----
.../src/test/resources/docker/setup.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../src/test/resources/pipeline-test.yaml | 16 ++++---
.../flink-cdc-pipeline-connector-starrocks/pom.xml | 24 +++++-----
.../sink/EventRecordSerializationSchema.java | 13 ++---
.../starrocks/sink/SchemaChangeConfig.java | 13 ++---
.../starrocks/sink/StarRocksDataSink.java | 13 ++---
.../starrocks/sink/StarRocksDataSinkFactory.java | 13 ++---
.../starrocks/sink/StarRocksDataSinkOptions.java | 13 ++---
.../starrocks/sink/StarRocksMetadataApplier.java | 13 ++---
.../connectors/starrocks/sink/StarRocksUtils.java | 13 ++---
.../starrocks/sink/TableCreateConfig.java | 13 ++---
.../starrocks/sink/CdcDataTypeTransformerTest.java | 13 ++---
.../sink/EventRecordSerializationSchemaTest.java | 13 ++---
.../starrocks/sink/MockStarRocksCatalog.java | 13 ++---
.../sink/StarRocksDataSinkFactoryTest.java | 13 ++---
.../sink/StarRocksMetadataApplierTest.java | 13 ++---
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-cdc-pipeline-connector-values/pom.xml | 24 +++++-----
.../cdc/connectors/values/ValuesDatabase.java | 13 ++---
.../values/factory/ValuesDataFactory.java | 13 ++---
.../cdc/connectors/values/sink/ValuesDataSink.java | 13 ++---
.../values/sink/ValuesDataSinkHelper.java | 13 ++---
.../values/sink/ValuesDataSinkOptions.java | 13 ++---
.../connectors/values/source/ValuesDataSource.java | 13 ++---
.../values/source/ValuesDataSourceHelper.java | 13 ++---
.../values/source/ValuesDataSourceOptions.java | 13 ++---
.../com.ververica.cdc.common.factories.Factory | 17 +++----
.../cdc/connectors/values/ValuesDatabaseTest.java | 13 ++---
.../values/sink/ValuesDataSinkHelperTest.java | 13 ++---
.../values/source/ValuesDataSourceITCase.java | 13 ++---
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-cdc-pipeline-connectors/pom.xml | 24 +++++-----
.../flink-cdc-base/pom.xml | 26 +++++-----
.../connectors/base/config/BaseSourceConfig.java | 13 ++---
.../connectors/base/config/JdbcSourceConfig.java | 13 ++---
.../base/config/JdbcSourceConfigFactory.java | 13 ++---
.../cdc/connectors/base/config/SourceConfig.java | 13 ++---
.../connectors/base/dialect/DataSourceDialect.java | 13 ++---
.../base/dialect/JdbcDataSourceDialect.java | 13 ++---
.../connectors/base/options/JdbcSourceOptions.java | 13 ++---
.../cdc/connectors/base/options/SourceOptions.java | 13 ++---
.../cdc/connectors/base/options/StartupMode.java | 13 ++---
.../connectors/base/options/StartupOptions.java | 13 ++---
.../base/relational/JdbcSourceEventDispatcher.java | 13 ++---
.../relational/connection/ConnectionPoolId.java | 13 ++---
.../relational/connection/ConnectionPools.java | 13 ++---
.../connection/JdbcConnectionFactory.java | 13 ++---
.../connection/JdbcConnectionPoolFactory.java | 13 ++---
.../relational/connection/JdbcConnectionPools.java | 13 ++---
.../handler/SchemaChangeEventHandler.java | 13 ++---
.../base/source/EmbeddedFlinkDatabaseHistory.java | 13 ++---
.../connectors/base/source/IncrementalSource.java | 13 ++---
.../base/source/assigner/AssignerStatus.java | 13 ++---
.../base/source/assigner/HybridSplitAssigner.java | 13 ++---
.../source/assigner/SnapshotSplitAssigner.java | 13 ++---
.../base/source/assigner/SplitAssigner.java | 13 ++---
.../base/source/assigner/StreamSplitAssigner.java | 13 ++---
.../base/source/assigner/splitter/ChunkRange.java | 13 ++---
.../source/assigner/splitter/ChunkSplitter.java | 13 ++---
.../assigner/splitter/JdbcSourceChunkSplitter.java | 13 ++---
.../assigner/state/HybridPendingSplitsState.java | 13 ++---
.../source/assigner/state/PendingSplitsState.java | 13 ++---
.../state/PendingSplitsStateSerializer.java | 13 ++---
.../assigner/state/SnapshotPendingSplitsState.java | 13 ++---
.../assigner/state/StreamPendingSplitsState.java | 13 ++---
.../enumerator/IncrementalSourceEnumerator.java | 13 ++---
.../base/source/jdbc/JdbcIncrementalSource.java | 13 ++---
.../events/FinishedSnapshotSplitsAckEvent.java | 13 ++---
.../events/FinishedSnapshotSplitsReportEvent.java | 13 ++---
.../events/FinishedSnapshotSplitsRequestEvent.java | 13 ++---
.../events/LatestFinishedSplitsNumberEvent.java | 13 ++---
.../LatestFinishedSplitsNumberRequestEvent.java | 13 ++---
.../meta/events/StreamSplitAssignedEvent.java | 13 ++---
.../source/meta/events/StreamSplitMetaEvent.java | 13 ++---
.../meta/events/StreamSplitMetaRequestEvent.java | 13 ++---
.../meta/events/StreamSplitUpdateAckEvent.java | 13 ++---
.../meta/events/StreamSplitUpdateRequestEvent.java | 13 ++---
.../connectors/base/source/meta/offset/Offset.java | 13 ++---
.../meta/offset/OffsetDeserializerSerializer.java | 13 ++---
.../base/source/meta/offset/OffsetFactory.java | 13 ++---
.../base/source/meta/split/ChangeEventRecords.java | 13 ++---
.../meta/split/FinishedSnapshotSplitInfo.java | 13 ++---
.../source/meta/split/SchemalessSnapshotSplit.java | 13 ++---
.../base/source/meta/split/SnapshotSplit.java | 13 ++---
.../base/source/meta/split/SnapshotSplitState.java | 13 ++---
.../base/source/meta/split/SourceRecords.java | 13 ++---
.../base/source/meta/split/SourceSplitBase.java | 13 ++---
.../source/meta/split/SourceSplitSerializer.java | 13 ++---
.../base/source/meta/split/SourceSplitState.java | 13 ++---
.../base/source/meta/split/StreamSplit.java | 13 ++---
.../base/source/meta/split/StreamSplitState.java | 13 ++---
.../source/meta/wartermark/WatermarkEvent.java | 13 ++---
.../base/source/meta/wartermark/WatermarkKind.java | 13 ++---
.../base/source/metrics/SourceReaderMetrics.java | 13 ++---
.../source/reader/IncrementalSourceReader.java | 13 ++---
.../reader/IncrementalSourceReaderContext.java | 13 ++---
.../reader/IncrementalSourceReaderWithCommit.java | 13 ++---
.../reader/IncrementalSourceRecordEmitter.java | 13 ++---
.../reader/IncrementalSourceSplitReader.java | 13 ++---
.../reader/external/AbstractScanFetchTask.java | 13 ++---
.../base/source/reader/external/FetchTask.java | 13 ++---
.../base/source/reader/external/Fetcher.java | 13 ++---
.../external/IncrementalSourceScanFetcher.java | 13 ++---
.../external/IncrementalSourceStreamFetcher.java | 13 ++---
.../external/JdbcSourceFetchTaskContext.java | 13 ++---
.../base/source/utils/hooks/SnapshotPhaseHook.java | 13 ++---
.../source/utils/hooks/SnapshotPhaseHooks.java | 13 ++---
.../connectors/base/utils/EnvironmentUtils.java | 13 ++---
.../cdc/connectors/base/utils/ObjectUtils.java | 13 ++---
.../cdc/connectors/base/utils/OptionUtils.java | 13 ++---
.../cdc/connectors/base/utils/SerializerUtils.java | 13 ++---
.../connectors/base/utils/SourceRecordUtils.java | 13 ++---
.../connectors/base/utils/VersionComparable.java | 13 ++---
.../connectors/base/JdbcConnectionPoolTest.java | 13 ++---
.../base/MySqlChangeEventSourceExampleTest.java | 13 ++---
.../experimental/EmbeddedFlinkDatabaseHistory.java | 13 ++---
.../base/experimental/MySqlChunkSplitter.java | 13 ++---
.../connectors/base/experimental/MySqlDialect.java | 13 ++---
.../base/experimental/MySqlSourceBuilder.java | 13 ++---
.../experimental/MysqlPooledDataSourceFactory.java | 13 ++---
.../experimental/config/MySqlSourceConfig.java | 13 ++---
.../config/MySqlSourceConfigFactory.java | 13 ++---
.../base/experimental/config/ServerIdRange.java | 13 ++---
.../experimental/fetch/MySqlScanFetchTask.java | 13 ++---
.../fetch/MySqlSourceFetchTaskContext.java | 13 ++---
.../experimental/fetch/MySqlStreamFetchTask.java | 13 ++---
.../handler/MySqlSchemaChangeEventHandler.java | 13 ++---
.../base/experimental/offset/BinlogOffset.java | 13 ++---
.../experimental/offset/BinlogOffsetFactory.java | 13 ++---
.../experimental/utils/MySqlConnectionUtils.java | 13 ++---
.../base/experimental/utils/MySqlSchema.java | 13 ++---
.../base/experimental/utils/MySqlTypeUtils.java | 13 ++---
.../base/experimental/utils/MySqlUtils.java | 13 ++---
.../experimental/utils/TableDiscoveryUtils.java | 13 ++---
.../state/PendingSplitsStateSerializerTest.java | 13 ++---
.../version5/HybridPendingSplitsStateVersion5.java | 13 ++---
.../PendingSplitsStateSerializerVersion5.java | 13 ++---
.../SnapshotPendingSplitsStateVersion5.java | 13 ++---
.../meta/split/SourceSplitSerializerTest.java | 13 ++---
.../LegacySourceSplitSerializierVersion4.java | 13 ++---
.../meta/split/version4/StreamSplitVersion4.java | 13 ++---
.../connectors/base/testutils/MySqlContainer.java | 13 ++---
.../connectors/base/testutils/MySqlVersion.java | 13 ++---
.../connectors/base/testutils/UniqueDatabase.java | 13 ++---
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/docker/server-gtids/my.cnf | 22 ++++-----
.../src/test/resources/docker/setup.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-db2-cdc/pom.xml | 26 +++++-----
.../ververica/cdc/connectors/db2/Db2Source.java | 13 ++---
.../connectors/db2/table/Db2ReadableMetaData.java | 13 ++---
.../cdc/connectors/db2/table/Db2TableSource.java | 13 ++---
.../db2/table/Db2TableSourceFactory.java | 13 ++---
.../cdc/connectors/db2/table/StartupMode.java | 13 ++---
.../cdc/connectors/db2/table/StartupOptions.java | 13 ++---
.../cdc/connectors/db2/utils/OptionUtils.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 17 +++----
.../cdc/connectors/db2/Db2SourceTest.java | 13 ++---
.../ververica/cdc/connectors/db2/Db2TestBase.java | 13 ++---
.../connectors/db2/table/Db2ConnectorITCase.java | 13 ++---
.../db2/table/Db2TableSourceFactoryTest.java | 13 ++---
.../src/test/resources/db2_server/Dockerfile | 23 ++++-----
.../src/test/resources/db2_server/asncdc.c | 31 ++++++------
.../src/test/resources/db2_server/asncdc_UDF.sql | 26 +++++-----
.../test/resources/db2_server/asncdcaddremove.sql | 26 +++++-----
.../src/test/resources/db2_server/asncdctables.sql | 26 +++++-----
.../src/test/resources/db2_server/cdcsetup.sh | 25 +++++-----
.../test/resources/db2_server/column_type_test.sql | 26 +++++-----
.../src/test/resources/db2_server/dbsetup.sh | 25 +++++-----
.../src/test/resources/db2_server/inventory.sql | 26 +++++-----
.../test/resources/db2_server/startup-agent.sql | 26 +++++-----
.../test/resources/db2_server/startup-cdc-demo.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-debezium/pom.xml | 24 +++++-----
.../debezium/DebeziumDeserializationSchema.java | 13 ++---
.../cdc/debezium/DebeziumSourceFunction.java | 13 ++---
.../JsonDebeziumDeserializationSchema.java | 13 ++---
.../StringDebeziumDeserializationSchema.java | 13 ++---
.../java/com/ververica/cdc/debezium/Validator.java | 13 ++---
.../event/DebeziumEventDeserializationSchema.java | 13 ++---
.../event/DebeziumSchemaDataTypeInference.java | 13 ++---
.../debezium/event/SchemaDataTypeInference.java | 13 ++---
.../event/SourceRecordEventDeserializer.java | 13 ++---
.../history/FlinkJsonTableChangeSerializer.java | 13 ++---
.../debezium/internal/DebeziumChangeConsumer.java | 13 ++---
.../debezium/internal/DebeziumChangeFetcher.java | 13 ++---
.../cdc/debezium/internal/DebeziumOffset.java | 13 ++---
.../internal/DebeziumOffsetSerializer.java | 13 ++---
.../debezium/internal/FlinkDatabaseHistory.java | 13 ++---
.../internal/FlinkDatabaseSchemaHistory.java | 13 ++---
.../debezium/internal/FlinkOffsetBackingStore.java | 13 ++---
.../ververica/cdc/debezium/internal/Handover.java | 13 ++---
.../cdc/debezium/internal/SchemaRecord.java | 13 ++---
.../debezium/table/AppendMetadataCollector.java | 13 ++---
.../cdc/debezium/table/DebeziumChangelogMode.java | 13 ++---
.../cdc/debezium/table/DebeziumOptions.java | 13 ++---
.../table/DeserializationRuntimeConverter.java | 13 ++---
.../DeserializationRuntimeConverterFactory.java | 13 ++---
.../cdc/debezium/table/MetadataConverter.java | 13 ++---
.../table/RowDataDebeziumDeserializeSchema.java | 13 ++---
.../debezium/table/RowDataMetadataConverter.java | 13 ++---
.../cdc/debezium/utils/DatabaseHistoryUtil.java | 13 ++---
.../ververica/cdc/debezium/utils/JdbcUrlUtils.java | 13 ++---
.../cdc/debezium/utils/ResolvedSchemaUtils.java | 13 ++---
.../cdc/debezium/utils/TemporalConversions.java | 13 ++---
.../flink-connector-mongodb-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/mongodb/MongoDBSource.java | 13 ++---
.../internal/MongoDBConnectorSourceConnector.java | 13 ++---
.../internal/MongoDBConnectorSourceTask.java | 13 ++---
.../mongodb/internal/MongoDBEnvelope.java | 13 ++---
.../connectors/mongodb/source/MongoDBSource.java | 13 ++---
.../mongodb/source/MongoDBSourceBuilder.java | 13 ++---
.../assigners/splitters/MongoDBChunkSplitter.java | 13 ++---
.../splitters/SampleBucketSplitStrategy.java | 13 ++---
.../assigners/splitters/ShardedSplitStrategy.java | 13 ++---
.../assigners/splitters/SingleSplitStrategy.java | 13 ++---
.../source/assigners/splitters/SplitContext.java | 13 ++---
.../source/assigners/splitters/SplitStrategy.java | 13 ++---
.../splitters/SplitVectorSplitStrategy.java | 13 ++---
.../mongodb/source/config/MongoDBSourceConfig.java | 13 ++---
.../source/config/MongoDBSourceConfigFactory.java | 13 ++---
.../source/config/MongoDBSourceOptions.java | 13 ++---
.../mongodb/source/connection/MongoClientPool.java | 13 ++---
.../mongodb/source/dialect/MongoDBDialect.java | 13 ++---
.../source/offset/ChangeStreamDescriptor.java | 13 ++---
.../mongodb/source/offset/ChangeStreamOffset.java | 13 ++---
.../source/offset/ChangeStreamOffsetFactory.java | 13 ++---
.../source/reader/MongoDBRecordEmitter.java | 13 ++---
.../reader/fetch/MongoDBFetchTaskContext.java | 13 ++---
.../source/reader/fetch/MongoDBScanFetchTask.java | 13 ++---
.../reader/fetch/MongoDBStreamFetchTask.java | 13 ++---
.../connectors/mongodb/source/utils/BsonUtils.java | 13 ++---
.../mongodb/source/utils/ChunkUtils.java | 13 ++---
.../source/utils/CollectionDiscoveryUtils.java | 13 ++---
.../mongodb/source/utils/MongoRecordUtils.java | 13 ++---
.../mongodb/source/utils/MongoUtils.java | 13 ++---
.../mongodb/source/utils/ResumeTokenUtils.java | 13 ++---
.../MongoDBConnectorDeserializationSchema.java | 13 ++---
...onnectorFullChangelogDeserializationSchema.java | 13 ++---
.../mongodb/table/MongoDBReadableMetadata.java | 13 ++---
.../mongodb/table/MongoDBTableSource.java | 13 ++---
.../mongodb/table/MongoDBTableSourceFactory.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../connectors/mongodb/LegacyMongoDBContainer.java | 13 ++---
.../mongodb/LegacyMongoDBSourceExampleTest.java | 13 ++---
.../mongodb/LegacyMongoDBSourceTest.java | 13 ++---
.../mongodb/LegacyMongoDBSourceTestBase.java | 13 ++---
.../connectors/mongodb/LegacyMongoDBTestBase.java | 13 ++---
.../mongodb/source/MongoDBFullChangelogITCase.java | 13 ++---
.../source/MongoDBParallelSourceExampleTest.java | 13 ++---
.../source/MongoDBParallelSourceITCase.java | 13 ++---
.../mongodb/source/MongoDBSourceTestBase.java | 13 ++---
.../mongodb/source/NewlyAddedTableITCase.java | 13 ++---
.../reader/MongoDBSnapshotSplitReaderTest.java | 13 ++---
.../reader/MongoDBStreamSplitReaderTest.java | 13 ++---
.../mongodb/source/utils/BsonUtilsTest.java | 13 ++---
.../mongodb/source/utils/ResumeTokenUtilsTest.java | 13 ++---
.../mongodb/table/MongoDBConnectorITCase.java | 13 ++---
.../mongodb/table/MongoDBRegexFilterITCase.java | 13 ++---
.../mongodb/table/MongoDBTableFactoryTest.java | 13 ++---
.../mongodb/table/MongoDBTimeZoneITCase.java | 13 ++---
.../mongodb/utils/MongoDBAssertUtils.java | 13 ++---
.../connectors/mongodb/utils/MongoDBContainer.java | 13 ++---
.../connectors/mongodb/utils/MongoDBTestUtils.java | 13 ++---
.../connectors/mongodb/utils/RecordsFormatter.java | 13 ++---
.../cdc/connectors/mongodb/utils/TestTable.java | 13 ++---
.../src/test/resources/ddl/chunk_test.js | 22 ++++-----
.../src/test/resources/ddl/column_type_test.js | 22 ++++-----
.../src/test/resources/ddl/customer.js | 22 ++++-----
.../src/test/resources/ddl/inventory.js | 22 ++++-----
.../src/test/resources/ddl/ns-dotted.js | 22 ++++-----
.../src/test/resources/ddl/ns-regex.js | 22 ++++-----
.../src/test/resources/ddl/ns_regex.js | 22 ++++-----
.../src/test/resources/docker/mongodb/random.key | 16 ++++---
.../src/test/resources/docker/mongodb/setup.js | 22 ++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-mysql-cdc/pom.xml | 26 +++++-----
.../binlog/event/deserialization/ColumnType.java | 13 ++---
.../TableMapEventDataDeserializer.java | 13 ++---
.../TableMapEventMetadataDeserializer.java | 13 ++---
.../mysql/binlog/io/BufferedSocketInputStream.java | 13 ++---
.../cdc/connectors/mysql/MySqlSource.java | 13 ++---
.../cdc/connectors/mysql/MySqlValidator.java | 11 +++--
.../mysql/SeekBinlogToTimestampFilter.java | 13 ++---
.../connectors/mysql/debezium/DebeziumUtils.java | 13 ++---
.../debezium/EmbeddedFlinkDatabaseHistory.java | 13 ++---
.../debezium/dispatcher/EventDispatcherImpl.java | 13 ++---
.../debezium/dispatcher/SignalEventDispatcher.java | 13 ++---
.../mysql/debezium/reader/BinlogSplitReader.java | 13 ++---
.../mysql/debezium/reader/DebeziumReader.java | 13 ++---
.../mysql/debezium/reader/SnapshotSplitReader.java | 13 ++---
.../reader/StoppableChangeEventSourceContext.java | 13 ++---
.../debezium/task/MySqlBinlogSplitReadTask.java | 13 ++---
.../debezium/task/MySqlSnapshotSplitReadTask.java | 13 ++---
.../debezium/task/context/MySqlErrorHandler.java | 13 ++---
.../task/context/MySqlTaskContextImpl.java | 13 ++---
.../debezium/task/context/StatefulTaskContext.java | 13 ++---
.../exception/SchemaOutOfSyncException.java | 13 ++---
.../mysql/schema/MySqlFieldDefinition.java | 13 ++---
.../cdc/connectors/mysql/schema/MySqlSchema.java | 13 ++---
.../mysql/schema/MySqlTableDefinition.java | 13 ++---
.../connectors/mysql/schema/MySqlTypeUtils.java | 13 ++---
.../cdc/connectors/mysql/source/MySqlSource.java | 13 ++---
.../mysql/source/MySqlSourceBuilder.java | 13 ++---
.../mysql/source/assigners/AssignerStatus.java | 13 ++---
.../mysql/source/assigners/ChunkRange.java | 13 ++---
.../mysql/source/assigners/ChunkSplitter.java | 13 ++---
.../source/assigners/MySqlBinlogSplitAssigner.java | 13 ++---
.../mysql/source/assigners/MySqlChunkSplitter.java | 13 ++---
.../source/assigners/MySqlHybridSplitAssigner.java | 13 ++---
.../assigners/MySqlSnapshotSplitAssigner.java | 13 ++---
.../mysql/source/assigners/MySqlSplitAssigner.java | 13 ++---
.../assigners/state/BinlogPendingSplitsState.java | 13 ++---
.../source/assigners/state/ChunkSplitterState.java | 13 ++---
.../assigners/state/HybridPendingSplitsState.java | 13 ++---
.../source/assigners/state/PendingSplitsState.java | 13 ++---
.../state/PendingSplitsStateSerializer.java | 13 ++---
.../state/SnapshotPendingSplitsState.java | 13 ++---
.../mysql/source/config/MySqlSourceConfig.java | 13 ++---
.../source/config/MySqlSourceConfigFactory.java | 13 ++---
.../mysql/source/config/MySqlSourceOptions.java | 13 ++---
.../mysql/source/config/ServerIdRange.java | 13 ++---
.../mysql/source/connection/ConnectionPoolId.java | 13 ++---
.../mysql/source/connection/ConnectionPools.java | 13 ++---
.../source/connection/JdbcConnectionFactory.java | 13 ++---
.../source/connection/JdbcConnectionPools.java | 13 ++---
.../source/connection/PooledDataSourceFactory.java | 13 ++---
.../source/enumerator/MySqlSourceEnumerator.java | 13 ++---
.../source/events/BinlogSplitAssignedEvent.java | 13 ++---
.../mysql/source/events/BinlogSplitMetaEvent.java | 13 ++---
.../source/events/BinlogSplitMetaRequestEvent.java | 13 ++---
.../source/events/BinlogSplitUpdateAckEvent.java | 13 ++---
.../events/BinlogSplitUpdateRequestEvent.java | 13 ++---
.../events/FinishedSnapshotSplitsAckEvent.java | 13 ++---
.../events/FinishedSnapshotSplitsReportEvent.java | 13 ++---
.../events/FinishedSnapshotSplitsRequestEvent.java | 13 ++---
.../events/LatestFinishedSplitsNumberEvent.java | 13 ++---
.../LatestFinishedSplitsNumberRequestEvent.java | 13 ++---
.../source/metrics/MySqlSourceReaderMetrics.java | 13 ++---
.../mysql/source/offset/BinlogOffset.java | 13 ++---
.../mysql/source/offset/BinlogOffsetBuilder.java | 13 ++---
.../mysql/source/offset/BinlogOffsetKind.java | 13 ++---
.../source/offset/BinlogOffsetSerializer.java | 13 ++---
.../mysql/source/offset/BinlogOffsetUtils.java | 13 ++---
.../mysql/source/reader/MySqlRecordEmitter.java | 13 ++---
.../mysql/source/reader/MySqlSourceReader.java | 13 ++---
.../source/reader/MySqlSourceReaderContext.java | 13 ++---
.../mysql/source/reader/MySqlSplitReader.java | 13 ++---
.../source/split/FinishedSnapshotSplitInfo.java | 13 ++---
.../mysql/source/split/MySqlBinlogSplit.java | 13 ++---
.../mysql/source/split/MySqlBinlogSplitState.java | 13 ++---
.../mysql/source/split/MySqlRecords.java | 13 ++---
.../source/split/MySqlSchemalessSnapshotSplit.java | 13 ++---
.../mysql/source/split/MySqlSnapshotSplit.java | 13 ++---
.../source/split/MySqlSnapshotSplitState.java | 13 ++---
.../connectors/mysql/source/split/MySqlSplit.java | 13 ++---
.../mysql/source/split/MySqlSplitSerializer.java | 13 ++---
.../mysql/source/split/MySqlSplitState.java | 13 ++---
.../mysql/source/split/SourceRecords.java | 13 ++---
.../connectors/mysql/source/utils/ChunkUtils.java | 13 ++---
.../mysql/source/utils/EnvironmentUtils.java | 13 ++---
.../connectors/mysql/source/utils/ObjectUtils.java | 13 ++---
.../connectors/mysql/source/utils/RecordUtils.java | 13 ++---
.../mysql/source/utils/SerializerUtils.java | 13 ++---
.../mysql/source/utils/StatementUtils.java | 13 ++---
.../mysql/source/utils/TableDiscoveryUtils.java | 13 ++---
.../mysql/source/utils/VersionComparable.java | 13 ++---
.../source/utils/hooks/SnapshotPhaseHook.java | 13 ++---
.../source/utils/hooks/SnapshotPhaseHooks.java | 13 ++---
.../MySqlDeserializationConverterFactory.java | 13 ++---
.../mysql/table/MySqlReadableMetadata.java | 13 ++---
.../connectors/mysql/table/MySqlTableSource.java | 13 ++---
.../mysql/table/MySqlTableSourceFactory.java | 13 ++---
.../cdc/connectors/mysql/table/StartupMode.java | 13 ++---
.../cdc/connectors/mysql/table/StartupOptions.java | 13 ++---
.../cdc/connectors/mysql/utils/OptionUtils.java | 13 ++---
.../io/debezium/connector/mysql/GtidUtils.java | 13 ++---
.../connector/mysql/util/ErrorMessageUtils.java | 11 +++--
.../org.apache.flink.table.factories.Factory | 17 +++----
.../TableMapEventDataDeserializerTest.java | 13 ++---
.../binlog/io/BufferedSocketInputStreamTest.java | 13 ++---
.../mysql/LegacyMySqlSourceExampleTest.java | 13 ++---
.../connectors/mysql/LegacyMySqlSourceITCase.java | 13 ++---
.../connectors/mysql/LegacyMySqlSourceTest.java | 13 ++---
.../cdc/connectors/mysql/LegacyMySqlTestBase.java | 13 ++---
.../cdc/connectors/mysql/MySqlTestUtils.java | 11 +++--
.../cdc/connectors/mysql/MySqlValidatorTest.java | 11 +++--
.../mysql/debezium/DebeziumUtilsTest.java | 13 ++---
.../debezium/reader/BinlogSplitReaderTest.java | 13 ++---
.../debezium/reader/SnapshotSplitReaderTest.java | 13 ++---
.../mysql/source/MySqlSourceExampleTest.java | 13 ++---
.../connectors/mysql/source/MySqlSourceITCase.java | 13 ++---
.../mysql/source/MySqlSourceTestBase.java | 13 ++---
.../mysql/source/NewlyAddedTableITCase.java | 13 ++---
.../mysql/source/SpecificStartingOffsetITCase.java | 13 ++---
.../assigners/MySqlBinlogSplitAssignerTest.java | 13 ++---
.../source/assigners/MySqlChunkSplitterTest.java | 13 ++---
.../assigners/MySqlHybridSplitAssignerTest.java | 13 ++---
.../assigners/MySqlSnapshotSplitAssignerTest.java | 13 ++---
.../state/PendingSplitsStateSerializerTest.java | 13 ++---
.../source/reader/MySqlRecordEmitterTest.java | 13 ++---
.../mysql/source/reader/MySqlSourceReaderTest.java | 13 ++---
.../source/split/MySqlSplitSerializerTest.java | 13 ++---
.../mysql/source/split/MySqlSplitStateTest.java | 13 ++---
.../mysql/source/utils/ObjectUtilsTest.java | 13 ++---
.../mysql/source/utils/RecordUtilsTest.java | 13 ++---
.../mysql/source/utils/SerializerUtilsTest.java | 13 ++---
.../mysql/table/MySqlCompatibilityITCase.java | 13 ++---
.../mysql/table/MySqlConnectorITCase.java | 13 ++---
.../mysql/table/MySqlTableSourceFactoryTest.java | 13 ++---
.../mysql/table/MySqlTimezoneITCase.java | 13 ++---
.../mysql/table/MysqlConnectorCharsetITCase.java | 13 ++---
.../connectors/mysql/testutils/MySqlContainer.java | 13 ++---
.../connectors/mysql/testutils/MySqlVersion.java | 13 ++---
.../mysql/testutils/RecordsFormatter.java | 13 ++---
.../cdc/connectors/mysql/testutils/TestTable.java | 13 ++---
.../mysql/testutils/TestTableSchemas.java | 13 ++---
.../connectors/mysql/testutils/UniqueDatabase.java | 13 ++---
.../connectors/polardbx/PolardbxCharsetITCase.java | 13 ++---
.../connectors/polardbx/PolardbxSourceITCase.java | 13 ++---
.../polardbx/PolardbxSourceTestBase.java | 13 ++---
.../io/debezium/connector/mysql/GtidUtilsTest.java | 13 ++---
.../mysql/util/ErrorMessageUtilsTest.java | 11 +++--
.../test/resources/ddl/binlog_metadata_test.sql | 26 +++++-----
.../src/test/resources/ddl/charset_test.sql | 26 +++++-----
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../test/resources/ddl/column_type_test_mysql8.sql | 26 +++++-----
.../src/test/resources/ddl/customer.sql | 26 +++++-----
.../src/test/resources/ddl/customer3.0.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/ddl/polardbx_ddl_test.sql | 26 +++++-----
.../src/test/resources/ddl/user_1.sql | 26 +++++-----
.../src/test/resources/ddl/user_2.sql | 26 +++++-----
.../docker/server-gtids/expire-seconds/my.cnf | 22 ++++-----
.../src/test/resources/docker/server-gtids/my.cnf | 22 ++++-----
.../src/test/resources/docker/server/my.cnf | 22 ++++-----
.../src/test/resources/docker/setup.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-oceanbase-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/oceanbase/OceanBaseSource.java | 13 ++---
.../oceanbase/source/OceanBaseConnection.java | 13 ++---
.../OceanBaseDeserializationRuntimeConverter.java | 13 ++---
.../source/OceanBaseRichSourceFunction.java | 13 ++---
.../RowDataOceanBaseDeserializationSchema.java | 13 ++---
.../table/OceanBaseAppendMetadataCollector.java | 13 ++---
.../table/OceanBaseDeserializationSchema.java | 13 ++---
.../table/OceanBaseMetadataConverter.java | 13 ++---
.../oceanbase/table/OceanBaseReadableMetadata.java | 13 ++---
.../oceanbase/table/OceanBaseRecord.java | 13 ++---
.../oceanbase/table/OceanBaseTableSource.java | 13 ++---
.../table/OceanBaseTableSourceFactory.java | 13 ++---
.../connectors/oceanbase/table/StartupMode.java | 13 ++---
.../connectors/oceanbase/utils/OptionUtils.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../connectors/oceanbase/OceanBaseTestBase.java | 13 ++---
.../oceanbase/table/OceanBaseConnectorITCase.java | 13 ++---
.../oceanbase/table/OceanBaseTableFactoryTest.java | 13 ++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/ddl/inventory_meta.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-oracle-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/oracle/OracleSource.java | 13 ++---
.../cdc/connectors/oracle/OracleValidator.java | 13 ++---
.../connectors/oracle/source/OracleDialect.java | 13 ++---
.../source/OraclePooledDataSourceFactory.java | 13 ++---
.../oracle/source/OracleSourceBuilder.java | 13 ++---
.../assigner/splitter/OracleChunkSplitter.java | 13 ++---
.../oracle/source/config/OracleSourceConfig.java | 13 ++---
.../source/config/OracleSourceConfigFactory.java | 13 ++---
.../oracle/source/config/OracleSourceOptions.java | 13 ++---
.../handler/OracleSchemaChangeEventHandler.java | 13 ++---
.../oracle/source/meta/offset/RedoLogOffset.java | 13 ++---
.../source/meta/offset/RedoLogOffsetFactory.java | 13 ++---
.../source/reader/fetch/EventProcessorFactory.java | 13 ++---
.../source/reader/fetch/OracleScanFetchTask.java | 13 ++---
.../reader/fetch/OracleSourceFetchTaskContext.java | 13 ++---
.../source/reader/fetch/OracleStreamFetchTask.java | 13 ++---
.../fetch/StoppableChangeEventSourceContext.java | 13 ++---
.../oracle/source/utils/OracleConnectionUtils.java | 13 ++---
.../oracle/source/utils/OracleSchema.java | 13 ++---
.../oracle/source/utils/OracleTypeUtils.java | 13 ++---
.../oracle/source/utils/OracleUtils.java | 13 ++---
.../OracleDeserializationConverterFactory.java | 13 ++---
.../oracle/table/OracleReadableMetaData.java | 13 ++---
.../connectors/oracle/table/OracleTableSource.java | 13 ++---
.../oracle/table/OracleTableSourceFactory.java | 13 ++---
.../cdc/connectors/oracle/util/ChunkUtils.java | 13 ++---
.../connectors/oracle/util/OracleJdbcUrlUtils.java | 13 ++---
.../connector/oracle/logminer/LogMinerAdapter.java | 13 ++---
.../LogMinerStreamingChangeEventSource.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../oracle/OracleChangeEventSourceExampleTest.java | 13 ++---
.../cdc/connectors/oracle/OracleSourceTest.java | 13 ++---
.../oracle/source/OracleSourceITCase.java | 13 ++---
.../oracle/source/OracleSourceTestBase.java | 13 ++---
.../oracle/table/OracleConnectorITCase.java | 13 ++---
.../oracle/table/OracleTableSourceFactoryTest.java | 13 ++---
.../oracle/testutils/RecordsFormatter.java | 13 ++---
.../cdc/connectors/oracle/testutils/TestTable.java | 13 ++---
.../testcontainers/containers/OracleContainer.java | 13 ++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/customer.sql | 26 +++++-----
.../src/test/resources/ddl/product.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-postgres-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/postgres/PostgreSQLSource.java | 13 ++---
.../postgres/source/PostgresChunkSplitter.java | 13 ++---
.../source/PostgresConnectionPoolFactory.java | 13 ++---
.../postgres/source/PostgresDialect.java | 13 ++---
.../postgres/source/PostgresSourceBuilder.java | 13 ++---
.../source/config/PostgresSourceConfig.java | 13 ++---
.../source/config/PostgresSourceConfigFactory.java | 13 ++---
.../source/config/PostgresSourceOptions.java | 13 ++---
.../enumerator/PostgresSourceEnumerator.java | 13 ++---
.../source/events/OffsetCommitAckEvent.java | 13 ++---
.../postgres/source/events/OffsetCommitEvent.java | 13 ++---
.../source/fetch/PostgresScanFetchTask.java | 13 ++---
.../fetch/PostgresSourceFetchTaskContext.java | 13 ++---
.../source/fetch/PostgresStreamFetchTask.java | 13 ++---
.../fetch/StoppableChangeEventSourceContext.java | 13 ++---
.../handler/PostgresSchemaChangeEventHandler.java | 13 ++---
.../postgres/source/offset/PostgresOffset.java | 13 ++---
.../source/offset/PostgresOffsetFactory.java | 13 ++---
.../source/offset/PostgresOffsetUtils.java | 13 ++---
.../source/reader/PostgresSourceReader.java | 13 ++---
.../postgres/source/utils/ChunkUtils.java | 13 ++---
.../source/utils/CustomPostgresSchema.java | 13 ++---
.../postgres/source/utils/PostgresQueryUtils.java | 13 ++---
.../postgres/source/utils/PostgresTypeUtils.java | 13 ++---
.../postgres/source/utils/TableDiscoveryUtils.java | 13 ++---
.../PostgreSQLDeserializationConverterFactory.java | 13 ++---
.../postgres/table/PostgreSQLReadableMetadata.java | 13 ++---
.../postgres/table/PostgreSQLTableFactory.java | 13 ++---
.../postgres/table/PostgreSQLTableSource.java | 13 ++---
.../postgres/table/PostgresValueValidator.java | 13 ++---
.../cdc/connectors/postgres/utils/OptionUtils.java | 13 ++---
.../connector/postgresql/PostgresObjectUtils.java | 13 ++---
.../io/debezium/connector/postgresql/Utils.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../connectors/postgres/PostgreSQLSourceTest.java | 13 ++---
.../cdc/connectors/postgres/PostgresTestBase.java | 13 ++---
.../postgres/source/MockPostgresDialect.java | 13 ++---
.../postgres/source/NewlyAddedTableITCase.java | 13 ++---
.../postgres/source/PostgresDialectTest.java | 13 ++---
.../postgres/source/PostgresSourceExampleTest.java | 13 ++---
.../postgres/source/PostgresSourceITCase.java | 13 ++---
.../source/fetch/PostgresScanFetchTaskTest.java | 13 ++---
.../fetch/PostgresSourceFetchTaskContextTest.java | 13 ++---
.../postgres/table/MockPostgreSQLTableFactory.java | 13 ++---
.../postgres/table/MockPostgreSQLTableSource.java | 13 ++---
.../postgres/table/PostgreSQLConnectorITCase.java | 13 ++---
.../postgres/table/PostgreSQLSavepointITCase.java | 13 ++---
.../postgres/table/PostgreSQLTableFactoryTest.java | 13 ++---
.../postgres/testutils/PostgresTestUtils.java | 13 ++---
.../postgres/testutils/RecordsFormatter.java | 13 ++---
.../connectors/postgres/testutils/TestHelper.java | 13 ++---
.../connectors/postgres/testutils/TestTable.java | 13 ++---
.../postgres/testutils/UniqueDatabase.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/customer.sql | 26 +++++-----
.../src/test/resources/ddl/index_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/ddl/replica_identity.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-sqlserver-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/sqlserver/SqlServerSource.java | 13 ++---
.../connectors/sqlserver/SqlServerValidator.java | 13 ++---
.../sqlserver/source/SqlServerSourceBuilder.java | 13 ++---
.../source/config/SqlServerSourceConfig.java | 13 ++---
.../config/SqlServerSourceConfigFactory.java | 13 ++---
.../source/dialect/SqlServerChunkSplitter.java | 13 ++---
.../sqlserver/source/dialect/SqlServerDialect.java | 13 ++---
.../dialect/SqlServerPooledDataSourceFactory.java | 13 ++---
.../sqlserver/source/dialect/SqlServerSchema.java | 13 ++---
.../handler/SqlServerSchemaChangeEventHandler.java | 13 ++---
.../sqlserver/source/offset/LsnFactory.java | 13 ++---
.../sqlserver/source/offset/LsnOffset.java | 13 ++---
.../reader/fetch/SqlServerScanFetchTask.java | 13 ++---
.../fetch/SqlServerSourceFetchTaskContext.java | 13 ++---
.../reader/fetch/SqlServerStreamFetchTask.java | 13 ++---
.../source/utils/SqlServerConnectionUtils.java | 13 ++---
.../sqlserver/source/utils/SqlServerTypeUtils.java | 13 ++---
.../sqlserver/source/utils/SqlServerUtils.java | 13 ++---
.../SqlServerDeserializationConverterFactory.java | 13 ++---
.../sqlserver/table/SqlServerReadableMetadata.java | 13 ++---
.../sqlserver/table/SqlServerTableFactory.java | 13 ++---
.../sqlserver/table/SqlServerTableSource.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../SqlServerParallelSourceExampleTest.java | 13 ++---
.../connectors/sqlserver/SqlServerTestBase.java | 13 ++---
.../sqlserver/source/SqlServerSourceITCase.java | 13 ++---
.../sqlserver/source/SqlServerSourceTestBase.java | 13 ++---
.../read/fetch/SqlServerScanFetchTaskTest.java | 13 ++---
.../sqlserver/table/SqlServerConnectorITCase.java | 13 ++---
.../sqlserver/table/SqlServerTableFactoryTest.java | 13 ++---
.../sqlserver/table/SqlServerTimezoneITCase.java | 13 ++---
.../sqlserver/testutils/RecordsFormatter.java | 13 ++---
.../connectors/sqlserver/testutils/TestTable.java | 13 ++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/customer.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/ddl/product.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-test-util/pom.xml | 24 +++++-----
.../cdc/connectors/utils/AssertUtils.java | 13 ++---
.../cdc/connectors/utils/TestSourceContext.java | 13 ++---
.../flink-connector-tidb-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/tidb/TDBSourceOptions.java | 13 ++---
.../ververica/cdc/connectors/tidb/TiDBSource.java | 13 ++---
.../tidb/TiKVChangeEventDeserializationSchema.java | 13 ++---
.../tidb/TiKVRichParallelSourceFunction.java | 13 ++---
.../TiKVSnapshotEventDeserializationSchema.java | 13 ++---
...owDataTiKVChangeEventDeserializationSchema.java | 13 ++---
.../RowDataTiKVEventDeserializationSchemaBase.java | 13 ++---
...DataTiKVSnapshotEventDeserializationSchema.java | 13 ++---
.../cdc/connectors/tidb/table/StartupMode.java | 13 ++---
.../cdc/connectors/tidb/table/StartupOptions.java | 13 ++---
.../cdc/connectors/tidb/table/TiDBTableSource.java | 13 ++---
.../tidb/table/TiDBTableSourceFactory.java | 13 ++---
.../tidb/table/TiKVAppendMetadataCollector.java | 13 ++---
.../table/TiKVDeserializationRuntimeConverter.java | 13 ++---
.../tidb/table/TiKVMetadataConverter.java | 13 ++---
.../tidb/table/TiKVReadableMetadata.java | 13 ++---
.../connectors/tidb/table/utils/OptionUtils.java | 13 ++---
.../tidb/table/utils/TableKeyRangeUtils.java | 13 ++---
.../src/main/java/org/tikv/cdc/CDCClient.java | 13 ++---
.../src/main/java/org/tikv/cdc/CDCEvent.java | 13 ++---
.../main/java/org/tikv/cdc/RegionCDCClient.java | 13 ++---
.../common/operation/iterator/ScanIterator.java | 13 ++---
.../java/org/tikv/common/util/ChannelFactory.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 16 ++++---
.../cdc/connectors/tidb/TiDBTestBase.java | 13 ++---
.../connectors/tidb/table/TiDBConnectorITCase.java | 13 ++---
.../tidb/table/TiDBConnectorRegionITCase.java | 13 ++---
.../tidb/table/TiDBTableSourceFactoryTest.java | 13 ++---
.../src/test/resources/config/pd.toml | 16 ++++---
.../src/test/resources/config/tidb.toml | 16 ++++---
.../src/test/resources/config/tikv.toml | 16 ++++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/ddl/region_switch_test.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-connector-vitess-cdc/pom.xml | 26 +++++-----
.../cdc/connectors/vitess/VitessSource.java | 13 ++---
.../cdc/connectors/vitess/VitessValidator.java | 13 ++---
.../vitess/config/SchemaAdjustmentMode.java | 13 ++---
.../cdc/connectors/vitess/config/TabletType.java | 13 ++---
.../vitess/table/VitessTableFactory.java | 13 ++---
.../connectors/vitess/table/VitessTableSource.java | 13 ++---
.../org.apache.flink.table.factories.Factory | 17 +++----
.../cdc/connectors/vitess/VitessSourceTest.java | 13 ++---
.../cdc/connectors/vitess/VitessTestBase.java | 13 ++---
.../vitess/container/VitessContainer.java | 13 ++---
.../vitess/table/VitessConnectorITCase.java | 13 ++---
.../vitess/table/VitessTableFactoryTest.java | 13 ++---
.../src/test/resources/ddl/column_type_test.sql | 26 +++++-----
.../src/test/resources/ddl/inventory.sql | 26 +++++-----
.../src/test/resources/log4j2-test.properties | 21 ++++-----
.../flink-sql-connector-db2-cdc/pom.xml | 24 +++++-----
.../ververica/cdc/connectors/db2/DummyDocs.java | 13 ++---
.../flink-sql-connector-mongodb-cdc/pom.xml | 24 +++++-----
.../cdc/connectors/mongodb/DummyDocs.java | 13 ++---
.../flink-sql-connector-mysql-cdc/pom.xml | 24 +++++-----
.../ververica/cdc/connectors/mysql/DummyDocs.java | 13 ++---
.../flink-sql-connector-oceanbase-cdc/pom.xml | 24 +++++-----
.../cdc/connectors/oceanbase/DummyDocs.java | 13 ++---
.../flink-sql-connector-oracle-cdc/pom.xml | 24 +++++-----
.../ververica/cdc/connectors/oracle/DummyDocs.java | 13 ++---
.../flink-sql-connector-postgres-cdc/pom.xml | 24 +++++-----
.../cdc/connectors/postgres/DummyDocs.java | 13 ++---
.../flink-sql-connector-sqlserver-cdc/pom.xml | 24 +++++-----
.../cdc/connectors/sqlserver/DummyDocs.java | 13 ++---
.../flink-sql-connector-tidb-cdc/pom.xml | 24 +++++-----
.../src/main/java/DummyDocs.java | 13 ++---
.../flink-sql-connector-vitess-cdc/pom.xml | 24 +++++-----
.../ververica/cdc/connectors/vitess/DummyDocs.java | 13 ++---
.../flink-cdc-source-connectors/pom.xml | 24 +++++-----
flink-cdc-connect/pom.xml | 24 +++++-----
flink-cdc-dist/pom.xml | 24 +++++-----
flink-cdc-dist/src/main/assembly/assembly.xml | 24 +++++-----
.../src/main/flink-cdc-bin/bin/flink-cdc.sh | 23 ++++-----
.../src/main/flink-cdc-bin/conf/flink-cdc.yaml | 26 +++++-----
.../main/flink-cdc-bin/conf/log4j-cli.properties | 18 +++----
.../flink-cdc-pipeline-e2e-tests/pom.xml | 24 +++++-----
.../flink-cdc-source-e2e-tests/pom.xml | 24 +++++-----
.../cdc/connectors/tests/Db2E2eITCase.java | 13 ++---
.../cdc/connectors/tests/MongoE2eITCase.java | 13 ++---
.../cdc/connectors/tests/MySqlE2eITCase.java | 13 ++---
.../cdc/connectors/tests/OceanBaseE2eITCase.java | 13 ++---
.../cdc/connectors/tests/OracleE2eITCase.java | 13 ++---
.../cdc/connectors/tests/PostgresE2eITCase.java | 13 ++---
.../cdc/connectors/tests/SqlServerE2eITCase.java | 13 ++---
.../cdc/connectors/tests/TiDBE2eITCase.java | 13 ++---
.../cdc/connectors/tests/VitessE2eITCase.java | 13 ++---
.../tests/utils/FlinkContainerTestEnvironment.java | 13 ++---
.../cdc/connectors/tests/utils/JdbcProxy.java | 13 ++---
.../connectors/tests/utils/ParameterProperty.java | 13 ++---
.../connectors/tests/utils/SQLJobSubmission.java | 13 ++---
.../cdc/connectors/tests/utils/TestUtils.java | 13 ++---
.../src/test/resources/ddl/mongo_inventory.js | 22 ++++-----
.../src/test/resources/ddl/mysql_inventory.sql | 26 +++++-----
.../src/test/resources/ddl/oceanbase_inventory.sql | 26 +++++-----
.../src/test/resources/ddl/postgres_inventory.sql | 26 +++++-----
.../src/test/resources/ddl/sqlserver_inventory.sql | 26 +++++-----
.../src/test/resources/ddl/tidb_inventory.sql | 26 +++++-----
.../src/test/resources/ddl/vitess_inventory.sql | 26 +++++-----
.../src/test/resources/docker/db2/Dockerfile | 23 ++++-----
.../src/test/resources/docker/db2/asncdc.c | 31 ++++++------
.../src/test/resources/docker/db2/asncdc_UDF.sql | 26 +++++-----
.../test/resources/docker/db2/asncdcaddremove.sql | 26 +++++-----
.../src/test/resources/docker/db2/asncdctables.sql | 26 +++++-----
.../src/test/resources/docker/db2/cdcsetup.sh | 25 +++++-----
.../test/resources/docker/db2/column_type_test.sql | 26 +++++-----
.../src/test/resources/docker/db2/dbsetup.sh | 25 +++++-----
.../src/test/resources/docker/db2/inventory.sql | 26 +++++-----
.../test/resources/docker/db2/startup-agent.sql | 26 +++++-----
.../test/resources/docker/db2/startup-cdc-demo.sql | 26 +++++-----
.../src/test/resources/docker/mongodb/random.key | 22 ++++-----
.../src/test/resources/docker/mongodb/setup.js | 22 ++++-----
.../src/test/resources/docker/mysql/my.cnf | 22 ++++-----
.../src/test/resources/docker/mysql/setup.sql | 26 +++++-----
.../src/test/resources/docker/oceanbase/setup.sql | 26 +++++-----
.../src/test/resources/docker/tidb/pd.toml | 16 ++++---
.../src/test/resources/docker/tidb/tidb.toml | 16 ++++---
.../src/test/resources/docker/tidb/tikv.toml | 16 ++++---
.../src/test/resources/log4j2-test.properties | 21 ++++-----
flink-cdc-e2e-tests/pom.xml | 24 +++++-----
flink-cdc-runtime/pom.xml | 24 +++++-----
.../cdc/runtime/operators/route/RouteFunction.java | 13 ++---
.../runtime/operators/schema/SchemaOperator.java | 13 ++---
.../operators/schema/SchemaOperatorFactory.java | 13 ++---
.../schema/coordinator/SchemaManager.java | 13 ++---
.../schema/coordinator/SchemaRegistry.java | 13 ++---
.../schema/coordinator/SchemaRegistryProvider.java | 13 ++---
.../coordinator/SchemaRegistryRequestHandler.java | 13 ++---
.../schema/event/CoordinationResponseUtils.java | 13 ++---
.../operators/schema/event/FlushSuccessEvent.java | 13 ++---
.../operators/schema/event/GetSchemaRequest.java | 13 ++---
.../operators/schema/event/GetSchemaResponse.java | 13 ++---
.../schema/event/ReleaseUpstreamRequest.java | 13 ++---
.../schema/event/ReleaseUpstreamResponse.java | 13 ++---
.../schema/event/SchemaChangeRequest.java | 13 ++---
.../schema/event/SchemaChangeResponse.java | 13 ++---
.../schema/event/SinkWriterRegisterEvent.java | 13 ++---
.../operators/sink/DataSinkWriterOperator.java | 13 ++---
.../sink/DataSinkWriterOperatorFactory.java | 13 ++---
.../operators/sink/SchemaEvolutionClient.java | 13 ++---
.../cdc/runtime/partitioning/EventPartitioner.java | 13 ++---
.../runtime/partitioning/PartitioningEvent.java | 13 ++---
.../partitioning/PartitioningEventKeySelector.java | 13 ++---
.../partitioning/PostPartitionProcessor.java | 13 ++---
.../runtime/partitioning/PrePartitionOperator.java | 13 ++---
.../cdc/runtime/serializer/BooleanSerializer.java | 13 ++---
.../serializer/BytePrimitiveArraySerializer.java | 13 ++---
.../cdc/runtime/serializer/ByteSerializer.java | 13 ++---
.../cdc/runtime/serializer/DoubleSerializer.java | 13 ++---
.../cdc/runtime/serializer/EnumSerializer.java | 13 ++---
.../cdc/runtime/serializer/FloatSerializer.java | 13 ++---
.../cdc/runtime/serializer/IntSerializer.java | 13 ++---
.../runtime/serializer/InternalSerializers.java | 13 ++---
.../runtime/serializer/LinkedListSerializer.java | 13 ++---
.../cdc/runtime/serializer/ListSerializer.java | 13 ++---
.../cdc/runtime/serializer/LongSerializer.java | 13 ++---
.../cdc/runtime/serializer/MapSerializer.java | 13 ++---
.../NestedSerializersSnapshotDelegate.java | 13 ++---
.../serializer/NullableSerializerWrapper.java | 13 ++---
.../cdc/runtime/serializer/ShortSerializer.java | 13 ++---
.../cdc/runtime/serializer/StringSerializer.java | 13 ++---
.../cdc/runtime/serializer/TableIdSerializer.java | 13 ++---
.../serializer/TypeSerializerSingleton.java | 13 ++---
.../serializer/data/ArrayDataSerializer.java | 13 ++---
.../serializer/data/DecimalDataSerializer.java | 13 ++---
.../data/LocalZonedTimestampDataSerializer.java | 13 ++---
.../serializer/data/RecordDataSerializer.java | 13 ++---
.../serializer/data/StringDataSerializer.java | 13 ++---
.../serializer/data/TimestampDataSerializer.java | 13 ++---
.../data/ZonedTimestampDataSerializer.java | 13 ++---
.../data/binary/BinaryRecordDataSerializer.java | 13 ++---
.../data/writer/AbstractBinaryWriter.java | 13 ++---
.../data/writer/BinaryRecordDataWriter.java | 13 ++---
.../serializer/data/writer/BinaryWriter.java | 13 ++---
.../serializer/event/AddColumnEventSerializer.java | 13 ++---
.../event/AlterColumnTypeEventSerializer.java | 13 ++---
.../event/CreateTableEventSerializer.java | 13 ++---
.../event/DataChangeEventSerializer.java | 13 ++---
.../event/DropColumnEventSerializer.java | 13 ++---
.../runtime/serializer/event/EventSerializer.java | 13 ++---
.../event/PartitioningEventSerializer.java | 13 ++---
.../event/RenameColumnEventSerializer.java | 13 ++---
.../event/SchemaChangeEventSerializer.java | 13 ++---
.../serializer/schema/ColumnSerializer.java | 13 ++---
.../schema/ColumnWithPositionSerializer.java | 13 ++---
.../serializer/schema/DataFieldSerializer.java | 13 ++---
.../serializer/schema/DataTypeSerializer.java | 13 ++---
.../schema/MetadataColumnSerializer.java | 13 ++---
.../schema/PhysicalColumnSerializer.java | 13 ++---
.../serializer/schema/RowTypeSerializer.java | 13 ++---
.../serializer/schema/SchemaSerializer.java | 13 ++---
.../typeutils/BinaryRecordDataGenerator.java | 13 ++---
.../cdc/runtime/typeutils/EventTypeInfo.java | 13 ++---
.../typeutils/PartitioningEventTypeInfo.java | 13 ++---
.../runtime/operators/route/RouteFunctionTest.java | 13 ++---
.../operators/schema/SchemaOperatorTest.java | 13 ++---
.../schema/coordinator/SchemaManagerTest.java | 13 ++---
.../partitioning/PrePartitionOperatorTest.java | 13 ++---
.../runtime/serializer/BooleanSerializerTest.java | 13 ++---
.../BytePrimitiveArraySerializerTest.java | 13 ++---
.../cdc/runtime/serializer/ByteSerializerTest.java | 13 ++---
.../runtime/serializer/DoubleSerializerTest.java | 13 ++---
.../cdc/runtime/serializer/EnumSerializerTest.java | 13 ++---
.../runtime/serializer/FloatSerializerTest.java | 13 ++---
.../cdc/runtime/serializer/IntSerializerTest.java | 13 ++---
.../serializer/LinkedListSerializerTest.java | 13 ++---
.../cdc/runtime/serializer/ListSerializerTest.java | 13 ++---
.../cdc/runtime/serializer/LongSerializerTest.java | 13 ++---
.../cdc/runtime/serializer/MapSerializerTest.java | 13 ++---
.../serializer/NullableSerializerWrapperTest.java | 13 ++---
.../cdc/runtime/serializer/SerializerTestBase.java | 13 ++---
.../runtime/serializer/ShortSerializerTest.java | 13 ++---
.../runtime/serializer/StringSerializerTest.java | 13 ++---
.../runtime/serializer/TableIdSerializerTest.java | 13 ++---
.../serializer/data/ArrayDataSerializerTest.java | 13 ++---
.../serializer/data/DecimalDataSerializerTest.java | 13 ++---
.../LocalZonedTimestampDataSerializerTest.java | 13 ++---
.../serializer/data/RecordDataSerializerTest.java | 13 ++---
.../serializer/data/StringDataSerializerTest.java | 13 ++---
.../data/TimestampDataSerializerTest.java | 13 ++---
.../data/ZonedTimestampDataSerializerTest.java | 13 ++---
.../event/AddColumnEventSerializerTest.java | 13 ++---
.../event/AlterColumnTypeEventSerializerTest.java | 13 ++---
.../event/CreateTableEventSerializerTest.java | 13 ++---
.../event/DataChangeEventSerializerTest.java | 13 ++---
.../event/DropColumnEventSerializerTest.java | 13 ++---
.../serializer/event/EventSerializerTest.java | 13 ++---
.../event/PartitioningEventSerializerTest.java | 13 ++---
.../event/RenameColumnEventSerializerTest.java | 13 ++---
.../event/SchemaChangeEventSerializerTest.java | 13 ++---
.../serializer/schema/ColumnSerializerTest.java | 13 ++---
.../schema/ColumnWithPositionSerializerTest.java | 13 ++---
.../serializer/schema/DataFieldSerializerTest.java | 13 ++---
.../serializer/schema/DataTypeSerializerTest.java | 13 ++---
.../schema/MetadataColumnSerializerTest.java | 13 ++---
.../schema/PhysicalColumnSerializerTest.java | 13 ++---
.../serializer/schema/RowTypeSerializerTest.java | 13 ++---
.../serializer/schema/SchemaSerializerTest.java | 13 ++---
.../operators/EventOperatorTestHarness.java | 13 ++---
.../schema/CollectingMetadataApplier.java | 13 ++---
.../schema/TestingSchemaRegistryGateway.java | 13 ++---
.../typeutils/BinaryRecordDataGeneratorTest.java | 13 ++---
.../src/test/resources/log4j2-test.properties | 21 ++++-----
pom.xml | 55 ++++++++++++----------
tools/maven/checkstyle.xml | 30 ++++++------
tools/maven/suppressions.xml | 24 +++++-----
1131 files changed, 9507 insertions(+), 7367 deletions(-)
