牛一凡 created FLINK-35875:
---
Summary: Flink cdc frequently encounters LabelAlreadyExists errors
Key: FLINK-35875
URL: https://issues.apache.org/jira/browse/FLINK-35875
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35844.
--
Resolution: Abandoned
> Build Release Candidate: 1.20.0-rc1
>
>
[
https://issues.apache.org/jira/browse/FLINK-35844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867958#comment-17867958
]
Weijie Guo commented on FLINK-35844:
1.20-rc1 was officially cancelled because of th
[
https://issues.apache.org/jira/browse/FLINK-35848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-35848.
--
Resolution: Invalid
Canceled.
> [Release-1.20] Vote on the release candidate
> --
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1687470490
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -83,9 +83,15 @@ public Collection getJobManagerRunners() {
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867954#comment-17867954
]
Zakelly Lan commented on FLINK-35835:
-
[~Weijie Guo] Seems 1.20 does not contain FLI
flinkbot commented on PR #25111:
URL: https://github.com/apache/flink/pull/25111#issuecomment-2244299273
## CI report:
* 599839b334cb52e6159912ccb2162e314ce38198 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-23598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867951#comment-17867951
]
Shalini M commented on FLINK-23598:
---
Hi , Is there any update on this issue as there i
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867950#comment-17867950
]
Weijie Guo commented on FLINK-35810:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867949#comment-17867949
]
Weijie Guo commented on FLINK-33555:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867948#comment-17867948
]
Weijie Guo commented on FLINK-35835:
https://dev.azure.com/apache-flink/apache-flink
reswqa opened a new pull request, #25111:
URL: https://github.com/apache/flink/pull/25111
(no comment)
--
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-mai
sn-12-3 commented on PR #23563:
URL: https://github.com/apache/flink/pull/23563#issuecomment-2244234183
Hello, could someone please clarify if this PR requires any further
modifications as the PR is open from quite some time now.
--
This is an automated message from the Apache Git Service
leonardBang commented on PR #2944:
URL: https://github.com/apache/flink-cdc/pull/2944#issuecomment-2244218226
@lvyanquan Could you check the failed tests? and it's recommended to rebase
master.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
ruanhang1993 commented on code in PR #3438:
URL: https://github.com/apache/flink-cdc/pull/3438#discussion_r1687392535
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:
##
@@ -93,6 +93,7 @@ private FlinkPipelineComposer(StreamExec
JunRuiLee closed pull request #22542: [FLINK-31931][runtime] Prevent exception
history page from linking to non-existent TM page.
URL: https://github.com/apache/flink/pull/22542
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34730:
--
Assignee: LvYanquan
> Translate pages of Flink CDC docs to Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-35740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867938#comment-17867938
]
ouyangwulin commented on FLINK-35740:
-
[~seung-min] As this ticket describe，I have
leonardBang merged PR #3443:
URL: https://github.com/apache/flink-cdc/pull/3443
--
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
flinkbot commented on PR #25110:
URL: https://github.com/apache/flink/pull/25110#issuecomment-2244169719
## CI report:
* e83bc90e32841a76be85d96d25e1098e9276c50a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JunRuiLee opened a new pull request, #25110:
URL: https://github.com/apache/flink/pull/25110
## What is the purpose of the change
Fix hang issue in JobGraph generation when StreamGraph contains many
YieldingOperatorFactory.
## Brief change log
Add a c
[
https://issues.apache.org/jira/browse/FLINK-35766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35766:
---
Labels: pull-request-available (was: )
> When the job contains many YieldingOperatorFactory
shiyiky commented on code in PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#discussion_r1687363640
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java:
##
@@ -240
whhe commented on code in PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#discussion_r1687359553
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java:
##
@@ -240,12
[
https://issues.apache.org/jira/browse/FLINK-35874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867932#comment-17867932
]
Leonard Xu commented on FLINK-35874:
[~qiaozhongmin] Assigned to you
> Check pureBi
[
https://issues.apache.org/jira/browse/FLINK-35873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35873:
--
Assignee: LvYanquan
> Add HashFunctionProvider for Paimon DataSink.
> ---
[
https://issues.apache.org/jira/browse/FLINK-35874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35874:
--
Assignee: Zhongmin Qiao
> Check pureBinlogPhaseTables set before call getBinlogPosition metho
[
https://issues.apache.org/jira/browse/FLINK-35865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong resolved FLINK-35865.
-
Resolution: Fixed
Merged Into Master via :c5f391cf6a032333f398038cf96b11a0354bf3c3
> S
[
https://issues.apache.org/jira/browse/FLINK-35865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong reassigned FLINK-35865:
---
Assignee: Zhongqiang Gong
> Support Byte and Short in ObjectUtils
> -
GOODBOY008 merged PR #3481:
URL: https://github.com/apache/flink-cdc/pull/3481
--
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.
ChengJie1053 commented on PR #3487:
URL: https://github.com/apache/flink-cdc/pull/3487#issuecomment-2244140620
@PatrickRen Hi, can you take a look at this code for me
--
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-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867926#comment-17867926
]
Weijie Guo commented on FLINK-35095:
https://dev.azure.com/apache-flink/apache-flink
whhe commented on PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2244137919
> May be we should consider fix the BinaryLogClient with LifecycleListener
in a new pr ,because another pr also should be fixed
https://github.com/apache/flink-cdc/pull/1915/
+1, c
[
https://issues.apache.org/jira/browse/FLINK-35874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867924#comment-17867924
]
Zhongmin Qiao commented on FLINK-35874:
---
Assign this pr to me please. https://gi
RocMarshal commented on PR #123:
URL:
https://github.com/apache/flink-connector-jdbc/pull/123#issuecomment-2244122538
> Note: Before the merge, we can consider removing the
backward-compatibility module (and workflow) to avoid generating the jar, as it
was only meant to be a helper.
showuon commented on PR #24952:
URL: https://github.com/apache/flink/pull/24952#issuecomment-2244119347
The CI test passed. Thanks.
--
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 co
reswqa merged PR #25101:
URL: https://github.com/apache/flink/pull/25101
--
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
leonardBang commented on code in PR #2705:
URL: https://github.com/apache/flink-cdc/pull/2705#discussion_r1687318951
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java:
#
ChengJie1053 opened a new pull request, #3487:
URL: https://github.com/apache/flink-cdc/pull/3487
shiyiky commented on PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2244093727
May be we should consider fix the BinaryLogClient with LifecycleListener in
a new pr ,because another pr also should be fixed
https://github.com/apache/flink-cdc/pull/1915/
--
This
shiyiky commented on PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2244085865
> I think adding a server id can indeed solve the issue, and a
LifecycleListener is also needed for other exceptions. Can you add a basic
implementation like `ReaderThreadLifecycleListe
[
https://issues.apache.org/jira/browse/FLINK-33100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33100:
---
Assignee: Samrat Deb (was: Rui Fan)
> Implement YarnJobFetcher for Standalone Autoscaler
> ---
github-actions[bot] commented on PR #2705:
URL: https://github.com/apache/flink-cdc/pull/2705#issuecomment-2244013184
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.
--
snuyanzin commented on PR #24255:
URL: https://github.com/apache/flink/pull/24255#issuecomment-2243935706
@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.
ferenc-csaky commented on code in PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#discussion_r1686812531
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/CheckpointSpec.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Lice
ferenc-csaky commented on code in PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#discussion_r1684358470
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/JobSpec.java:
##
@@ -90,8 +100,8 @@ public class JobS
ferenc-csaky commented on code in PR #854:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/854#discussion_r1686476104
##
docs/content/docs/custom-resource/snapshots.md:
##
@@ -0,0 +1,117 @@
+---
+title: "Snapshots"
+weight: 3
+type: docs
+aliases:
+ - /custom-res
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1686805757
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -97,6 +106,14 @@ public JobManagerRunner unreg
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1686804638
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistryTest.java:
##
@@ -164,7 +164,8 @@ void testFailingLocalClea
rjbaucells commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2243290547
Hello,
What is the status of this PR?
Thanks
--
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-35726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867790#comment-17867790
]
David Perkins commented on FLINK-35726:
---
[~sverma] ,
Seems odd that this is inten
mxm commented on PR #847:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/847#issuecomment-2243227124
> The `actual_target_data_rate_join` still can be greater than
`target_data_rate_upstream_1` or `target_data_rate_upstream_2`. It means that
the upstreams' target_data_rate r
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1686721979
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -97,6 +106,14 @@ public JobManagerRunner unreg
Zhongmin Qiao created FLINK-35874:
-
Summary: Check pureBinlogPhaseTables set before call
getBinlogPosition method in BinlogSplitReader
Key: FLINK-35874
URL: https://issues.apache.org/jira/browse/FLINK-35874
whhe commented on PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2242931869
I think adding a server id can indeed solve the issue, and a
LifecycleListener is also needed for other exceptions. Can you add a basic
implementation like `ReaderThreadLifecycleListener`
[
https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-35872:
--
Fix Version/s: 2.0.0
1.20.0
> Fix the incorrect partition generation during period
[
https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35872.
---
Resolution: Fixed
> Fix the incorrect partition generation during period refresh in Full Mode
>
[
https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867749#comment-17867749
]
dalongliu commented on FLINK-35872:
---
Merged in master: af7d2b3ab0e0ecc4157005704bebac9
[
https://issues.apache.org/jira/browse/FLINK-35873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35873:
---
Labels: pull-request-available (was: )
> Add HashFunctionProvider for Paimon DataSink.
> --
lvyanquan opened a new pull request, #3486:
URL: https://github.com/apache/flink-cdc/pull/3486
A followup of https://github.com/apache/flink-cdc/pull/3414.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867744#comment-17867744
]
yux commented on FLINK-35634:
-
Paimon / kafka sink options have been added.
> Add a CDC qui
LvYanquan created FLINK-35873:
-
Summary: Add HashFunctionProvider for Paimon DataSink.
Key: FLINK-35873
URL: https://issues.apache.org/jira/browse/FLINK-35873
Project: Flink
Issue Type: New Featu
lsyldliu closed pull request #25108: [FLINK-35872][table] Fix the incorrect
partition generation during period refresh in Full Mode
URL: https://github.com/apache/flink/pull/25108
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
leonardBang commented on PR #3357:
URL: https://github.com/apache/flink-cdc/pull/3357#issuecomment-2242770101
> Is it possible to add actual values conversion checks besides existing
syntax parsing tests? And it should cover cases where `NULL` value is passed as
conversion argument.
XComp commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1686411653
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -97,6 +106,14 @@ public JobManagerRunner unregister(JobID j
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867735#comment-17867735
]
Keith Lee commented on FLINK-35853:
---
Thanks for your response Jinzhong.
I understand
flinkbot commented on PR #25109:
URL: https://github.com/apache/flink/pull/25109#issuecomment-2242532958
## CI report:
* fc3fe3cbe67d160f08dec878039f66d42a91b29d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867725#comment-17867725
]
Dylan He commented on FLINK-35864:
--
The original Hive implementation of CONV is kind of
[
https://issues.apache.org/jira/browse/FLINK-35864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35864:
---
Labels: pull-request-available (was: )
> Add CONV function
> -
>
>
dylanhz opened a new pull request, #25109:
URL: https://github.com/apache/flink/pull/25109
## What is the purpose of the change
Add CONV function.
Examples:
```SQL
> SELECT CONV(7, 10, 2);
111
```
## Brief change log
[FLINK-35864](https://issues.apa
Myasuka commented on PR #22964:
URL: https://github.com/apache/flink/pull/22964#issuecomment-2242408382
It seems this backport was not merged in release-1.17 branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867681#comment-17867681
]
Yue Ma edited comment on FLINK-35576 at 7/22/24 8:10 AM:
-
[~roma
[
https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867681#comment-17867681
]
Yue Ma commented on FLINK-35576:
update the pull request
[https://github.com/ververica/f
lshangq commented on PR #24787:
URL: https://github.com/apache/flink/pull/24787#issuecomment-2242267464
@leonardBang Could you please take a look when you have time?
cherry-pick to release-1.19 https://github.com/apache/flink/pull/25093
cherry-pick to release-1.20 https://github.co
shiyiky commented on PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2242253725
@whhe PTAL
--
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
75 matches
Mail list logo
