- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Documentation path like ".*/docs/.*" 176 files: docs/static/js/flink.js docs/static/font-awesome/css/font-awesome.css docs/static/fig/LICENSE.txt docs/layouts/shortcodes/pythondoc.html docs/layouts/shortcodes/github_repo.html docs/layouts/shortcodes/training_repo.html docs/layouts/shortcodes/build_time.html docs/layouts/shortcodes/check.html docs/layouts/shortcodes/sql_optional_connectors.html docs/layouts/shortcodes/unstable.html docs/layouts/shortcodes/sql_download_table.html docs/layouts/shortcodes/top.html docs/layouts/shortcodes/xmark.html docs/layouts/shortcodes/sql_optional_formats.html docs/layouts/shortcodes/py_download_link.html docs/layouts/shortcodes/tabs.html docs/layouts/shortcodes/py_connector_download_link.html docs/layouts/shortcodes/sql_connector_download_table.html docs/layouts/shortcodes/stable.html docs/layouts/shortcodes/version.html docs/layouts/shortcodes/img.html docs/layouts/shortcodes/sql_functions_zh.html docs/layouts/shortcodes/javadoc.html docs/layouts/shortcodes/scala_version.html docs/layouts/shortcodes/query_state_warning.html docs/layouts/shortcodes/downloads.html docs/layouts/shortcodes/artifact_tabs.html docs/layouts/shortcodes/connector_artifact.html docs/layouts/shortcodes/query_state_warning_zh.html docs/layouts/shortcodes/sql_functions.html docs/layouts/shortcodes/tab.html docs/layouts/shortcodes/artifact.html docs/layouts/shortcodes/gh_link.html docs/layouts/shortcodes/ref_static.html docs/layouts/shortcodes/training_link.html docs/layouts/shortcodes/all_versions.html docs/layouts/shortcodes/center.html docs/layouts/shortcodes/label.html docs/layouts/shortcodes/include_reporter_config.html docs/layouts/shortcodes/artifact_gradle.html docs/layouts/shortcodes/beta.html docs/layouts/_default/baseof.html docs/layouts/partials/docs/simple-title.html docs/layouts/partials/docs/menu.html docs/layouts/partials/docs/inject/menu-after.html docs/layouts/partials/docs/inject/menu-before.html docs/layouts/partials/docs/inject/head.html docs/layouts/partials/docs/inject/content-before.html docs/layouts/partials/docs/footer.html docs/layouts/partials/docs/title.html docs/layouts/partials/docs/menu-filetree.html docs/layouts/partials/docs/interpolate.html docs/layouts/partials/docs/toc.html docs/README.md docs/config.toml docs/content.zh/versions.md docs/content.zh/docs/faq/faq.md docs/content.zh/docs/faq/_index.md docs/content.zh/docs/developer-guide/understand-flink-cdc-api.md docs/content.zh/docs/developer-guide/licenses.md docs/content.zh/docs/developer-guide/_index.md docs/content.zh/docs/developer-guide/contribute-to-flink-cdc.md docs/content.zh/docs/core-concept/route.md docs/content.zh/docs/core-concept/table-id.md docs/content.zh/docs/core-concept/transform.md docs/content.zh/docs/core-concept/schema-evolution.md docs/content.zh/docs/core-concept/data-source.md docs/content.zh/docs/core-concept/data-sink.md docs/content.zh/docs/core-concept/_index.md docs/content.zh/docs/core-concept/data-pipeline.md docs/content.zh/docs/connectors/pipeline-connectors/elasticsearch.md docs/content.zh/docs/connectors/pipeline-connectors/kafka.md docs/content.zh/docs/connectors/pipeline-connectors/iceberg.md docs/content.zh/docs/connectors/pipeline-connectors/oceanbase.md docs/content.zh/docs/connectors/pipeline-connectors/mysql.md docs/content.zh/docs/connectors/pipeline-connectors/paimon.md docs/content.zh/docs/connectors/pipeline-connectors/starrocks.md docs/content.zh/docs/connectors/pipeline-connectors/maxcompute.md docs/content.zh/docs/connectors/pipeline-connectors/_index.md docs/content.zh/docs/connectors/pipeline-connectors/doris.md docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md docs/content.zh/docs/connectors/flink-sources/db2-cdc.md docs/content.zh/docs/connectors/flink-sources/sqlserver-cdc.md docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md docs/content.zh/docs/connectors/flink-sources/tidb-cdc.md docs/content.zh/docs/connectors/flink-sources/overview.md docs/content.zh/docs/connectors/flink-sources/_index.md docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md docs/content.zh/docs/connectors/flink-sources/vitess-cdc.md docs/content.zh/docs/connectors/flink-sources/datastream-api-package-guidance.md docs/content.zh/docs/connectors/flink-sources/tutorials/oracle-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/tidb-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/db2-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md docs/content.zh/docs/connectors/flink-sources/tutorials/_index.md docs/content.zh/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md docs/content.zh/docs/connectors/_index.md docs/content.zh/docs/get-started/quickstart/cdc-up-quickstart-guide.md docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md docs/content.zh/docs/get-started/quickstart/_index.md docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md docs/content.zh/docs/get-started/introduction.md docs/content.zh/docs/get-started/_index.md docs/content.zh/docs/deployment/standalone.md docs/content.zh/docs/deployment/yarn.md docs/content.zh/docs/deployment/kubernetes.md docs/content.zh/docs/deployment/_index.md docs/content.zh/_index.md docs/assets/github.css docs/assets/search-data.js docs/assets/_fonts.scss docs/assets/_custom.scss docs/content/versions.md docs/content/docs/faq/_index.md docs/content/docs/developer-guide/understand-flink-cdc-api.md docs/content/docs/developer-guide/licenses.md docs/content/docs/developer-guide/_index.md docs/content/docs/developer-guide/contribute-to-flink-cdc.md docs/content/docs/core-concept/route.md docs/content/docs/core-concept/table-id.md docs/content/docs/core-concept/transform.md docs/content/docs/core-concept/schema-evolution.md docs/content/docs/core-concept/data-source.md docs/content/docs/core-concept/data-sink.md docs/content/docs/core-concept/_index.md docs/content/docs/core-concept/data-pipeline.md docs/content/docs/connectors/pipeline-connectors/elasticsearch.md docs/content/docs/connectors/pipeline-connectors/kafka.md docs/content/docs/connectors/pipeline-connectors/iceberg.md docs/content/docs/connectors/pipeline-connectors/oceanbase.md docs/content/docs/connectors/pipeline-connectors/mysql.md docs/content/docs/connectors/pipeline-connectors/paimon.md docs/content/docs/connectors/pipeline-connectors/starrocks.md docs/content/docs/connectors/pipeline-connectors/maxcompute.md docs/content/docs/connectors/pipeline-connectors/_index.md docs/content/docs/connectors/pipeline-connectors/doris.md docs/content/docs/connectors/flink-sources/postgres-cdc.md docs/content/docs/connectors/flink-sources/oracle-cdc.md docs/content/docs/connectors/flink-sources/db2-cdc.md docs/content/docs/connectors/flink-sources/sqlserver-cdc.md docs/content/docs/connectors/flink-sources/mysql-cdc.md docs/content/docs/connectors/flink-sources/oceanbase-cdc.md docs/content/docs/connectors/flink-sources/tidb-cdc.md docs/content/docs/connectors/flink-sources/overview.md docs/content/docs/connectors/flink-sources/_index.md docs/content/docs/connectors/flink-sources/mongodb-cdc.md docs/content/docs/connectors/flink-sources/vitess-cdc.md docs/content/docs/connectors/flink-sources/datastream-api-package-guidance.md docs/content/docs/connectors/flink-sources/tutorials/oracle-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/build-real-time-data-lake-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/tidb-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/oceanbase-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/db2-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/mongodb-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/sqlserver-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/build-streaming-etl-tutorial.md docs/content/docs/connectors/flink-sources/tutorials/_index.md docs/content/docs/connectors/flink-sources/tutorials/polardbx-tutorial.md docs/content/docs/connectors/_index.md docs/content/docs/get-started/quickstart/cdc-up-quickstart-guide.md docs/content/docs/get-started/quickstart/mysql-to-doris.md docs/content/docs/get-started/quickstart/_index.md docs/content/docs/get-started/quickstart/mysql-to-starrocks.md docs/content/docs/get-started/introduction.md docs/content/docs/get-started/_index.md docs/content/docs/deployment/standalone.md docs/content/docs/deployment/yarn.md docs/content/docs/deployment/kubernetes.md docs/content/docs/deployment/_index.md docs/content/_index.md - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long lines (1000+ characters) 12 files: flink-cdc-cli/src/test/resources/flink-home/conf/flink-conf.yaml flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToDorisE2eITCase.java flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/resources/expectedEvents/mysqlToKafka/debezium-json-with-schema.txt flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/test/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchemaTest.java docs/static/js/anchor.min.js docs/static/flink-header-logo.svg docs/static/font-awesome/fonts/fontawesome-webfont.svg docs/static/font-awesome/css/font-awesome.min.css docs/content.zh/docs/connectors/pipeline-connectors/overview.md docs/content/docs/faq/faq.md docs/content/docs/connectors/pipeline-connectors/overview.md - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Hidden files and folders path like ".*/[.][a-zA-Z0-9_]+.*" 9 files: tools/cdcup/.gitignore .github/workflows/docs.sh .github/workflows/utils.sh .gitignore .asf.yaml .gitmodules docs/.gitignore .dlc.json .idea/vcs.xml - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Dependencies path like ".*/extern(al)?/.*" 6 files: flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/FetchTask.java flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/AbstractScanFetchTask.java flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcher.java flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceStreamFetcher.java flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/JdbcSourceFetchTaskContext.java flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/Fetcher.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Binaries for distribution path like ".*/bin/.*" 1 files: flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long file (1000000+ bytes) 1 files: git-history.txt - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -