monologuist commented on PR #3575:
URL: https://github.com/apache/flink-cdc/pull/3575#issuecomment-2311755677
@yuxiqian Hello, I would like to know which Flink CDC version your document
corresponds to. I only seem to see three schema change Behaviors in Flink CDC
3.0.1.
--
This is an aut
leonardBang commented on PR #3577:
URL: https://github.com/apache/flink-cdc/pull/3577#issuecomment-2311762537
@loserwang1024 Would you like to review this PR when you have time ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
yuxiqian commented on PR #3575:
URL: https://github.com/apache/flink-cdc/pull/3575#issuecomment-2311766702
Hi @monologuist, this PR reflects current `master` situation
(`release-3.3-SNAPSHOT`). Will backport it to previous release branches later.
--
This is an automated message from the A
leonardBang merged PR #3570:
URL: https://github.com/apache/flink-cdc/pull/3570
--
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
[
https://issues.apache.org/jira/browse/FLINK-36148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36148.
Resolution: Fixed
fixed in master: 3c1517f70f728e1ef8a4b6bed942d87d66d874df
> Support parsing DDL
ruanhang1993 commented on code in PR #3573:
URL: https://github.com/apache/flink-cdc/pull/3573#discussion_r1732312221
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/Selectors.java:
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-36133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-36133:
--
Parent: FLINK-33748
Issue Type: Sub-task (was: Technical Debt)
> Remove subclass implementati
leonardBang commented on code in PR #3577:
URL: https://github.com/apache/flink-cdc/pull/3577#discussion_r1732395696
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistry.java:
##
@@ -113,18 +119,27 @@ public class SchemaRegi
[
https://issues.apache.org/jira/browse/FLINK-36066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36066:
---
Assignee: Lei Yang
> Introducing the AdaptiveGraphGenerator component
> ---
[
https://issues.apache.org/jira/browse/FLINK-36033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36033:
---
Assignee: Junrui Li
> FLIP-469: Supports Adaptive Optimization of StreamGraph
> ---
[
https://issues.apache.org/jira/browse/FLINK-36032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-36032:
---
Assignee: Junrui Li
> FLIP-468: Introducing StreamGraph-Based Job Submission
>
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2311939034
> Caused by: org.rocksdb.RocksDBException: `/dev/null' exists but is not a
directory
This is because when run e2e test, the directory of rocksdb log will be
specified as` /d
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2311939990
@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
xingbe created FLINK-36159:
--
Summary: FLIP-470: Support Adaptive Broadcast Join
Key: FLINK-36159
URL: https://issues.apache.org/jira/browse/FLINK-36159
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-36159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xingbe updated FLINK-36159:
---
Description: This is the umbrella ticket for FLIP-470
https://cwiki.apache.org/confluence/display/FLINK/FLIP
pnowojski commented on code in PR #25235:
URL: https://github.com/apache/flink/pull/25235#discussion_r1732443462
##
docs/content/docs/deployment/filesystems/s3.md:
##
@@ -164,4 +164,38 @@ The `s3.entropy.key` defines the string in paths that is
replaced by the random
If a file
pnowojski commented on PR #25235:
URL: https://github.com/apache/flink/pull/25235#issuecomment-2311981366
> And I guess we also need to update zh version?
Yep, I wanted to wait until the english version is mostly done/approved, in
order to avoid copy pasting fixups.
--
This is an a
ferenc-csaky commented on PR #25231:
URL: https://github.com/apache/flink/pull/25231#issuecomment-2312059662
Thanks for the fix @gaborgsomogyi!
As I tried to understand the problem we have here, I checked the history of
what happened here before and why. The previous change that was m
leosanqing commented on PR #109:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/109#issuecomment-2312079949
@schulzp @alpinegizmo @aljoscha @rmetzger Has any body to review my code?
thk ❤️❤️
--
This is an automated message from the Apache Git Service.
To respond to th
Zakelly commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1732498188
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptorUtils.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
pnowojski commented on code in PR #25245:
URL: https://github.com/apache/flink/pull/25245#discussion_r1732604961
##
pom.xml:
##
@@ -2355,8 +2355,6 @@ under the License.
@org.apache.flink.annotation.Experimental
pnowojski commented on PR #25245:
URL: https://github.com/apache/flink/pull/25245#issuecomment-2312186890
Thanks @rkhachatryan for looking into this. Let's try without reverting.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
pnowojski commented on PR #25246:
URL: https://github.com/apache/flink/pull/25246#issuecomment-2312192390
Thanks @rkhachatryan for looking into this. Let's try without reverting.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-36063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-36063.
---
Fix Version/s: 2.0.0
Resolution: Fixed
master: 51f1684be0214a1a8c47ffb4ae20b6ebf6f0fc0c
> Migrate St
zhuzhurk closed pull request #25219: [FLINK-36063][runtime] Migrate StreamGraph
and its related classes from flink-streaming-java to flink-runtime.
URL: https://github.com/apache/flink/pull/25219
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Zakelly commented on code in PR #25192:
URL: https://github.com/apache/flink/pull/25192#discussion_r1732616249
##
flink-runtime-web/src/test/resources/rest_api_v1.snapshot:
##
@@ -4190,4 +4190,4 @@
}
}
} ]
-}
Review Comment:
Ah, it's better to revert this chan
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2312392245
@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
spena commented on code in PR #25247:
URL: https://github.com/apache/flink/pull/25247#discussion_r1732752338
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableAsUtil.java:
##
@@ -63,9 +79,90 @@ public class MergeTableAsUtil {
gaborgsomogyi commented on code in PR #25231:
URL: https://github.com/apache/flink/pull/25231#discussion_r1732792672
##
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java:
##
@@ -129,10 +129,9 @@ public void
gaborgsomogyi commented on code in PR #25231:
URL: https://github.com/apache/flink/pull/25231#discussion_r1732814002
##
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java:
##
@@ -129,10 +129,9 @@ public void
leonardBang commented on PR #3566:
URL: https://github.com/apache/flink-cdc/pull/3566#issuecomment-2312518458
Thanks @yuxiqian for the backport, all CI passed, I'll organize the commits
and merge it soon.
--
This is an automated message from the Apache Git Service.
To respond to the messa
zhuanshenbsj1 created FLINK-36160:
-
Summary: Support hive advanced configuration
Key: FLINK-36160
URL: https://issues.apache.org/jira/browse/FLINK-36160
Project: Flink
Issue Type: Improvement
zhuanshenbsj1 opened a new pull request, #25258:
URL: https://github.com/apache/flink/pull/25258
## 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 t
Wolff Bock von Wuelfingen created FLINK-36161:
-
Summary: Integration Test Example uses deprecated SinkFunction
Key: FLINK-36161
URL: https://issues.apache.org/jira/browse/FLINK-36161
Projec
flinkbot commented on PR #25258:
URL: https://github.com/apache/flink/pull/25258#issuecomment-2312648935
## CI report:
* 65a84f3a32e91294c6227f460c6ce97bc0d73868 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr merged PR #25247:
URL: https://github.com/apache/flink/pull/25247
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-35708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35708.
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: c1fa29ac91aeef64701d8d97b13644a4267
twalthr merged PR #25238:
URL: https://github.com/apache/flink/pull/25238
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-35790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35790.
Fix Version/s: 2.0.0
Assignee: Sergio Peña
Resolution: Fixed
Fixed in master: 8c11
gyfora opened a new pull request, #873:
URL: https://github.com/apache/flink-kubernetes-operator/pull/873
## What is the purpose of the change
Rename JobSpec.flinkStateSnapshotReference to JobSpec.initialState. This
should make less verbose and easier to memorize for users.
fl
gyfora commented on PR #870:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/870#issuecomment-2312765821
I have opened a new PR with the further shortened `initialState` version
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
GOODBOY008 commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1733042779
##
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java:
##
@@ -76,14 +76,14 @@
* Long values
gyfora commented on PR #873:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/873#issuecomment-2312807325
Actually @tweise @mateczagany , I have a slight concern about this
initialState reference field overall. It may make sense to simply keep the
current `initialSavepointPath
Gyula Fora created FLINK-36162:
--
Summary: Remove flinkStateSnapshotReference and namespace from
FlinkStateSnapshot jobReference
Key: FLINK-36162
URL: https://issues.apache.org/jira/browse/FLINK-36162
Pro
gyfora closed pull request #873: [FLINK-36145] Rename
flinkStateSnapshotReference to initialState
URL: https://github.com/apache/flink-kubernetes-operator/pull/873
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
[
https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877085#comment-17877085
]
Gyula Fora commented on FLINK-36145:
I will probably close this in favour of
https:
[
https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877086#comment-17877086
]
Gyula Fora commented on FLINK-36162:
cc [~thw]
> Remove flinkStateSnapshotReferenc
[
https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36150:
---
Issue Type: Bug (was: Improvement)
> tables.exclude is not valid if scan.binlog.newly-added-table.e
[
https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36150:
--
Assignee: Hongshun Wang
> tables.exclude is not valid if scan.binlog.newly-added-table.enable
leonardBang merged PR #3573:
URL: https://github.com/apache/flink-cdc/pull/3573
--
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
leonardBang merged PR #3577:
URL: https://github.com/apache/flink-cdc/pull/3577
--
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
[
https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36150.
Resolution: Fixed
master: afe9c3c0adb77594565b24c004daa6385d50d5fc
3.2: todo
> tables.exclude is
leonardBang merged PR #3566:
URL: https://github.com/apache/flink-cdc/pull/3566
--
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
leonardBang commented on PR #3568:
URL: https://github.com/apache/flink-cdc/pull/3568#issuecomment-2313070670
Thanks @leosanqing for the contribution, could you also check other
connectors? I think some start up mode of debezium should not pass to
underlying debeziunm engine once the Flink
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Fix Version/s: cdc-3.3.0
> The in-flight data will meet unrecoverable issue when restore from checkp
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36128.
Resolution: Fixed
master: 2e938a92f5335515f7eb46077254aee25acd9107
release-3.2: debd43cdd75eb53ce
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35056.
Resolution: Fixed
> when initial sqlserver table that's primary key is datetime type, it
> org.a
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876041#comment-17876041
]
Leonard Xu edited comment on FLINK-35056 at 8/27/24 4:56 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875816#comment-17875816
]
Leonard Xu edited comment on FLINK-36114 at 8/27/24 4:58 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875826#comment-17875826
]
Leonard Xu edited comment on FLINK-36092 at 8/27/24 4:57 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36081:
---
Fix Version/s: cdc-3.2.0
> Flink CDC MySQL source connector missing some columns data of newly added
[
https://issues.apache.org/jira/browse/FLINK-36094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36094.
Resolution: Fixed
fixed master: 6205a5a0f16d2cf72ff751573351c4e15ea59efb
release-3.2: 5a80757443e
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875326#comment-17875326
]
Leonard Xu edited comment on FLINK-36081 at 8/27/24 5:00 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874938#comment-17874938
]
Leonard Xu edited comment on FLINK-36088 at 8/27/24 5:01 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874940#comment-17874940
]
Leonard Xu edited comment on FLINK-36076 at 8/27/24 5:01 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36088.
Resolution: Fixed
> Fix NPE in PaimonDataSink.
> --
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36076.
Resolution: Fixed
> Hotfix: Set isSchemaChangeApplying as volatile for thread safe.
>
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36082.
Resolution: Fixed
> Fix NotSerializableException for KafkaDataSink
> -
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874876#comment-17874876
]
Leonard Xu edited comment on FLINK-36082 at 8/27/24 5:02 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36056.
Resolution: Fixed
fixed in master(3.2-SNAPSHOT): ab64eb3b574ebbeb81cf6b6500acbd211eea39ab
> chang
zakhalex commented on PR #3445:
URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2313494810
@ChengJie1053 - do you have the privilege to approve the workflows?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877194#comment-17877194
]
Thomas Weise commented on FLINK-36162:
--
[~gyfora] I was surprised when you closed y
klam-shop commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-kafka/pull/109#discussion_r1733569499
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java:
##
@@ -188,6 +188,120 @@ public void test
klam-shop commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-kafka/pull/109#discussion_r1733569499
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java:
##
@@ -188,6 +188,120 @@ public void test
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-2313665000
@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 comm
github-actions[bot] commented on PR #3440:
URL: https://github.com/apache/flink-cdc/pull/3440#issuecomment-2313776551
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
[
https://issues.apache.org/jira/browse/FLINK-35718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35718:
---
Labels: pull-request-available (was: )
> Cherrypick DBZ-5333 to fix frequently failover by
github-actions[bot] commented on PR #3286:
URL: https://github.com/apache/flink-cdc/pull/3286#issuecomment-2313776592
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
yuxiqian commented on code in PR #3578:
URL: https://github.com/apache/flink-cdc/pull/3578#discussion_r1733730877
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java:
##
@@ -719,6 +718,11 @@ public void testMe
ChengJie1053 commented on PR #3445:
URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2313885858
> @ChengJie1053 - do you have the privilege to approve the workflows?
I'm sorry. I don't have that clearance
--
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/FLINK-35917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-35917:
-
Description: Caused by: java.lang.RuntimeException: One or more fetchers
have encountered exception at
leonardBang commented on code in PR #3578:
URL: https://github.com/apache/flink-cdc/pull/3578#discussion_r1733762640
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java:
##
@@ -719,6 +718,11 @@ public void tes
[
https://issues.apache.org/jira/browse/FLINK-35917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-35917:
-
Description:
it occurred during the full to incremental phase:
Caused by: java.lang.RuntimeException: O
cobolbaby commented on PR #3433:
URL: https://github.com/apache/flink-cdc/pull/3433#issuecomment-2313956284
Does it only support jdbc-mysql? Can the jdbc be extended to a general sink
connector?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35599:
---
Labels: pull-request-available (was: )
> Add JDBC Sink Plugin to Flink-CDC-Pipeline
> -
GOODBOY008 merged PR #24692:
URL: https://github.com/apache/flink/pull/24692
--
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.ap
GOODBOY008 commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2314045037
@morozov LGTM
--
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
[
https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong resolved FLINK-35177.
-
Fix Version/s: 2.0.0
Resolution: Fixed
Merged to branch: Master , Via : bc3afba5c
GOODBOY008 commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2314102983
@morozov Can you open another pr to branch `release-1.20` ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Hongshun Wang created FLINK-36163:
-
Summary: Kafka cdc pipeline source supports protobuf format.
Key: FLINK-36163
URL: https://issues.apache.org/jira/browse/FLINK-36163
Project: Flink
Issue T
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2314121275
@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
tchivs created FLINK-36164:
--
Summary: JdbcIncrementalSource CheckPoint Timeout Due to
Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned
PostgreSQL Table
Key: FLINK-36164
URL: https://issues.apach
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
When synchronizing a PostgreSQL table using a connector, if the table contains
a large number
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
What's Wrong?
When synchronizing a PostgreSQL table using a connector, if the table contains
a
morozov opened a new pull request, #25259:
URL: https://github.com/apache/flink/pull/25259
This is a backport of https://github.com/apache/flink/pull/24692.
--
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
morozov commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2314127171
@GOODBOY008, please see https://github.com/apache/flink/pull/25259.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
What's Wrong?
When synchronizing a PostgreSQL table using a connector, if the table contains
a
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Attachment: image-2024-08-28-11-28-33-016.png
> JdbcIncrementalSource CheckPoint Timeout Due to Retrieving S
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Attachment: image-2024-08-28-11-28-21-496.png
> JdbcIncrementalSource CheckPoint Timeout Due to Retrieving S
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
What's Wrong?
When synchronizing a PostgreSQL table using a connector, if the table contains
a
1 - 100 of 118 matches
Mail list logo
