dmariassy commented on PR #24482:
URL: https://github.com/apache/flink/pull/24482#issuecomment-2246151636
Draft PR for the alternative implementation:
https://github.com/apache/flink/pull/25114
--
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot commented on PR #25114:
URL: https://github.com/apache/flink/pull/25114#issuecomment-2246160358
## CI report:
* de53e4219ddb42d08a578989675ebec012dd0b35 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dmariassy commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-kafka/pull/109#discussion_r1688736888
##
flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java:
##
@@ -144,14 +147,3
[
https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868193#comment-17868193
]
Trystan commented on FLINK-35285:
-
Great, we'll experiment with setting the max parallel
[
https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868193#comment-17868193
]
Trystan edited comment on FLINK-35285 at 7/23/24 9:31 PM:
--
Grea
[
https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868193#comment-17868193
]
Trystan edited comment on FLINK-35285 at 7/23/24 9:39 PM:
--
Grea
19priyadhingra commented on code in PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#discussion_r1688281873
##
flink-connector-aws/flink-connector-sqs/src/test/java/org/apache/flink/connector/sqs/sink/SqsSinkBuilderTest.java:
##
@@ -25,14 +25,6 @@
/** Cover
LvYanquan created FLINK-35888:
-
Summary: Add e2e test for paimon DataSink
Key: FLINK-35888
URL: https://issues.apache.org/jira/browse/FLINK-35888
Project: Flink
Issue Type: Technical Debt
lvyanquan opened a new pull request, #3491:
URL: https://github.com/apache/flink-cdc/pull/3491
(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,
[
https://issues.apache.org/jira/browse/FLINK-35888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35888:
---
Labels: pull-request-available (was: )
> Add e2e test for paimon DataSink
> ---
github-actions[bot] commented on PR #3350:
URL: https://github.com/apache/flink-cdc/pull/3350#issuecomment-2246584970
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.
--
github-actions[bot] commented on PR #3039:
URL: https://github.com/apache/flink-cdc/pull/3039#issuecomment-2246585165
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 #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1688985573
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java:
##
@@ -30,5 +33,5 @@ public interface DataSink {
EventSinkProvider getEventSin
yuxiqian commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1688986645
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java:
##
@@ -19,13 +19,22 @@
import org.apache.flink.cdc.common.annotation.Publ
yuxiqian commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1688989620
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventType.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundatio
yuxiqian commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1688991587
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventTypeFamily.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Fou
yuxiqian commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1688991979
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisDataSink.java:
##
yuxiqian commented on code in PR #3339:
URL: https://github.com/apache/flink-cdc/pull/3339#discussion_r1688992338
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/metrics/SchemaOperatorMetrics.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33977:
---
Assignee: RocMarshal
> Adaptive scheduler may not minimize the number of TMs during downscaling
> -
yuxiqian commented on code in PR #3285:
URL: https://github.com/apache/flink-cdc/pull/3285#discussion_r1688271544
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilterProcessor.java:
##
Review Comment:
To make newly added E2e te
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868218#comment-17868218
]
Rui Fan commented on FLINK-35835:
-
Hi [~zakelly] , this CI failure happens on master bra
1996fanrui commented on PR #25113:
URL: https://github.com/apache/flink/pull/25113#issuecomment-2246699764
@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
Jiabao-Sun commented on PR #3489:
URL: https://github.com/apache/flink-cdc/pull/3489#issuecomment-2246709941
Thanks @yuxiqian for the investigation.
How about bump the driver version to 4.11?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
yuxiqian opened a new pull request, #3492:
URL: https://github.com/apache/flink-cdc/pull/3492
This corrects MongoDB Driver version specification in docs.
--
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
yuxiqian opened a new pull request, #3493:
URL: https://github.com/apache/flink-cdc/pull/3493
This corrects MongoDB Driver version specification in docs.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868224#comment-17868224
]
Paul Lin commented on FLINK-35876:
--
+1. I've experienced a similar problem with CDC 3.0
lvyanquan commented on PR #3491:
URL: https://github.com/apache/flink-cdc/pull/3491#issuecomment-2246724208
@yuxiqian Can you help to review this?
--
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
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Baozhu Zhao updated FLINK-35885:
Summary: proctime aggregate window triggered by watermark (was:
SlicingWindowOperator should not
[
https://issues.apache.org/jira/browse/FLINK-35888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35888:
--
Assignee: LvYanquan
> Add e2e test for paimon DataSink
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35884:
--
Assignee: JunboWang
> Pipeline MySQL connector supports setting chunk column key
> --
[
https://issues.apache.org/jira/browse/FLINK-35876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Youle updated FLINK-35876:
--
Description:
I use mysql cdc to read data from mysql to write to doris, mysql cdc may
change from sanpshot m
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868227#comment-17868227
]
Zakelly Lan commented on FLINK-35835:
-
[~fanrui] Thanks for the reminder! I'll take
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Baozhu Zhao updated FLINK-35885:
Description:
We have discovered an unexpected case where abnormal data with a count of 0
occurs w
Jiabao-Sun commented on code in PR #3493:
URL: https://github.com/apache/flink-cdc/pull/3493#discussion_r1689035628
##
docs/content.zh/docs/connectors/flink-sources/overview.md:
##
@@ -37,7 +37,7 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/
Jiabao-Sun commented on code in PR #3492:
URL: https://github.com/apache/flink-cdc/pull/3492#discussion_r1689036246
##
docs/content.zh/docs/connectors/flink-sources/overview.md:
##
@@ -37,7 +37,7 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868229#comment-17868229
]
Zakelly Lan commented on FLINK-35835:
-
I was able to reproduce this when I add {{Thr
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Baozhu Zhao updated FLINK-35885:
Description:
We have discovered an unexpected case where abnormal data with a count of 0
occurs w
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Baozhu Zhao updated FLINK-35885:
Description:
We have discovered an unexpected case where abnormal data with a count of 0
occurs w
yuxiqian commented on code in PR #3491:
URL: https://github.com/apache/flink-cdc/pull/3491#discussion_r1689033306
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml:
##
@@ -113,6 +134,152 @@ limitations under the License.
${testcontainers.version}
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35884:
---
Fix Version/s: cdc-3.2.0
> Pipeline MySQL connector supports setting chunk column key
>
yuxiqian commented on code in PR #3493:
URL: https://github.com/apache/flink-cdc/pull/3493#discussion_r1689044606
##
docs/content.zh/docs/connectors/flink-sources/overview.md:
##
@@ -37,7 +37,7 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/b
nateab opened a new pull request, #25115:
URL: https://github.com/apache/flink/pull/25115
## What is the purpose of the change
This PR introduces `DESCRIBE FUNCTION` syntax, allowing users to describe
the metadata of a given function. The design for this is covered under
FLIP
[
https://issues.apache.org/jira/browse/FLINK-35822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35822:
---
Labels: pull-request-available (was: )
> FLIP-465: Introduce DESCRIBE FUNCTION
> --
anupamaggarwal commented on PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#issuecomment-2246776962
Thanks for contributing this super useful feature @mateczagany 👍 !.
I am still new to the operator codebase so pls feel free to ignore if
something is not relev
flinkbot commented on PR #25115:
URL: https://github.com/apache/flink/pull/25115#issuecomment-2246777977
## CI report:
* 70f38a3197427c5fec17f7c7a3578ed1291c97f8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868232#comment-17868232
]
Yun Tang commented on FLINK-35885:
--
I think this problem might be because user misuse e
1996fanrui commented on code in PR #25113:
URL: https://github.com/apache/flink/pull/25113#discussion_r1689012554
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/AbstractSlotPoolServiceFactory.java:
##
@@ -34,14 +36,18 @@ public abstract class Abstract
chenyuzhi459 commented on code in PR #855:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/855#discussion_r1689050095
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -289,6 +28
leonardBang merged PR #3488:
URL: https://github.com/apache/flink-cdc/pull/3488
--
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-35874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35874:
---
Fix Version/s: cdc-3.2.0
> Check pureBinlogPhaseTables set before call getBinlogPosition method in
Jiabao-Sun merged PR #3492:
URL: https://github.com/apache/flink-cdc/pull/3492
--
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.
Jiabao-Sun merged PR #3493:
URL: https://github.com/apache/flink-cdc/pull/3493
--
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-35874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35874.
Resolution: Implemented
Implemented via master(3.2-SNAPSHOT)： ea71b2302ddc5f9b7be65843dbf3f5bed4ca
[
https://issues.apache.org/jira/browse/FLINK-35874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35874:
---
Affects Version/s: cdc-3.1.1
> Check pureBinlogPhaseTables set before call getBinlogPosition method
Zakelly opened a new pull request, #25116:
URL: https://github.com/apache/flink/pull/25116
## What is the purpose of the change
Like the title said, make file-merging test tolerate the scenario that
source does not produce any record.
## Brief change log
- Change the ve
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35835:
---
Labels: pull-request-available (was: )
> SnapshotFileMergingCompatibilityITCase.testSwitchF
flinkbot commented on PR #25116:
URL: https://github.com/apache/flink/pull/25116#issuecomment-2246809131
## CI report:
* a2b0a3795011a8fae37480af5952e7bfface6f4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868246#comment-17868246
]
Dylan He commented on FLINK-35887:
--
I have solved the problem, but what is the practica
[
https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868251#comment-17868251
]
Gyula Fora commented on FLINK-35285:
"always act" would only make sense if we disabl
[
https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868252#comment-17868252
]
Gyula Fora commented on FLINK-35285:
Looping in [~mxm] as he may have input here too
gyfora commented on code in PR #855:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/855#discussion_r1689124506
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -313,9 +313,19 @
Jiabao-Sun commented on code in PR #3489:
URL: https://github.com/apache/flink-cdc/pull/3489#discussion_r1689134338
##
docs/content.zh/docs/connectors/flink-sources/overview.md:
##
@@ -37,7 +37,7 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/
yuxiqian commented on code in PR #3489:
URL: https://github.com/apache/flink-cdc/pull/3489#discussion_r1689156469
##
docs/content.zh/docs/connectors/flink-sources/overview.md:
##
@@ -37,7 +37,7 @@ You can also read [tutorials]({{< ref
"docs/connectors/flink-sources/tutorials/b
[
https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868246#comment-17868246
]
Dylan He edited comment on FLINK-35887 at 7/24/24 5:36 AM:
---
I
101 - 164 of 164 matches
Mail list logo
