[
https://issues.apache.org/jira/browse/FLINK-37532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-37532.
Resolution: Not A Problem
> Job recovery always starts from initialSavepointPath when JobManager H
lvyanquan commented on PR #3708:
URL: https://github.com/apache/flink-cdc/pull/3708#issuecomment-2746993395
Add please rebase to solve the conflicts.
--
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
aiwenmo commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2009513615
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouter.java:
##
@@ -95,4 +96,23 @@ private TableId resolveReplacement(
aiwenmo commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2009509031
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouter.java:
##
@@ -76,7 +77,7 @@ public List route(TableId sourceTable
aiwenmo commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2009509031
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouter.java:
##
@@ -76,7 +77,7 @@ public List route(TableId sourceTable
lvyanquan commented on PR #3957:
URL: https://github.com/apache/flink-cdc/pull/3957#issuecomment-2746968883
PTAL @leonardBang.
--
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
hejufang commented on PR #25837:
URL: https://github.com/apache/flink/pull/25837#issuecomment-2746773866
@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.
fsk119 merged PR #26323:
URL: https://github.com/apache/flink/pull/26323
--
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.apache
flinkbot commented on PR #26338:
URL: https://github.com/apache/flink/pull/26338#issuecomment-2746914354
## CI report:
* 1d19be629ec14ee2a6bed28aa33a8c0bd3b68329 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lvyanquan commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2009421299
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouter.java:
##
@@ -95,4 +96,23 @@ private TableId resolveReplacement
hejufang commented on PR #25837:
URL: https://github.com/apache/flink/pull/25837#issuecomment-2746233755
@fredia Thank you for your suggestions. I have updated the relevant
descriptions in the metrics.md document.
Additionally, I believe the overhead of serializing is quite low, as the
flinkbot commented on PR #26337:
URL: https://github.com/apache/flink/pull/26337#issuecomment-2746847407
## CI report:
* 23ee73365b4371447ef7a2175215ba6a40f0364e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
beliefer opened a new pull request, #26338:
URL: https://github.com/apache/flink/pull/26338
## What is the purpose of the change
This PR aims to short circuit judgment for create blob storage dir
According to
https://github.com/apache/flink/blob/df058589affe786f5dcbf253cd3769502c28
yuxiqian commented on code in PR #3957:
URL: https://github.com/apache/flink-cdc/pull/3957#discussion_r2009433702
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java
yuxiqian commented on PR #3965:
URL: https://github.com/apache/flink-cdc/pull/3965#issuecomment-2746843623
CI passed in my forked repo, mark it ready for review.
This PR is aimed at migration framework with minimal changes for
reviewability. More E2e test cases could be added later to
lvyanquan commented on code in PR #3957:
URL: https://github.com/apache/flink-cdc/pull/3957#discussion_r2009429769
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.jav
beliefer commented on PR #26334:
URL: https://github.com/apache/flink/pull/26334#issuecomment-2746715794
@xintongsong Thank you for your explanation. I will close this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
beliefer opened a new pull request, #26337:
URL: https://github.com/apache/flink/pull/26337
## What is the purpose of the change
This PR aims to rename `VoidBlobStore` to `NoOperationBlobStore`.
## Brief change log
Rename `VoidBlobStore` to `NoOperationBlobStore`.
AppleJunJiang commented on PR #3442:
URL: https://github.com/apache/flink-cdc/pull/3442#issuecomment-2746803586
为啥这么久了还没有合并？
--
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.
lvyanquan commented on PR #2705:
URL: https://github.com/apache/flink-cdc/pull/2705#issuecomment-2746801489
Met the same problem and it‘s indeed helpful.
Could @edmond-kk help to rebase to master?
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
lvyanquan commented on PR #3960:
URL: https://github.com/apache/flink-cdc/pull/3960#issuecomment-2746797888
PTAL @leonardBang.
--
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-37375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37375:
Issue Type: New Feature (was: Bug)
> Checkpoint supports the Operator to customize asynchronous s
[
https://issues.apache.org/jira/browse/FLINK-37375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937775#comment-17937775
]
Zakelly Lan commented on FLINK-37375:
-
[~hejufang001] But it still required to be fi
loserwang1024 commented on PR #3874:
URL: https://github.com/apache/flink-cdc/pull/3874#issuecomment-2746720174
This idea looks good to me, which will help imporve a lot. I have some
advice:
1. we can do this before add stream split. When adding stream split, we can
do what
org.apache.f
beliefer closed pull request #26334: [FLINK-37531] Respect the design of chain
programming for RpcServiceBuilder
URL: https://github.com/apache/flink/pull/26334
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
beliefer opened a new pull request, #26334:
URL: https://github.com/apache/flink/pull/26334
## What is the purpose of the change
This PR aims to respect the design of chain programming for
`RpcServiceBuilder`.
According to the design of `RpcServiceBuilder`, the implementation shoul
beliefer commented on PR #26319:
URL: https://github.com/apache/flink/pull/26319#issuecomment-2746720571
> Probably I missed something however can you please describe what is the
issue here and how we could check that it is gone after this commit?
It's obviously. I have added the desc
lvyanquan commented on PR #3960:
URL: https://github.com/apache/flink-cdc/pull/3960#issuecomment-2746679194
> Seems `DataSinkWriterOperator` does not manipulate data change events in
BinaryRecordData level. Will printing corresponding TableId suffice?
Yeah, corresponding TableId and S
linqigeng created FLINK-37537:
-
Summary: Duplicate key when job failover in SchemaOperator
Key: FLINK-37537
URL: https://issues.apache.org/jira/browse/FLINK-37537
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-37532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937764#comment-17937764
]
Jun He commented on FLINK-37532:
[~gyfora] Thanks for your reply. I'll enable JM HA.
>
fsk119 merged PR #26324:
URL: https://github.com/apache/flink/pull/26324
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936990#comment-17936990
]
Shengkai Fang edited comment on FLINK-37222 at 3/24/25 1:23 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-37222.
-
Resolution: Fixed
> Table planner exception when sql client submit job
> ---
hejufang commented on code in PR #25837:
URL: https://github.com/apache/flink/pull/25837#discussion_r2009127739
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingMapState.java:
##
@@ -33,133 +37,223 @@
* @param Type of the user entry key of
lvyanquan commented on code in PR #3960:
URL: https://github.com/apache/flink-cdc/pull/3960#discussion_r2009049446
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java:
##
@@ -274,6 +275,28 @@ public void close() throws Ex
Efrat19 commented on PR #26320:
URL: https://github.com/apache/flink/pull/26320#issuecomment-2746105572
@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 specifi
lvyanquan commented on PR #3960:
URL: https://github.com/apache/flink-cdc/pull/3960#issuecomment-2746102551
What's more, could we add same optimization in
DataSinkWriterOperator#processElement method？
--
This is an automated message from the Apache Git Service.
To respond to the message,
37 matches
Mail list logo
