[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872204#comment-17872204
]
Zakelly Lan commented on FLINK-34510:
-
[~spoon-lz] Thanks for your volunteering! Alr
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-34510:
---
Assignee: liuzhuo
> Flink 2.0: Rename RestoreMode to RecoveryClaimMode
> --
[
https://issues.apache.org/jira/browse/FLINK-36020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siyuan zheng updated FLINK-36020:
-
Description:
Running a Flink job on YARN, setting
'taskmanager.network.memory.buffer-debloat.pe
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872199#comment-17872199
]
liuzhuo commented on FLINK-34510:
-
[~zakelly] Could you please assign this issue to me？
[
https://issues.apache.org/jira/browse/FLINK-36020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siyuan zheng updated FLINK-36020:
-
Summary: An exception occurred when enabling the buffer debloating
mechanism: Time should be no
[
https://issues.apache.org/jira/browse/FLINK-36020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siyuan zheng updated FLINK-36020:
-
Summary: when enable buffer debloating mechanism got a exception: Time
should be non negative
[
https://issues.apache.org/jira/browse/FLINK-36020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siyuan zheng updated FLINK-36020:
-
Summary: exception: Time should be non negative when enable buffer
debloating mechanism (was: e
[
https://issues.apache.org/jira/browse/FLINK-35615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872198#comment-17872198
]
yux commented on FLINK-35615:
-
This has been resolved in https://github.com/apache/flink-cdc
[
https://issues.apache.org/jira/browse/FLINK-35715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-35715.
---
Resolution: Fixed
fix via(3.2-SNAPSHOT):07446d1f9de23b6d5e7b50de1b00ba901ffd31db
> Mysql Source sup
[
https://issues.apache.org/jira/browse/FLINK-36020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siyuan zheng updated FLINK-36020:
-
Description:
Running a Flink job on YARN, setting
'taskmanager.network.memory.buffer-debloat.pe
ruanhang1993 merged PR #3511:
URL: https://github.com/apache/flink-cdc/pull/3511
--
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...@flin
[
https://issues.apache.org/jira/browse/FLINK-36020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
siyuan zheng updated FLINK-36020:
-
Description:
Running a Flink job on YARN, setting
'taskmanager.network.memory.buffer-debloat.pe
siyuan zheng created FLINK-36020:
Summary: exception: Time should be non negative
Key: FLINK-36020
URL: https://issues.apache.org/jira/browse/FLINK-36020
Project: Flink
Issue Type: Bug
yanggang created FLINK-36019:
Summary: flink_ha目录下的文件，可以通过配置自定义权限
Key: FLINK-36019
URL: https://issues.apache.org/jira/browse/FLINK-36019
Project: Flink
Issue Type: New Feature
Affects Versio
[
https://issues.apache.org/jira/browse/FLINK-35774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872193#comment-17872193
]
yux commented on FLINK-35774:
-
Resolved by https://github.com/apache/flink-cdc/pull/3285.
>
[
https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872192#comment-17872192
]
yux commented on FLINK-35852:
-
Resolved in https://github.com/apache/flink-cdc/pull/3285.
>
[
https://issues.apache.org/jira/browse/FLINK-35012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872188#comment-17872188
]
Weijie Guo commented on FLINK-35012:
https://dev.azure.com/apache-flink/apache-flink
qg-lin commented on PR #3482:
URL: https://github.com/apache/flink-cdc/pull/3482#issuecomment-2277193856
> fix paimon
> Expose newly added tables capture in mysql pipeline connec
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872185#comment-17872185
]
Ruan Hang commented on FLINK-35143:
---
fix via master(3.2-SNAPSHOT): 09f36a4a05797b7e319
ruanhang1993 merged PR #3411:
URL: https://github.com/apache/flink-cdc/pull/3411
--
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...@flin
melin commented on PR #3482:
URL: https://github.com/apache/flink-cdc/pull/3482#issuecomment-2277162861
fix
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872182#comment-17872182
]
Rui Fan commented on FLINK-36018:
-
Hey [~gyfora] [~mxm] , would you mind checking whethe
reswqa commented on PR #25164:
URL: https://github.com/apache/flink/pull/25164#issuecomment-2277104649
Can you rebase?
--
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 un
Rui Fan created FLINK-36018:
---
Summary: Support lazy scale down to avoid frequent rescaling
Key: FLINK-36018
URL: https://issues.apache.org/jira/browse/FLINK-36018
Project: Flink
Issue Type: Improve
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2277077343
Rebased with `master` and resolved conflicts. cc @leonardBang @ruanhang1993
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
loserwang1024 commented on code in PR #3520:
URL: https://github.com/apache/flink-cdc/pull/3520#discussion_r1710612188
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java:
##
@@ -20,6 +20,7 @@
import org.apache.flink.cdc.common.ann
flinkbot commented on PR #25182:
URL: https://github.com/apache/flink/pull/25182#issuecomment-2277045070
## CI report:
* f5c2a6c7c1de6be79b54bb037b9f996be5843575 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35997:
---
Labels: pull-request-available (was: )
> Incomplete Table API & Python API of built-in func
dylanhz opened a new pull request, #25182:
URL: https://github.com/apache/flink/pull/25182
## What is the purpose of the change
Complete the Table API and Python API for LTRIM and RTRIM.
Examples:
```Java
str.ltrim(trimStr);
str.rtrim(trimStr);
```
## Brief ch
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872171#comment-17872171
]
Weijie Guo commented on FLINK-33555:
https://dev.azure.com/apache-flink/apache-flink
lincoln-lil commented on PR #25180:
URL: https://github.com/apache/flink/pull/25180#issuecomment-2277018182
@xuyangzhong you can rebase the latest branch to get e2e pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
lincoln-lil commented on PR #25179:
URL: https://github.com/apache/flink/pull/25179#issuecomment-2277018449
@xuyangzhong rebase the latest branch to get e2e pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-36007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reassigned FLINK-36007:
-
Assignee: Hongshun Wang
> cdc load and register factory in once search
> --
Jiabao-Sun merged PR #3506:
URL: https://github.com/apache/flink-cdc/pull/3506
--
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-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872169#comment-17872169
]
Weijie Guo commented on FLINK-35974:
1.20: 94c6903f44c0ab73c1316ccb8861a19b53a71651
[
https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35974:
---
Fix Version/s: 1.19.2
1.20.1
> PyFlink YARN per-job on Docker test failed because
loserwang1024 commented on code in PR #3519:
URL: https://github.com/apache/flink-cdc/pull/3519#discussion_r1710552773
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssign
reswqa merged PR #25177:
URL: https://github.com/apache/flink/pull/25177
--
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
reswqa merged PR #25178:
URL: https://github.com/apache/flink/pull/25178
--
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-35442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35442:
---
Labels: pull-request-available (was: )
> Kafka Pipeline Sink may distribute the same key to
lvyanquan opened a new pull request, #3522:
URL: https://github.com/apache/flink-cdc/pull/3522
To make sure the same record sending to the same partition after job
restarted.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
xuyangzhong commented on PR #25179:
URL: https://github.com/apache/flink/pull/25179#issuecomment-2276988449
@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 commen
xuyangzhong commented on PR #25180:
URL: https://github.com/apache/flink/pull/25180#issuecomment-2276987842
@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 commen
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-2276687135
@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
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-2276581946
@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
Kevin Lam created FLINK-36017:
-
Summary: Support Passing Metadata to Formats in KafkaDynamicSink
Key: FLINK-36017
URL: https://issues.apache.org/jira/browse/FLINK-36017
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-35944.
Fix Version/s: 2.0.0
Resolution: Fixed
master: f1eb644024df497738a4a40fba7c0ae29cf8
zentol merged PR #25170:
URL: https://github.com/apache/flink/pull/25170
--
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
angelachenn commented on PR #834:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/834#issuecomment-2276410434
hey @gyfora, thanks for checking in, and apologies for the lack of updates.
I had to shift my focus to some higher-priority tasks and have also been on
vacation. I do
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872084#comment-17872084
]
Xingcan Cui commented on FLINK-36004:
-
Please see the screenshot for an explanation.
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-36004:
Attachment: screenshot-1.png
> Flink SQL returns wrong results for Paimon tables with complex sche
VittoriDavide commented on PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2276295085
yes this PR will be super helpful for us as well 👀
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
gaborgsomogyi commented on PR #18664:
URL: https://github.com/apache/flink/pull/18664#issuecomment-2276215030
The token framework stores everything in-memory and it's not compatible with
`HADOOP_TOKEN_FILE_LOCATION`. Such case the new container will load the file
content with old tokens (YA
dpengpeng commented on PR #18664:
URL: https://github.com/apache/flink/pull/18664#issuecomment-2276162116
@gaborgsomogyi Hello, I am currently using Flink version 1.15.2 and have
encountered an issue with the HDFS delegation token expiring after 7 days in a
Kerberos scenario.
I have seen
[
https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35265.
--
Resolution: Fixed
> Implement FlinkStateSnapshot custom resource
> ---
[
https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-35265:
---
Fix Version/s: kubernetes-operator-1.10.0
> Implement FlinkStateSnapshot custom resource
> -
[
https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872060#comment-17872060
]
Gyula Fora commented on FLINK-35265:
merged to main:
0f390144cb8516d31aac61e46b9ce06
[
https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-35265:
--
Assignee: Mate Czagany
> Implement FlinkStateSnapshot custom resource
> -
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872058#comment-17872058
]
Xingcan Cui commented on FLINK-36004:
-
I narrowed down the scope a bit. In the table
aiwenmo closed pull request #3455: [FLINK-35774][cdc-runtime] Fix the cache of
transform is not updated after process schema change event
URL: https://github.com/apache/flink-cdc/pull/3455
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-36012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36012:
-
Assignee: Zdenek Tison
> Integrate StateTransitionManager into WaitingForResources stat
[
https://issues.apache.org/jira/browse/FLINK-36011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36011:
-
Assignee: Zdenek Tison
> Generalize RescaleManager to become StateTransitionManager
> -
gyfora merged PR #821:
URL: https://github.com/apache/flink-kubernetes-operator/pull/821
--
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
aiwenmo commented on PR #3455:
URL: https://github.com/apache/flink-cdc/pull/3455#issuecomment-2276030958
The issue has been fixed by https://github.com/apache/flink-cdc/pull/3285.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/FLINK-31534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-31534.
Fix Version/s: 2.0.0
Assignee: Sergio Peña
Resolution: Fixed
Fixed as part of FLIN
[
https://issues.apache.org/jira/browse/FLINK-31534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-31534:
-
Component/s: Table SQL / Planner
> CREATE TABLE AS SELECT should support to define primary key
>
[
https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-31533.
Fix Version/s: 2.0.0
Assignee: Sergio Peña
Resolution: Fixed
Fixed as part of FLIN
PatrickRen merged PR #3093:
URL: https://github.com/apache/flink-cdc/pull/3093
--
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.
Zdenek Tison created FLINK-36016:
Summary: Synchronize initialization time and clock usage
Key: FLINK-36016
URL: https://issues.apache.org/jira/browse/FLINK-36016
Project: Flink
Issue Type:
Zdenek Tison created FLINK-36015:
Summary: Align rescale parameters
Key: FLINK-36015
URL: https://issues.apache.org/jira/browse/FLINK-36015
Project: Flink
Issue Type: Sub-task
Compo
Zdenek Tison created FLINK-36014:
Summary: Align the desired and sufficient resources definiton in
Executing and WaitForResources states
Key: FLINK-36014
URL: https://issues.apache.org/jira/browse/FLINK-36014
Zdenek Tison created FLINK-36013:
Summary: Introduce the transition from Restarting to
CreatingExecutionGraph state
Key: FLINK-36013
URL: https://issues.apache.org/jira/browse/FLINK-36013
Project: Fli
yuxiqian commented on PR #3521:
URL: https://github.com/apache/flink-cdc/pull/3521#issuecomment-2275944544
Marked it as draft for now, need to add more tests to verify if table-level
schema change event works as expected.
--
This is an automated message from the Apache Git Service.
To res
twalthr commented on PR #25170:
URL: https://github.com/apache/flink/pull/25170#issuecomment-2275945382
@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-36010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy updated FLINK-36010:
Description:
h2. Description
Running a job on single execution mode with HA enabled typically [sh
Zdenek Tison created FLINK-36012:
Summary: Integrate StateTransitionManager into WaitingForResources
state
Key: FLINK-36012
URL: https://issues.apache.org/jira/browse/FLINK-36012
Project: Flink
Zdenek Tison created FLINK-36011:
Summary: Generalize RescaleManager to become StateTransitionManager
Key: FLINK-36011
URL: https://issues.apache.org/jira/browse/FLINK-36011
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-35941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-35941:
-
Component/s: Table SQL / Planner
> Add CompiledPlan annotations to BatchExecLimit
>
[
https://issues.apache.org/jira/browse/FLINK-35941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35941.
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: 8a45cd6cffb7ff55e0af6c1167b255d7da6
twalthr merged PR #25168:
URL: https://github.com/apache/flink/pull/25168
--
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-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872011#comment-17872011
]
Zdenek Tison commented on FLINK-35035:
--
This task will be used as a parent task for
[
https://issues.apache.org/jira/browse/FLINK-36010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy updated FLINK-36010:
Fix Version/s: 1.20.1
> Duplicate Job Submission returns Succeeded on single execution even if Glo
gaborgsomogyi commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1709562167
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactService.java:
##
@@ -173,4 +203,36 @@ priva
jnh5y commented on code in PR #25171:
URL: https://github.com/apache/flink/pull/25171#discussion_r1709560780
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/batch/MatchRecognizeBatchRestoreTest.java:
##
@@ -0,0 +1,46 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-35035:
-
Assignee: Zdenek Tison
> Reduce job pause time when cluster resources are expanded in a
Ahmed Hamdy created FLINK-36010:
---
Summary: Duplicate Job Submission returns Succeeded on single
execution even if Global state is FAILED
Key: FLINK-36010
URL: https://issues.apache.org/jira/browse/FLINK-36010
João Boto created FLINK-36009:
-
Summary: Change configs to use CondigOptions
Key: FLINK-36009
URL: https://issues.apache.org/jira/browse/FLINK-36009
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #25181:
URL: https://github.com/apache/flink/pull/25181#issuecomment-2275829536
## CI report:
* 34dc44d8843fc879e21ff3e3f8dc48f4927b676b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
leonardBang commented on code in PR #3519:
URL: https://github.com/apache/flink-cdc/pull/3519#discussion_r1709493160
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner
leonardBang commented on code in PR #3520:
URL: https://github.com/apache/flink-cdc/pull/3520#discussion_r1709483268
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java:
##
@@ -20,6 +20,7 @@
import org.apache.flink.cdc.common.annot
[
https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35859:
--
Assignee: Hongshun Wang
> [flink-cdc] Fix: The assigner is not ready to offer finished split
[
https://issues.apache.org/jira/browse/FLINK-35859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871996#comment-17871996
]
Leonard Xu commented on FLINK-35859:
Assigned to you [~loserwang1024] , thanks for t
[
https://issues.apache.org/jira/browse/FLINK-36008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871994#comment-17871994
]
Lorenzo Nicora commented on FLINK-36008:
I created a PR with the small change re
[
https://issues.apache.org/jira/browse/FLINK-36008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36008:
---
Labels: pull-request-available (was: )
> Guidance for previewing connector docs contributio
nicusX opened a new pull request, #25181:
URL: https://github.com/apache/flink/pull/25181
## What is the purpose of the change
* Improving the contributors' experience when modifying docs of an existing
connector or developing docs of a new connector.
## Brief change log
leonardBang closed pull request #3470: pipeline add param
scan.newly-added-table.enabled
URL: https://github.com/apache/flink-cdc/pull/3470
--
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 specif
leonardBang commented on PR #3470:
URL: https://github.com/apache/flink-cdc/pull/3470#issuecomment-2275774886
closed as duplicate with an earlier
https://github.com/apache/flink-cdc/pull/3411
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
1 - 100 of 168 matches
Mail list logo
