[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854914#comment-17854914
]
elon_X commented on FLINK-35157:
[~fanrui] Sure, I will backport this fix to 1.17, 1.18,
[ https://issues.apache.org/jira/browse/FLINK-35157 ]
elon_X deleted comment on FLINK-35157:
was (Author: JIRAUSER303028):
[~fanrui] Sure, I will backport this fix to 1.17, 1.18, and 1.19. Thank you :D
> Sources with watermark alignment get stuck o
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855611#comment-17855611
]
elon_X commented on FLINK-35157:
Hi [~fanrui]
I have already backported this fix to 1.1
elon_X created FLINK-35631:
--
Summary: KafkaSource parameter partition.discovery.interval.ms
with a default value of 5 minutes does not take effect
Key: FLINK-35631
URL: https://issues.apache.org/jira/browse/FLINK-35631
[
https://issues.apache.org/jira/browse/FLINK-35631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35631:
---
Affects Version/s: kafka-3.1.0
(was: 1.17.2)
> KafkaSource parameter partition.di
[
https://issues.apache.org/jira/browse/FLINK-35631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35631:
---
Issue Type: Improvement (was: Bug)
> KafkaSource parameter partition.discovery.interval.ms with a default v
elon_X created FLINK-35632:
--
Summary: The example provided in the kafkaSource documentation
for topic regex subscription is incorrect
Key: FLINK-35632
URL: https://issues.apache.org/jira/browse/FLINK-35632
[
https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35632:
---
Description:
[https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kafka/#t
[
https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35632:
---
Attachment: image-2024-06-18-18-41-41-212.png
> The example provided in the kafkaSource/pulsarSource docume
[
https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35632:
---
Summary: The example provided in the kafkaSource/pulsarSource
documentation for topic regex subscription is
[
https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35632:
---
Attachment: image-2024-06-18-18-41-53-593.png
> The example provided in the kafkaSource/pulsarSource docume
[
https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35632:
---
Description:
[https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kafka/#t
[
https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35632:
---
Description:
[https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kafka/#t
[
https://issues.apache.org/jira/browse/FLINK-35631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855977#comment-17855977
]
elon_X commented on FLINK-35631:
[~martijnvisser] Thank you for your response. I checked
[
https://issues.apache.org/jira/browse/FLINK-35631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856110#comment-17856110
]
elon_X commented on FLINK-35631:
[~robyoung] Ah, I have already fixed this issue. Once i
elon_X created FLINK-35685:
--
Summary: Some metrics in the MetricStore are duplicated when
increasing or decreasing task parallelism
Key: FLINK-35685
URL: https://issues.apache.org/jira/browse/FLINK-35685
Pro
[
https://issues.apache.org/jira/browse/FLINK-35685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X closed FLINK-35685.
--
Resolution: Fixed
> Some metrics in the MetricStore are duplicated when increasing or decreasing
> task paral
elon_X created FLINK-35076:
--
Summary: Watermark alignment will cause data flow to experience
serious shake
Key: FLINK-35076
URL: https://issues.apache.org/jira/browse/FLINK-35076
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35076:
---
Attachment: (was: image-2024-04-10-20-13-14-752.png)
> Watermark alignment will cause data flow to exper
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35076:
---
Description:
In our company, there is a requirement scenario for multi-stream join
operations, we are makin
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35076:
---
Attachment: image-2024-04-10-20-25-59-387.png
> Watermark alignment will cause data flow to experience serio
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35076:
---
Description:
In our company, there is a requirement scenario for multi-stream join
operations, we are makin
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35076:
---
Attachment: image-2024-04-10-20-29-13-835.png
> Watermark alignment will cause data flow to experience serio
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35076:
---
Description:
In our company, there is a requirement scenario for multi-stream join
operations, we are makin
[
https://issues.apache.org/jira/browse/FLINK-35064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835964#comment-17835964
]
elon_X commented on FLINK-35064:
[~chalixar]
Thank you for your reply. I also used relo
elon_X created FLINK-35088:
--
Summary: watermark alignment maxAllowedWatermarkDrift and
updateInterval param need check
Key: FLINK-35088
URL: https://issues.apache.org/jira/browse/FLINK-35088
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836238#comment-17836238
]
elon_X commented on FLINK-35076:
[~kkrugler]
Thank you for your reply.
Setting the idl
[
https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836238#comment-17836238
]
elon_X edited comment on FLINK-35076 at 4/11/24 3:23 PM:
-
[~kkru
[
https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838534#comment-17838534
]
elon_X commented on FLINK-35088:
[~martijnvisser] [~masc] I'm sorry for the late reply.
elon_X created FLINK-35160:
--
Summary: Support for Thread Dump provides a convenient way to
display issues of thread deadlocks in tasks
Key: FLINK-35160
URL: https://issues.apache.org/jira/browse/FLINK-35160
[
https://issues.apache.org/jira/browse/FLINK-35160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35160:
---
Attachment: (was: image-2024-04-18-21-00-04-532.png)
> Support for Thread Dump provides a convenient way
[
https://issues.apache.org/jira/browse/FLINK-35160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35160:
---
Attachment: image-2024-04-20-14-43-36-939.png
Description:
After receiving feedback from the business s
elon_X created FLINK-35178:
--
Summary: Checkpoint CLAIM mode does not fully control snapshot
ownership
Key: FLINK-35178
URL: https://issues.apache.org/jira/browse/FLINK-35178
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35178:
---
Attachment: image-2024-04-22-15-16-02-381.png
> Checkpoint CLAIM mode does not fully control snapshot owners
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839522#comment-17839522
]
elon_X commented on FLINK-35178:
[~lijinzhong]
Thank you for your response.
I have be
[
https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839522#comment-17839522
]
elon_X edited comment on FLINK-35178 at 4/22/24 3:20 PM:
-
[~liji
[
https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840041#comment-17840041
]
elon_X commented on FLINK-35088:
[~fanrui] I am very happy to fix this issue, please ass
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35157:
---
Attachment: image-2024-04-24-21-36-16-146.png
> Sources with watermark alignment get stuck once some subtask
[
https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840443#comment-17840443
]
elon_X commented on FLINK-35157:
hi, [~fanrui] Can you assign this issue to me? I can fi
elon_X created FLINK-35506:
--
Summary: disable kafka auto-commit and rely on flink’s
checkpointing if both are enabled
Key: FLINK-35506
URL: https://issues.apache.org/jira/browse/FLINK-35506
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35506:
---
Attachment: image-2024-06-03-23-39-28-270.png
> disable kafka auto-commit and rely on flink’s checkpointing
[
https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35506:
---
Description:
When I use KafkaSource for consuming topics and set the Kafka parameter
{{{}enable.auto.commit
[
https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X updated FLINK-35506:
---
Description:
When I use KafkaSource for consuming topics and set the Kafka parameter
{{{}enable.auto.commit
[
https://issues.apache.org/jira/browse/FLINK-35506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
elon_X closed FLINK-35506.
--
Resolution: Not A Problem
> disable kafka auto-commit and rely on flink’s checkpointing if both are
> enabled
44 matches
Mail list logo
