[TEST] [WIP] reproduce oracle issue

.asf.yaml

@@ -0,0 +1,46 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+github:
+  description: "Flink CDC is a streaming data integration tool"
+  homepage: https://nightlies.apache.org/flink/flink-cdc-docs-stable
+  labels:
+    - flink
+    - distributed
+    - data-integration
+    - data-pipeline
+    - real-time
+    - batch
+    - change-data-capture
+    - schema-evolution
+    - mysql
+    - postgresql
+    - kafka
+    - paimon
+    - cdc
+    - etl
+    - elt
+  enabled_merge_buttons:
+    squash: true
+    merge: false
+    rebase: true
+  autolink_jira: FLINK
+  collaborators:
+    - flinkbot
+notifications:
+  commits: commits@flink.apache.org
+  pullrequests: issues@flink.apache.org
+  jobs: builds@flink.apache.org
+  jira_options: link label

.dlc.json

@@ -0,0 +1,35 @@
+{
+  "ignorePatterns": [
+    {
+      "pattern": "^http://localhost"
+    },
+    {
+      "pattern": "^#"
+    },
+    {
+      "pattern": "^{"
+    },
+    {
+      "pattern": "^https://repo1.maven.org/maven2/org/apache/flink.*SNAPSHOT.*"
+    },
+    {
+      "pattern": "^https://mvnrepository.com"
+    },
+    {
+      "pattern": "^https://img.shields.io"
+    },
+    {
+      "pattern": "^https://twitter.com*"
+    }
+  ],
+  "timeout": "30s",
+  "retryOn429": true,
+  "retryCount": 10,
+  "fallbackRetryDelay": "1000s",
+  "aliveStatusCodes": [
+    0,
+    200,
+    401,
+    403
+  ]
+}

.github/ISSUE_TEMPLATE/config.yml

@@ -1,5 +1,17 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
 blank_issues_enabled: false
-contact_links:
-  - name: Ask a question or get support
-    url: https://github.com/ververica/flink-cdc-connectors/discussions/categories/q-a
-    about: Ask a question or request support for CDC Connectors for Apache Flink®
+

.github/ISSUE_TEMPLATE/issue-notice.yml

@@ -0,0 +1,72 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+name: Read Notice on Creating New Issues
+description: We have moved to Apache Jira for managing issues
+body:
+  - type: markdown
+    attributes:
+      value: |
+        Thank you for choosing Flink CDC! 
+
+        As required by Apache Flink, please report bugs or new features on [Apache Jira](https://issues.apache.org/jira)
+        under the project `Flink` using component tag `Flink CDC`. You must have a JIRA account in order to log cases and issues.
+        If you don’t have an ASF JIRA account, you can request one at the [ASF Self-serve portal](https://selfserve.apache.org/jira-account.html),
+        account creation requires review by the PMC member of the application project, which normally takes one to two working days to be approved.
+
+        You can also initiate discussions in Apache Flink's dev mailing list (dev@flink.apache.org) for technical issues.
+
+        If you have any questions about using Flink CDC, please use Flink user mailing list (user@flink.apache.org)
+
+        Please note that issues created here on GitHub will be **ignored and automatically closed**.
+  - type: checkboxes
+    attributes:
+      label: Please don't check the box below
+      options:
+        - label: I'm aware that bugs and new features should be reported on [Apache Jira](https://issues.apache.org/jira)  or Flink mailing list (dev@flink.apache.org) instead of here
+          required: true
+  - type: checkboxes
+    attributes:
+      label: Again, please don't check the box below
+      options:
+        - label: I'm aware that new issues on GitHub will be ignored and automatically closed.
+          required: true
+  - type: markdown
+    attributes:
+      value: |
+        ---
+        感谢您选择 Flink CDC! 
+
+        由于 Apache Flink 的要求，请在 [Apache Jira](https://issues.apache.org/jira) 的 `Flink` 项目下使用 `Flink CDC` 标签来反馈缺陷或新功能。
+        您需要登录 Jira 帐户才能创建 issue 去记录缺陷或新功能，如果您没有 Apache JIRA 账号，您可以在 [ASF Jira 账号](https://selfserve.apache.org/jira-account.html)
+        申请账号，账号创建会由申请项目的 PMC member 审核，通常一到两个工作日可以通过。
+
+        您也可以在 Apache Flink 的开发者邮件列表（dev@flink.apache.org）中对技术问题发起讨论。
+
+        如果您有关于使用 Flink CDC 的问题，请在 Flink 用户邮件列表（user@flink.apache.org）中咨询。
+
+        请注意，在此创建的 GitHub issue 会被**忽略且自动关闭**。
+  - type: checkboxes
+    attributes:
+      label: 请不要勾选以下选项
+      options:
+        - label: 我已知悉缺陷和新功能需要在 [Apache Jira](https://issues.apache.org/jira) 或 Flink 邮件列表（dev@flink.apache.org）中反馈，而不是在这里创建新 issue。
+          required: true
+  - type: checkboxes
+    attributes:
+      label: 也请不要勾选以下选项
+      options:
+        - label: 我已知悉 GitHub 上的新 issue 会被忽略且自动关闭。
+          required: true

.github/labeler.yml

@@ -0,0 +1,88 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+# 
+#      http://www.apache.org/licenses/LICENSE-2.0
+# 
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# Pull Request Labeler Github Action Configuration: https://github.com/marketplace/actions/labeler
+
+build:
+  - .github/**/*
+  - .idea/**/*
+  - tools/**/*
+  - .gitignore
+  - azure-pipelines.yml
+  - pom.xml
+docs:
+  - docs/**/*
+  - README.md
+cli:
+  - flink-cdc-cli/**/*
+common:
+  - flink-cdc-common/**/*
+composer:
+  - flink-cdc-composer/**/*
+dist:
+  - flink-cdc-dist/**/*
+runtime:
+  - flink-cdc-runtime/**/*
+e2e-tests:
+  - flink-cdc-e2e-tests/**/*
+migration-tests:
+  - flink-cdc-migration-tests/**/*
+base:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/**/*
+debezium:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-debezium/**/*
+connector-test-util:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-test-util/**/*
+db2-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-db2-cdc/**/*
+mongodb-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/**/*
+mysql-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/**/*
+oceanbase-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/**/*
+oracle-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/**/*
+postgres-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/**/*
+sqlserver-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/**/*
+tidb-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/**/*
+vitess-cdc-connector:
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/**/*
+  - flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-vitess-cdc/**/*
+values-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/**/*
+mysql-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/**/*
+paimon-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/**/*
+kafka-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/**/*
+doris-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/**/*
+starrocks-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/**/*
+elasticsearch-pipeline-connector:
+  - flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/**/*