[
https://issues.apache.org/jira/browse/FLINK-37001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913987#comment-17913987
]
dalongliu commented on FLINK-37001:
---
Merged in master branch: 6b4385ec17e7ac832d22f048
[
https://issues.apache.org/jira/browse/FLINK-37001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-37001.
---
Assignee: xuyang
Resolution: Fixed
> Remove all direct uses of
> `TableEnvironmentInternal#re
lsyldliu merged PR #25889:
URL: https://github.com/apache/flink/pull/25889
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
hackergin commented on code in PR #25988:
URL: https://github.com/apache/flink/pull/25988#discussion_r1919690980
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/materializedtable/MaterializedTableManager.java:
##
@@ -1244,4 +1278,99 @@ priva
[
https://issues.apache.org/jira/browse/FLINK-37162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-37162:
---
Summary: Add Data Sink Documentation (was: Add Data Sources Documentation)
> Add Data Sink Document
Yanquan Lv created FLINK-37162:
--
Summary: Add Data Sources Documentation
Key: FLINK-37162
URL: https://issues.apache.org/jira/browse/FLINK-37162
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-37162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-37162:
---
Labels: 2.0-related (was: )
> Add Data Sources Documentation
> --
>
>
flinkbot commented on PR #26000:
URL: https://github.com/apache/flink/pull/26000#issuecomment-2597619865
## CI report:
* 42d79c108d797a351c2fc83f41bf0fca5935e3bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys merged PR #25952:
URL: https://github.com/apache/flink/pull/25952
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
suez1224 commented on PR #25965:
URL: https://github.com/apache/flink/pull/25965#issuecomment-2597601633
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
suez1224 commented on PR #25965:
URL: https://github.com/apache/flink/pull/25965#issuecomment-2597571178
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
sn-12-3 commented on PR #25528:
URL: https://github.com/apache/flink/pull/25528#issuecomment-2597571101
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-37136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37136:
---
Labels: pull-request-available (was: )
> FLIP-501: Support Window Extension in DataStream V
codenohup opened a new pull request, #26001:
URL: https://github.com/apache/flink/pull/26001
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-37160:
---
Description:
This is for cross-team verification of the release 2.0 work item: "Adaptive
broadcast
[
https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-37161:
---
Description:
This is for cross-team verification of the release 2.0 work item: "Adaptive
skewed joi
Junrui Lee created FLINK-37161:
--
Summary: Cross-team verification for "Adaptive skewed join
optimization for batch jobs"
Key: FLINK-37161
URL: https://issues.apache.org/jira/browse/FLINK-37161
Project: F
Junrui Lee created FLINK-37160:
--
Summary: Cross-team verification for "Adaptive broadcast join for
batch jobs"
Key: FLINK-37160
URL: https://issues.apache.org/jira/browse/FLINK-37160
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37113:
---
Summary: Introduce documentation for datastream api v2 (was: Introduce
document for datastream api
sn-12-3 commented on PR #25528:
URL: https://github.com/apache/flink/pull/25528#issuecomment-2597508920
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
Weijie Guo created FLINK-37159:
--
Summary:
MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing
timeout in AZP
Key: FLINK-37159
URL: https://issues.apache.org/jira/browse/FLINK-37159
Jiabao-Sun commented on PR #43:
URL:
https://github.com/apache/flink-connector-mongodb/pull/43#issuecomment-2597485624
Thanks @GOODBOY008 for the review.
Docs added, could you help review it again?
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-37158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37158:
---
Labels: pull-request-available (was: )
> Introduce ForSt to existing ITCases
>
fredia opened a new pull request, #26000:
URL: https://github.com/apache/flink/pull/26000
## What is the purpose of the change
Introduce ForSt to existing IT Cases.
## Brief change log
- Enable Async State in `OneInputTransformation`
- Introduce forst to `A
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913966#comment-17913966
]
Vinh Pham commented on FLINK-35093:
---
hi [~loserwang1024] , i have a thought about this
Yanfei Lei created FLINK-37158:
--
Summary: Introduce ForSt to existing ITCases
Key: FLINK-37158
URL: https://issues.apache.org/jira/browse/FLINK-37158
Project: Flink
Issue Type: Sub-task
sn-12-3 commented on PR #25528:
URL: https://github.com/apache/flink/pull/25528#issuecomment-2597461441
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-36713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohsen Rezaei updated FLINK-36713:
--
Summary: NoSuchMethodError: PostgresConnection with
PostgresIncrementalSource at runtime (was
Zakelly closed pull request #23347: [FLINK-20886] Support printing the thread
dump when checkpoint expired
URL: https://github.com/apache/flink/pull/23347
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to g
Zakelly commented on code in PR #25899:
URL: https://github.com/apache/flink/pull/25899#discussion_r191955
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java:
##
@@ -283,6 +293,39 @@ public String toString() {
fa
Zakelly closed pull request #23138: [FLINK-32753] Print JVM flags on AZP
URL: https://github.com/apache/flink/pull/23138
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsu
lvyanquan commented on PR #3856:
URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2597402903
> I missed this issue #3704, good idea. Maybe support `AssignStrategy` in
base module is better? Do we implement this in a future PR or in this PR?
My previous PR provided both
[
https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35234:
--
Fix Version/s: cdc-3.2.0
(was: cdc-3.3.1)
> Fix NullPointerException of
> org.
[
https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-35234.
---
Resolution: Fixed
> Fix NullPointerException of
> org.apache.flink.cdc.common.configuration.Configu
[
https://issues.apache.org/jira/browse/FLINK-35234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35234:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Fix NullPointerException of
> org.
[
https://issues.apache.org/jira/browse/FLINK-35684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35684:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.1)
> Add missing option for DataSource a
[
https://issues.apache.org/jira/browse/FLINK-35589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35589:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Support MemorySize type in FlinkCDC
[
https://issues.apache.org/jira/browse/FLINK-35684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35684:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Add missing option for DataSource a
[
https://issues.apache.org/jira/browse/FLINK-35718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35718:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Cherrypick DBZ-5333 to fix frequent
[
https://issues.apache.org/jira/browse/FLINK-35888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35888:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Add e2e test for paimon DataSink
>
[
https://issues.apache.org/jira/browse/FLINK-36827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36827:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> [Docs] Tidy up Flink CDC Doris/MySQ
[
https://issues.apache.org/jira/browse/FLINK-35834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35834:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Update Doris Dependency to 1.6.2 to
[
https://issues.apache.org/jira/browse/FLINK-35444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35444:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Paimon Pipeline Connector support c
[
https://issues.apache.org/jira/browse/FLINK-35349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35349:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Use connection in openJdbcConnectio
[
https://issues.apache.org/jira/browse/FLINK-36111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36111:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> fix: adjust MultiTableCommittableCh
[
https://issues.apache.org/jira/browse/FLINK-36218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36218:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Documentations clean up before CDC
[
https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35919:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> The rowkind keyword option for MySQ
[
https://issues.apache.org/jira/browse/FLINK-36220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36220:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Clean up typo and stale links in do
[
https://issues.apache.org/jira/browse/FLINK-35627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35627:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Avoid conflict when pipeline job th
[
https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34750:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "legacy-flink-cdc-sources" Page of
[
https://issues.apache.org/jira/browse/FLINK-35090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35090:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Doris sink fails to create table wh
[
https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34904:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> [Feature] submit Flink CDC pipeline
[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34752:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "legacy-flink-cdc-sources" Page of
[
https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34749:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "legacy-flink-cdc-sources" Page of
[
https://issues.apache.org/jira/browse/FLINK-36708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36708:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Optimize Table Collection Handling
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913945#comment-17913945
]
Shuai Xu commented on FLINK-36167:
--
I would like try to fix it. Could you assign it to
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913945#comment-17913945
]
Shuai Xu edited comment on FLINK-36167 at 1/17/25 3:57 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-35873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35873:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Add HashFunctionProvider for Paimon
[
https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34735:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "Developer Guide - Understanding Fl
[
https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34747:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "legacy-flink-cdc-sources" Page of
[
https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34736:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "Deployment - Standalone" Page for
[
https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34748:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> "legacy-flink-cdc-sources" Page of
[
https://issues.apache.org/jira/browse/FLINK-36566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36566:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Code optimization: always identify
[
https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35544:
--
Fix Version/s: cdc-3.3.0
(was: cdc-3.3.1)
> No description of Flink Operator in
[
https://issues.apache.org/jira/browse/FLINK-36263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36263:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Include only changed columns in old
[
https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-35544.
---
Resolution: Fixed
> No description of Flink Operator in the Deployment of Kubernetes document
> ---
[
https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34730:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.1)
> Translate pages of Flink CDC docs t
[
https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34730:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Translate pages of Flink CDC docs t
[
https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35544:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> No description of Flink Operator in
[
https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36023:
--
Fix Version/s: cdc-3.2.0
(was: cdc-3.4.0)
> Flink CDC K8S Native Application Mo
[
https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-36023.
---
Resolution: Fixed
master(3.2-SNAOSHOT):5284df571feb91354248bf0ffac184b89d9db30c
> Flink CDC K8S Nat
[
https://issues.apache.org/jira/browse/FLINK-36023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36023:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Flink CDC K8S Native Application Mo
[
https://issues.apache.org/jira/browse/FLINK-36219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36219:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Add Flink compatibility matrix of C
beryllw commented on PR #3856:
URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2597376945
> What‘s more, could you add this optimization to `MongoDBChunkSplitter`?
https://github.com/apache/flink-cdc/pull/3704#discussion_r1864686969
I missed this issue https://gi
[
https://issues.apache.org/jira/browse/FLINK-36573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36573:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
(was: cdc-3.2.1
[
https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34467:
--
Fix Version/s: (was: cdc-3.3.0)
> Implement Lineage Interface in Jdbc Connector
>
[
https://issues.apache.org/jira/browse/FLINK-35849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35849:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> [flink-cdc] Use expose_snapshot to
[
https://issues.apache.org/jira/browse/FLINK-36041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36041:
--
Issue Type: Improvement (was: Technical Debt)
> Eliminate Calcite dependency during runtime
> ---
[
https://issues.apache.org/jira/browse/FLINK-36844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36844:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Postgres CDC document add mapping f
[
https://issues.apache.org/jira/browse/FLINK-36041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36041:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Eliminate Calcite dependency during
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36546:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Handle batch sources in DataSinkTra
[
https://issues.apache.org/jira/browse/FLINK-35671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35671:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Support Iceberg CDC Pipeline Sink
>
[
https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35173:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.1.0)
(was: cdc-3.3.0
[
https://issues.apache.org/jira/browse/FLINK-35760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35760:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> [docs] Add scan.newly-added-table.e
[
https://issues.apache.org/jira/browse/FLINK-35693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35693:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Change variable specificOffsetFile,
[
https://issues.apache.org/jira/browse/FLINK-36036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36036:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> CDC remove unused dependency jar fr
[
https://issues.apache.org/jira/browse/FLINK-36036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36036:
--
Issue Type: Technical Debt (was: Improvement)
> CDC remove unused dependency jar from calcite-core
>
[
https://issues.apache.org/jira/browse/FLINK-36163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36163:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Kafka cdc pipeline source supports
[
https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35664:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Flink CDC pipeline transform suppor
[
https://issues.apache.org/jira/browse/FLINK-35586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35586:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Detected conflict when using Paimon
[
https://issues.apache.org/jira/browse/FLINK-35586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35586:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.1)
> Detected conflict when using Paimon
[
https://issues.apache.org/jira/browse/FLINK-35567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35567:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> CDC BinaryWriter cast NullableSeria
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-35344.
---
Resolution: Fixed
master(3.3-SNAOSHT) :47f5660055016460719bc8a9a72cee868e9aa6fe
> Move same code fr
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35344:
--
Issue Type: Technical Debt (was: Improvement)
> Move same code from multiple subclasses to JdbcSource
hackergin commented on code in PR #25988:
URL: https://github.com/apache/flink/pull/25988#discussion_r1919510180
##
flink-end-to-end-tests/test-scripts/test_kubernetes_materialized_table.sh:
##
@@ -0,0 +1,242 @@
+#!/usr/bin/env bash
+#
+# Licensed to the Apache Software Foundati
[
https://issues.apache.org/jira/browse/FLINK-35459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35459:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Use Incremental Source Framework in
[
https://issues.apache.org/jira/browse/FLINK-35450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35450:
--
Fix Version/s: cdc-3.4.0
(was: cdc-3.3.0)
> Introduce Tikv pipeline DataSource
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35344:
--
Fix Version/s: cdc-3.3.0
(was: cdc-3.3.1)
> Move same code from multiple subcla
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35344:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Move same code from multiple subcla
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35296:
--
Fix Version/s: cdc-3.3.1
(was: cdc-3.3.0)
> Flink mysql-cdc connector stops rea
1 - 100 of 522 matches
Mail list logo
