qyfftf opened a new pull request, #3906:
URL: https://github.com/apache/flink-cdc/pull/3906
I've implemented a solution where data is collected from MySQL once and then
sent to multiple target data sources, such as Paimon, Kafka, and StarRocks,
which reduces redundant data collection.
pi
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-37255:
---
Description:
The new configuration option scan.partition.record-size was introduced by
FLINK-36075,
[
https://issues.apache.org/jira/browse/FLINK-37156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37156:
---
Labels: pull-request-available (was: )
> A Flink pipeline supports collecting data once and
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-37255:
---
Priority: Blocker (was: Major)
> Unsupported options: scan.partition.record-size
>
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923952#comment-17923952
]
yux commented on FLINK-37255:
-
I'll prepare a patch for this.
> Unsupported options: scan.p
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-37255:
--
Assignee: yux (was: Jiabao Sun)
> Unsupported options: scan.partition.record-size
>
[
https://issues.apache.org/jira/browse/FLINK-37256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923966#comment-17923966
]
Piotr Nowojski edited comment on FLINK-37256 at 2/5/25 9:02 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Description:
When the table schema contains the following field:
{color:#00}`tenant_id`{color}
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Attachment: 1.png
> Flink CDC OceanBase Connector Throws Exception for Column Default Value
> ‘DEFA
lvyanquan commented on PR #140:
URL:
https://github.com/apache/flink-connector-kafka/pull/140#issuecomment-2636096310
Hi, @PatrickRen can you help to review again and help to complete this PR？
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
lvyanquan commented on PR #149:
URL:
https://github.com/apache/flink-connector-kafka/pull/149#issuecomment-2636103200
Hi, @PatrickRen 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
UR
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Description:
When the table schema contains the following field:
：
{color:#00}`tenant_id`{colo
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Summary: Flink CDC OceanBase Connector Throws Exception for Column Default
Value ‘DEFAULT ‘0’ (was:
flinkbot commented on PR #26106:
URL: https://github.com/apache/flink/pull/26106#issuecomment-2636105860
## CI report:
* 0f17c6288fb5f885c235bb7aa3e7dd78de2ade92 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuxiqian opened a new pull request, #51:
URL: https://github.com/apache/flink-connector-mongodb/pull/51
This closes FLINK-37255.
`scan.partition.record-size` option was introduced in FLINK-36075, but
corresponding config manifest wasn't updated, which makes it impossible for
Flink SQ
AlexYinHan opened a new pull request, #26106:
URL: https://github.com/apache/flink/pull/26106
## What is the purpose of the change
This pull request addresses several bugs in ForSt that may prevent proper
file reuse, leading to slower or failed snapshot and restoration operati
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Description:
When the table schema contains the following field:
：
{color:#00}`tenant_id`{colo
[
https://issues.apache.org/jira/browse/FLINK-37256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923966#comment-17923966
]
Piotr Nowojski commented on FLINK-37256:
I can see two broad solutions.
1. Use
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Description:
When the table schema contains the following field:
{color:#00}`tenant_id`{color}
[
https://issues.apache.org/jira/browse/FLINK-37256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923966#comment-17923966
]
Piotr Nowojski edited comment on FLINK-37256 at 2/5/25 8:56 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-36929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-36929.
---
Fix Version/s: 2.1.0
Resolution: Fixed
[{{a4eb676}}|https://github.com/apache/flink/c
[
https://issues.apache.org/jira/browse/FLINK-36929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-36929.
-
> SQL connector for keyed savepoint data
> --
>
>
zhougit86 commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-2636294560
> @zhougit86 @ljw-hit Hi, is there a plan to revive effort on it?
Ok let me look into conflict first
--
This is an automated message from the Apache Git Service.
To respond to t
whhe opened a new pull request, #3907:
URL: https://github.com/apache/flink-cdc/pull/3907
(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
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37254:
---
Labels: pull-request-available (was: )
> flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常
Zakelly merged PR #26040:
URL: https://github.com/apache/flink/pull/26040
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923962#comment-17923962
]
Zakelly Lan commented on FLINK-37021:
-
Follow up PR:
* master: f975783ce9a688a99e2f7
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37254:
---
Description:
When the table schema contains the following field:
{color:#00}`tenant_id`{color}
afedulov commented on code in PR #938:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/938#discussion_r1942507092
##
flink-kubernetes-operator-api/pom.xml:
##
@@ -55,6 +55,18 @@ under the License.
+
+org.apache.flink
+
yuxiqian commented on PR #51:
URL:
https://github.com/apache/flink-connector-mongodb/pull/51#issuecomment-2636181379
Thanks for @Jiabao-Sun's kind review! Addressed comments in latest commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Zakelly opened a new pull request, #26107:
URL: https://github.com/apache/flink/pull/26107
## What is the purpose of the change
English documents for Disaggregate State and new State APIs
## Brief change log
Still writting... will add commit if finished.
- Doc
[
https://issues.apache.org/jira/browse/FLINK-36439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36439:
---
Labels: pull-request-available (was: )
> Documentation for Disaggregated State Storage and
lincoln-lil opened a new pull request, #26108:
URL: https://github.com/apache/flink/pull/26108
## What is the purpose of the change
This is a trivial fix for string comparison in `FlinkCalcMergeRule`.
However it doesn't actually affect the optimization results, so no new cases
were a
yangjf2019 closed pull request #25916: [hotfix] Update copyright NOTICE year to
2025
URL: https://github.com/apache/flink/pull/25916
--
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 comm
Jiabao-Sun merged PR #51:
URL: https://github.com/apache/flink-connector-mongodb/pull/51
--
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-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923982#comment-17923982
]
Jiabao Sun edited comment on FLINK-37255 at 2/5/25 11:11 AM:
-
Jiabao-Sun merged PR #52:
URL: https://github.com/apache/flink-connector-mongodb/pull/52
--
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-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-37255.
Resolution: Fixed
> Unsupported options: scan.partition.record-size
>
RanJinh commented on PR #25590:
URL: https://github.com/apache/flink/pull/25590#issuecomment-2636439765
@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.
gyfora commented on code in PR #938:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/938#discussion_r1942746157
##
flink-kubernetes-operator-api/pom.xml:
##
@@ -55,6 +55,18 @@ under the License.
+
+org.apache.flink
+
[
https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-35687:
-
Fix Version/s: 2.0-preview
(was: 1.20.0)
> JSON_QUERY should retu
gyfora merged PR #939:
URL: https://github.com/apache/flink-kubernetes-operator/pull/939
--
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-37242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-37242.
--
Assignee: thanh tung dao
Resolution: Fixed
merged to main 67aa78b1cc52acba4e73dc348d98196617464c
flinkbot commented on PR #26111:
URL: https://github.com/apache/flink/pull/26111#issuecomment-2637257809
## CI report:
* 94244da081bfe60e66ddf0bf49c176d7881f6983 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mxm commented on code in PR #941:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/941#discussion_r1943210819
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java:
##
@@ -403,6 +403,28 @@ public static Long
calculat
[
https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-37258:
--
Fix Version/s: (was: 2.1.0)
> Order Flink Job list in Flink UI with start time
> -
Matthias Pohl created FLINK-37259:
-
Summary: StreamCheckpointingITCase times out
Key: FLINK-37259
URL: https://issues.apache.org/jira/browse/FLINK-37259
Project: Flink
Issue Type: Bug
mxm commented on code in PR #941:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/941#discussion_r1943120952
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -757,16 +778,35 @@ public Map getC
mxm commented on code in PR #941:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/941#discussion_r1943201542
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -757,16 +778,35 @@ public Map getC
[
https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-37258:
-
Assignee: Ahmed Hamdy
> Order Flink Job list in Flink UI with start time
>
mxm commented on PR #941:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/941#issuecomment-2637573408
Tried it out on a local k8s cluster with various Flink versions:
https://github.com/user-attachments/assets/f6909e9d-5710-4965-9645-55ce8b06fe82";
/>
https://github.
yuxiqian closed pull request #3884: [tests][ci] Miscellaneous improvements on
CI robustness
URL: https://github.com/apache/flink-cdc/pull/3884
--
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 spe
yuxiqian commented on PR #3884:
URL: https://github.com/apache/flink-cdc/pull/3884#issuecomment-2638951176
Closed in favor of #3911.
--
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 c
whhe closed pull request #3909: [hotfix][ci] Use raise to fix uncaught throw
URL: https://github.com/apache/flink-cdc/pull/3909
--
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.
[
https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37234.
Resolution: Fixed
Fixed via master(3.3-SNAPSHOT): 81e6a4a329498ddd9ff63d9db8ddbcf22882a7fc
> Add
Zhang Hechuan created FLINK-37265:
-
Summary: document of python elasticsearch connector exeample has a
mistake
Key: FLINK-37265
URL: https://issues.apache.org/jira/browse/FLINK-37265
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923982#comment-17923982
]
Jiabao Sun commented on FLINK-37255:
Fixed via mongodb repo
main: 123334b8a70e5b3cc
boring-cyborg[bot] commented on PR #155:
URL:
https://github.com/apache/flink-connector-jdbc/pull/155#issuecomment-2636257302
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
roseduan opened a new pull request, #155:
URL: https://github.com/apache/flink-connector-jdbc/pull/155
In PostgreSQL, there is no need to specify the unique key fields in the
update clause.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot commented on PR #26107:
URL: https://github.com/apache/flink/pull/26107#issuecomment-2636265648
## CI report:
* c5c732493e7d6b3dbb877ebffd620695cef52c3d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #26108:
URL: https://github.com/apache/flink/pull/26108#issuecomment-2636265903
## CI report:
* dcaa98389b7308ab184467a039163b466b560d53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuxiqian commented on PR #51:
URL:
https://github.com/apache/flink-connector-mongodb/pull/51#issuecomment-2636249551
> Thanks @yuxiqian for the quick update. LGTM.
>
> Could you help make a backport to v2.0 branch?
Sure, cherry-picked in #52
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923955#comment-17923955
]
Jiabao Sun commented on FLINK-37255:
Thanks [~xiqian_yu], assigned to you.
> Unsupp
[
https://issues.apache.org/jira/browse/FLINK-37255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37255:
---
Labels: pull-request-available (was: )
> Unsupported options: scan.partition.record-size
>
Piotr Nowojski created FLINK-37256:
--
Summary: Firing timers can block recovery process
Key: FLINK-37256
URL: https://issues.apache.org/jira/browse/FLINK-37256
Project: Flink
Issue Type: Impr
gaborgsomogyi merged PR #26035:
URL: https://github.com/apache/flink/pull/26035
--
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
boring-cyborg[bot] commented on PR #115:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/115#issuecomment-2636487184
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
[
https://issues.apache.org/jira/browse/FLINK-36660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36660:
---
Labels: pull-request-available (was: )
> Release flink-connector-elasticsearch vx.x.x for F
lvyanquan opened a new pull request, #115:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/115
Bump Flink version to 2.0-preview1.
--
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 t
Zakelly merged PR #26106:
URL: https://github.com/apache/flink/pull/26106
--
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.apach
Zakelly commented on PR #26093:
URL: https://github.com/apache/flink/pull/26093#issuecomment-2636492172
Thanks. 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 comment.
T
[
https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923962#comment-17923962
]
Zakelly Lan edited comment on FLINK-37021 at 2/5/25 11:38 AM:
Zakelly merged PR #26093:
URL: https://github.com/apache/flink/pull/26093
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924034#comment-17924034
]
Zakelly Lan commented on FLINK-37222:
-
Master:
* ac4f5952d5dd47e09644681b8f0fbf2b46a
Zakelly merged PR #26104:
URL: https://github.com/apache/flink/pull/26104
--
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.apach
XComp commented on code in PR #26111:
URL: https://github.com/apache/flink/pull/26111#discussion_r1943202076
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java:
##
@@ -878,8 +879,12 @@ public CompletableFuture
requestMultipleJobDetails(Duration
davidradl commented on code in PR #26111:
URL: https://github.com/apache/flink/pull/26111#discussion_r1943263854
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -1225,7 +1257,16 @@ public void testOverridingJobVertexParallelisms() th
[
https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37234:
--
Assignee: Yanquan Lv
> Add timeout for test case to avoid Infinite waiting
> ---
leonardBang merged PR #154:
URL: https://github.com/apache/flink-connector-jdbc/pull/154
--
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-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37234:
---
Labels: pull-request-available (was: )
> Add timeout for test case to avoid Infinite waitin
boring-cyborg[bot] commented on PR #154:
URL:
https://github.com/apache/flink-connector-jdbc/pull/154#issuecomment-2638952636
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Weijie Guo created FLINK-37263:
--
Summary: AggregateITCase.testConstantGroupKeyWithUpsertSink failed
Key: FLINK-37263
URL: https://issues.apache.org/jira/browse/FLINK-37263
Project: Flink
Issue T
yuxiqian commented on PR #3911:
URL: https://github.com/apache/flink-cdc/pull/3911#issuecomment-2638961294
Would @leonardBang and @whhe like to take a look?
--
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
lsyldliu commented on code in PR #26064:
URL: https://github.com/apache/flink/pull/26064#discussion_r1944182747
##
docs/content.zh/docs/dev/table/materialized-table/statements.md:
##
@@ -326,6 +328,67 @@ ALTER MATERIALIZED TABLE my_materialized_table REFRESH
PARTITION (ds='2024
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
"ElasticsearchEmitter" has not method named "static", it should be
"static_index
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
"ElasticsearchEmitter" has no method named "static", it should be
"static_index"
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924371#comment-17924371
]
Weijie Guo commented on FLINK-33555:
https://dev.azure.com/apache-flink/apache-flink
yuxiqian opened a new pull request, #3911:
URL: https://github.com/apache/flink-cdc/pull/3911
This PR mainly focuses on improving test case effectiveness by:
* Single-stage CI failure should not cause the whole matrix got cancelled
* Removed vulnerable & unmaintained FastJson from t
xuhuang created FLINK-37264:
---
Summary: two bugs of DSv2
Key: FLINK-37264
URL: https://issues.apache.org/jira/browse/FLINK-37264
Project: Flink
Issue Type: New Feature
Components: API / Da
flinkbot commented on PR #26112:
URL: https://github.com/apache/flink/pull/26112#issuecomment-2639023195
## CI report:
* e0f529506e5225fce4b103fcb81eabc903ebea4f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dianfu merged PR #26058:
URL: https://github.com/apache/flink/pull/26058
--
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
dianfu merged PR #26059:
URL: https://github.com/apache/flink/pull/26059
--
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-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
"ElasticsearchEmitter" has no method named "ElasticsearchEmitter.static", it
sho
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
There is no method named "ElasticsearchEmitter.static", it should be
"Elasticsea
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Affects Version/s: (was: 1.17.0)
(was: 1.18.0)
dianfu merged PR #26060:
URL: https://github.com/apache/flink/pull/26060
--
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-37205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-37205.
---
Fix Version/s: 2.0.0
1.19.2
1.20.2
Resolution: Fixed
Fixed in:
codenohup opened a new pull request, #26112:
URL: https://github.com/apache/flink/pull/26112
## What is the purpose of the change
Fix two bugs of DataStream V2:
1. When joining two tuple DataStreams using JoinExtension, an exception is
thrown "Tuple needs to be parameterized by usi
[
https://issues.apache.org/jira/browse/FLINK-37264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37264:
---
Labels: pull-request-available (was: )
> two bugs of DSv2
>
>
>
reswqa opened a new pull request, #210:
URL: https://github.com/apache/flink-docker/pull/210
(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-
1 - 100 of 195 matches
Mail list logo
