flinkbot commented on PR #24842:
URL: https://github.com/apache/flink/pull/24842#issuecomment-2132050840
## CI report:
* 745f6f511d6e978317e42d1ca6e4b51d5d201926 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35453:
---
Labels: pull-request-available (was: )
> StreamReader Charset fix with UTF8 in core files
>
xuzifu666 opened a new pull request, #24842:
URL: https://github.com/apache/flink/pull/24842
## What is the purpose of the change
StreamReader Charset fix with UTF8 in core files
## Brief change log
StreamReader Charset fix with UTF8 in core files
#
xy created FLINK-35453:
--
Summary: StreamReader Charset fix with UTF8 in core files
Key: FLINK-35453
URL: https://issues.apache.org/jira/browse/FLINK-35453
Project: Flink
Issue Type: Improvement
Affe
[
https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35452:
---
Description:
We've seen some cases where a MySQL CDC job is restarted with some newly added
tables,
[
https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35452:
---
Summary: MySQL CDC is not tracking newly added tables when a failure
happens after the snapshot phas
[
https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35452:
---
Description:
We've seen some cases where a MySQL CDC job is restarted with some newly added
tables,
[
https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-35452:
---
Description:
We've seen some cases where a MySQL CDC job is restarted with some newly added
tables,
Sharon Xie created FLINK-35452:
--
Summary: MySQL CDC not tracking newly added tables after snapshot
Key: FLINK-35452
URL: https://issues.apache.org/jira/browse/FLINK-35452
Project: Flink
Issue Ty
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614911177
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTimeoutTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Li
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614911032
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTimeoutTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Li
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614910580
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTimeoutTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Li
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614908849
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTimeoutTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Li
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614909440
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterTimeoutTest.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Li
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614907240
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBase.java:
##
@@ -54,6 +54,8 @@ public abstract class AsyncSin
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614905336
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java:
##
@@ -533,4 +607,77 @@ private int getNex
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614904850
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java:
##
@@ -533,4 +607,77 @@ private int getNex
vahmed-hamdy commented on code in PR #24839:
URL: https://github.com/apache/flink/pull/24839#discussion_r1614903605
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBase.java:
##
@@ -73,6 +97,8 @@ protected AsyncSinkBase(
Rose-365 commented on PR #9097:
URL: https://github.com/apache/flink/pull/9097#issuecomment-2131387633
Hello, I'm LXT, my first day in the flink community, I want to contribute to
the community by translating docs, but I found that the path of this project
seems to have changed, and I can't
Yubin Li created FLINK-35451:
Summary: Support `ALTER CATALOG COMMENT` syntax
Key: FLINK-35451
URL: https://issues.apache.org/jira/browse/FLINK-35451
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #24841:
URL: https://github.com/apache/flink/pull/24841#issuecomment-2131362898
## CI report:
* fb738b0acce19682d7ba377baefe8a26f551518e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ZmmBigdata commented on PR #24841:
URL: https://github.com/apache/flink/pull/24841#issuecomment-2131360809
Verified already
--
This is an automated message from the Apache Git Service.
To re
ZmmBigdata opened a new pull request, #24841:
URL: https://github.com/apache/flink/pull/24841
## What is the purpose of the change
Flink sql gettingstarted Expression 'dept_id' is not being grouped
