leonardBang commented on PR #3680:
URL: https://github.com/apache/flink-cdc/pull/3680#issuecomment-2490230409
> @leonardBang Will this PR be reviewed soon? I'm planning to implement
[FLINK-36763](https://issues.apache.org/jira/browse/FLINK-36763) based on this.
Added to my todo list
[
https://issues.apache.org/jira/browse/FLINK-36763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36763:
---
Fix Version/s: cdc-3.3.0
> Support schema inference and evolution with single-table-mutliple-partiti
noorall commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1851480334
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobgraph/forwardgroup/ForwardGroupComputeUtilTest.java:
##
@@ -182,7 +319,56 @@ private static Set
computeForwa
noorall commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1851480334
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobgraph/forwardgroup/ForwardGroupComputeUtilTest.java:
##
@@ -182,7 +319,56 @@ private static Set
computeForwa
Shengkai Fang created FLINK-36755:
-
Summary: Relax the limit about the pipeline.jar must have one in
application mode
Key: FLINK-36755
URL: https://issues.apache.org/jira/browse/FLINK-36755
Project: F
[
https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36754:
---
Labels: pull-request-available (was: )
> When projection is empty or null, it is treated as
yux created FLINK-36763:
---
Summary: Support schema inference and evolution with
single-table-mutliple-partition sources
Key: FLINK-36763
URL: https://issues.apache.org/jira/browse/FLINK-36763
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-36762:
--
Summary: Add E2ECase to run script in application mode (was: Add E2ECase
to run sql client in
Shengkai Fang created FLINK-36761:
-
Summary: Add document about how to deploy script with SQL Client
and SQL Gateway
Key: FLINK-36761
URL: https://issues.apache.org/jira/browse/FLINK-36761
Project: Fl
Shengkai Fang created FLINK-36759:
-
Summary: Intrdouce REST API to deploy script
Key: FLINK-36759
URL: https://issues.apache.org/jira/browse/FLINK-36759
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-36758:
-
Summary: Introduce driver to load the application in application
mode
Key: FLINK-36758
URL: https://issues.apache.org/jira/browse/FLINK-36758
Project: Flink
Shengkai Fang created FLINK-36756:
-
Summary: Bump up the sql-gateway rest api version
Key: FLINK-36756
URL: https://issues.apache.org/jira/browse/FLINK-36756
Project: Flink
Issue Type: Sub-ta
Shengkai Fang created FLINK-36757:
-
Summary: Introduce splitter to split scripts
Key: FLINK-36757
URL: https://issues.apache.org/jira/browse/FLINK-36757
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36754:
--
Description:
When projection is empty or NULL, the projection should be treated as an
asterisk. The following
[
https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36754:
--
Description:
When projection is empty or NULL, the projection should be treated as an
asterisk. The following
MOBIN created FLINK-36754:
-
Summary: When projection is empty or null, it is treated as an
asterisk
Key: FLINK-36754
URL: https://issues.apache.org/jira/browse/FLINK-36754
Project: Flink
Issue Type:
snuyanzin closed pull request #24908: [FLINK-35282][FLINK-35520] PyFlink
Support for Apache Beam > 2.49
URL: https://github.com/apache/flink/pull/24908
--
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
snuyanzin commented on PR #24908:
URL: https://github.com/apache/flink/pull/24908#issuecomment-2490143091
closed in favor of https://github.com/apache/flink/pull/25541,
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
Rui Fan created FLINK-36753:
---
Summary: Adaptive Scheduler actively triggers a Checkpoint
Key: FLINK-36753
URL: https://issues.apache.org/jira/browse/FLINK-36753
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899927#comment-17899927
]
Fangwei Duan commented on FLINK-23409:
--
same as @felixzh, No more queue resouces.
sim-pez commented on PR #25614:
URL: https://github.com/apache/flink/pull/25614#issuecomment-2489628212
Hi @davidradl, thank you for your feedback. I’ve pushed again to fix all the
typos I found.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35093:
--
Assignee: Vinh Pham (was: Hongshun Wang)
> Postgres source connector support SPECIFIC_OFFSET
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899924#comment-17899924
]
Leonard Xu commented on FLINK-35093:
[~phamvinh1712]Assigned to you
> Postgres sour
[
https://issues.apache.org/jira/browse/FLINK-36753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36753:
Description:
FLIP-461[1] and FLINK-35549[2] support that rescale could be executed after the
next complet
[
https://issues.apache.org/jira/browse/FLINK-36753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36753:
Description:
FLIP-461[1] and FLINK-35549[2] support that rescale could be executed after the
next complet
[
https://issues.apache.org/jira/browse/FLINK-36572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897081#comment-17897081
]
Leonard Xu edited comment on FLINK-36572 at 11/21/24 2:04 AM:
[
https://issues.apache.org/jira/browse/FLINK-36572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36572.
Resolution: Fixed
> The local time zone is wrongly set in StarRocks pipeline sink
> --
[
https://issues.apache.org/jira/browse/FLINK-36572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36572:
---
Fix Version/s: cdc-3.2.1
> The local time zone is wrongly set in StarRocks pipeline sink
> -
leonardBang merged PR #3733:
URL: https://github.com/apache/flink-cdc/pull/3733
--
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
zhuzhurk commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1847688952
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/IntermediateDataSet.java:
##
@@ -43,6 +44,8 @@ public class IntermediateDataSet implements
java.io.Se
fredia merged PR #25643:
URL: https://github.com/apache/flink/pull/25643
--
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-36527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-36527.
-
Fix Version/s: kubernetes-operator-1.11.0
Resolution: Fixed
Merged to main(1.11.0) via: acc04da2b
huyuanfeng2018 commented on PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#issuecomment-2489903494
Thanks for the review @mxm @1996fanrui @SamBarker
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dependabot[bot] opened a new pull request, #46:
URL: https://github.com/apache/flink-playgrounds/pull/46
Bumps org.apache.kafka:kafka-clients from 3.3.1 to 3.7.1.
[![Dependabot compatibility
score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=
RocMarshal commented on PR #25510:
URL: https://github.com/apache/flink/pull/25510#issuecomment-2489832062
Hi, @XComp Could you help take a look if you had the free time ?
Thank you very much~ :)
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
github-actions[bot] commented on PR #3538:
URL: https://github.com/apache/flink-cdc/pull/3538#issuecomment-2489789390
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3538: Optimize log level
URL: https://github.com/apache/flink-cdc/pull/3538
--
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 unsubscr
github-actions[bot] commented on PR #3593:
URL: https://github.com/apache/flink-cdc/pull/3593#issuecomment-2489789317
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-36711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-36711.
-
Fix Version/s: 2.0.0
Assignee: Vincent Woo
Resolution: Fixed
Thanks [~vincentwoo] for th
Sai Sharath Dandi created FLINK-36752:
-
Summary: Emit state related metrics when checkpoints are disabled
Key: FLINK-36752
URL: https://issues.apache.org/jira/browse/FLINK-36752
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-32097:
Component/s: Connectors / Kinesis
> Implement support for Kinesis deaggregation
>
[
https://issues.apache.org/jira/browse/FLINK-32097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-32097:
Affects Version/s: aws-connector-5.0.0
> Implement support for Kinesis deaggregation
> ---
davidradl commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1850415111
##
docs/content.zh/docs/dev/datastream/sources.md:
##
@@ -294,9 +294,9 @@ public class FixedSizeSplitFetcherManager
public FixedSizeSplitFetcherManager(
mxm commented on PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#issuecomment-2489095198
Thanks @huyuanfeng2018!
--
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 sp
mxm merged PR #904:
URL: https://github.com/apache/flink-kubernetes-operator/pull/904
--
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...
[
https://issues.apache.org/jira/browse/FLINK-36739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899814#comment-17899814
]
Mehdi commented on FLINK-36739:
---
It seems to be a problem with GLIBC which is 2.23 but fro
lvyanquan commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1849637494
##
docs/content/docs/dev/datastream/sources.md:
##
@@ -325,16 +325,13 @@ public class FixedFetcherSizeSourceReader {
public FixedFetcherSizeSourceReader(
-
borislitvak commented on PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#issuecomment-2488981196
I actively use it, yes. You can built from branch.
On Wed, Nov 20, 2024, 17:24 Ecaterina Lazarescu ***@***.***>
wrote:
> Thank you for your prompt answer!,
EcaterinaL commented on PR #118:
URL:
https://github.com/apache/flink-connector-jdbc/pull/118#issuecomment-2488874691
Thank you for your prompt answer!,
Do you actively use it?
Have you merge it with your master?
--
This is an automated message from the Apache Git Service.
To r
davidradl commented on PR #25663:
URL: https://github.com/apache/flink/pull/25663#issuecomment-241174
is this the same as https://github.com/apache/flink/pull/25664
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
davidradl commented on code in PR #25669:
URL: https://github.com/apache/flink/pull/25669#discussion_r1850410306
##
docs/content.zh/docs/dev/table/common.md:
##
@@ -387,19 +387,19 @@ Table table = ...;
// register the view named 'exampleView' in the catalog named 'custom_cata
davidradl commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1850415111
##
docs/content.zh/docs/dev/datastream/sources.md:
##
@@ -294,9 +294,9 @@ public class FixedSizeSplitFetcherManager
public FixedSizeSplitFetcherManager(
davidradl commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2488701144
@mehdid93 when you say "There will be another PR to fix vulnerabilities once
this is merged.". Can you confirm that this PR does not introduce any
vulnerabilities compared to the older
davidradl commented on code in PR #25614:
URL: https://github.com/apache/flink/pull/25614#discussion_r1850386490
##
docs/content/docs/dev/table/hive-compatibility/hive-dialect/create.md:
##
@@ -27,7 +27,7 @@ With Hive dialect, the following CREATE statements are
supported for n
[
https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899490#comment-17899490
]
Feifan Wang commented on FLINK-36743:
-
Sorry I missed a important change from my col
leonardBang commented on PR #3510:
URL: https://github.com/apache/flink-cdc/pull/3510#issuecomment-2488389062
@loserwang1024 Could you kindly rebase your PR to latest master branch to
resolve potential conflicts?
--
This is an automated message from the Apache Git Service.
To respond to t
zhuzhurk commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1849791836
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/AdaptiveGraphManager.java:
##
@@ -0,0 +1,697 @@
+/*
+ * Licensed to the Apache Software Foundation
huyuanfeng2018 commented on code in PR #904:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1848520651
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -411,26 +416,30 @@ protected static > int scale(
ruanhang1993 merged PR #3743:
URL: https://github.com/apache/flink-cdc/pull/3743
--
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
kaygorodov commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1850149045
##
docs/content/docs/dev/datastream/sources.md:
##
@@ -325,16 +325,13 @@ public class FixedFetcherSizeSourceReader {
public FixedFetcherSizeSourceReader(
-
[
https://issues.apache.org/jira/browse/FLINK-36509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-36509:
--
Issue Type: Bug (was: Improvement)
> Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pi
[
https://issues.apache.org/jira/browse/FLINK-36750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-36750.
---
Resolution: Fixed
> Paimon connector would reuse sequence number when schema evolution happened
> --
yuxiqian closed pull request #3747: [hotfix][tests] Fix CI failure after
upgrading to Flink 1.19
URL: https://github.com/apache/flink-cdc/pull/3747
--
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 th
lvyanquan commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1850103994
##
docs/content/docs/dev/datastream/sources.md:
##
@@ -325,16 +325,13 @@ public class FixedFetcherSizeSourceReader {
public FixedFetcherSizeSourceReader(
-
lvyanquan commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1850103994
##
docs/content/docs/dev/datastream/sources.md:
##
@@ -325,16 +325,13 @@ public class FixedFetcherSizeSourceReader {
public FixedFetcherSizeSourceReader(
-
ruanhang1993 merged PR #3748:
URL: https://github.com/apache/flink-cdc/pull/3748
--
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
flinkbot commented on PR #25670:
URL: https://github.com/apache/flink/pull/25670#issuecomment-2488136503
## CI report:
* c7c73f9f60c35c64700e47eaa21b1a6e4f041aff UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25669:
URL: https://github.com/apache/flink/pull/25669#issuecomment-2488114295
## CI report:
* 995d861b3b62efed770c69b4853d840b4003dae4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36739:
---
Labels: pull-request-available (was: )
> Update NodeJS to v18.20.5 (LTS)
>
yuanoOo commented on code in PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#discussion_r1849995102
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/test/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseEventSerializa
mehdid93 opened a new pull request, #25670:
URL: https://github.com/apache/flink/pull/25670
Contribute-to: https://issues.apache.org/jira/browse/FLINK-36739
## What is the purpose of the change
This pull request raises the version of the NodeJS module which is a
pre-req
Huachao opened a new pull request, #25669:
URL: https://github.com/apache/flink/pull/25669
## What is the purpose of the change
Fix enviroment variable name inconsistence in code snippet.
## Brief change log
- Change `tableEnv` to `tEnv` for both `Java` and
yuanoOo commented on code in PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#discussion_r1849991842
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseEventSerializa
yuanoOo commented on code in PR #3360:
URL: https://github.com/apache/flink-cdc/pull/3360#discussion_r1849992101
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/test/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseMetadataApplie
leonardBang opened a new pull request, #3748:
URL: https://github.com/apache/flink-cdc/pull/3748
Fix conflicts after flink version bumped to 1.19
--
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
kaygorodov commented on code in PR #25667:
URL: https://github.com/apache/flink/pull/25667#discussion_r1849982828
##
docs/content/docs/dev/datastream/sources.md:
##
@@ -325,16 +325,13 @@ public class FixedFetcherSizeSourceReader {
public FixedFetcherSizeSourceReader(
-
[
https://issues.apache.org/jira/browse/FLINK-36751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899708#comment-17899708
]
haishui commented on FLINK-36751:
-
Hi [~pnowojski] , could you help investigate this?
>
haishui created FLINK-36751:
---
Summary: PausableRelativeClock does not pause when the source only
has one split
Key: FLINK-36751
URL: https://issues.apache.org/jira/browse/FLINK-36751
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36750:
---
Fix Version/s: cdc-3.3.0
> Paimon connector would reuse sequence number when schema evolution happen
[
https://issues.apache.org/jira/browse/FLINK-36750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899699#comment-17899699
]
Leonard Xu commented on FLINK-36750:
master:3a2d799fd8eceea76b0abfb066e70b2ca4d58648
leonardBang merged PR #3745:
URL: https://github.com/apache/flink-cdc/pull/3745
--
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 #3744:
URL: https://github.com/apache/flink-cdc/pull/3744
--
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 #3744:
URL: https://github.com/apache/flink-cdc/pull/3744#issuecomment-2487990882
CI passed, merging...
--
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
[
https://issues.apache.org/jira/browse/FLINK-36750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36750:
--
Assignee: Yanquan Lv
> Paimon connector would reuse sequence number when schema evolution hap
[
https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899418#comment-17899418
]
Feifan Wang commented on FLINK-36743:
-
[~arvid] We do use a internal version forked
[
https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899693#comment-17899693
]
Arvid Heise edited comment on FLINK-36743 at 11/20/24 9:06 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-36743.
-
Resolution: Duplicate
> Rescale from unaligend checkpoint failed
> -
tcmtang closed pull request #3746: 同步release3.2
URL: https://github.com/apache/flink-cdc/pull/3746
--
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: issue
[
https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899693#comment-17899693
]
Arvid Heise commented on FLINK-36743:
-
It looks like https://issues.apache.org/jira/
tcmtang opened a new pull request, #3746:
URL: https://github.com/apache/flink-cdc/pull/3746
(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-
[
https://issues.apache.org/jira/browse/FLINK-36750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36750:
---
Description:
When schema evolution happened, we will prepare commit and recreate a new
FileStoreWri
[
https://issues.apache.org/jira/browse/FLINK-36509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899629#comment-17899629
]
Ruan Hang commented on FLINK-36509:
---
3.2 : 40db6d5eb7661696797acba30384e37e56cdac5a
>
[
https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899674#comment-17899674
]
Arvid Heise commented on FLINK-36743:
-
I try to dig a bit deeper because there may s
yuxiqian commented on PR #3742:
URL: https://github.com/apache/flink-cdc/pull/3742#issuecomment-2487833115
Most changes are just repetitive while some needs more attention:
* Created wrapper classes `AbstractTestBaseProxy` because Flink's original
version was targeted to JUnit 4
*
94 matches
Mail list logo