[
https://issues.apache.org/jira/browse/FLINK-33937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850604#comment-17850604
]
Pinrui Dong commented on FLINK-33937:
-
It is still unsolved. Could you please assign
[
https://issues.apache.org/jira/browse/FLINK-35461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-35461.
Fix Version/s: 1.20.0
Resolution: Done
master (1.20): 132722e1b43607fe2236ecbbc3ba1faad1ad1
[ https://issues.apache.org/jira/browse/FLINK-34953 ]
Zhongqiang Gong deleted comment on FLINK-34953:
-
was (Author: JIRAUSER301076):
Hi [~mapohl][~martijnvisser] , PR is ready, But the flink-web repo's ci is not
enabled. Myabe open a ticket
reswqa commented on code in PR #24863:
URL: https://github.com/apache/flink/pull/24863#discussion_r1620086895
##
docs/content.zh/docs/dev/configuration/maven.md:
##
@@ -28,7 +28,7 @@ under the License.
## 要求
-- Maven 3.8.6 (推荐或者使用更高版本)
Review Comment:
I means you should
reswqa commented on code in PR #24863:
URL: https://github.com/apache/flink/pull/24863#discussion_r1620086895
##
docs/content.zh/docs/dev/configuration/maven.md:
##
@@ -28,7 +28,7 @@ under the License.
## 要求
-- Maven 3.8.6 (推荐或者使用更高版本)
Review Comment:
I mean you should
JunRuiLee commented on code in PR #24855:
URL: https://github.com/apache/flink/pull/24855#discussion_r1620092964
##
docs/content.zh/docs/ops/batch/recovery_from_job_master_failure.md:
##
@@ -0,0 +1,96 @@
+---
+title: "Recovery job progress from job master failures"
+weight: 4
+t
JingGe merged PR #24860:
URL: https://github.com/apache/flink/pull/24860
--
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
JingGe merged PR #24861:
URL: https://github.com/apache/flink/pull/24861
--
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
JingGe merged PR #24862:
URL: https://github.com/apache/flink/pull/24862
--
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
JunRuiLee opened a new pull request, #24872:
URL: https://github.com/apache/flink/pull/24872
## What is the purpose of the change
Update the batch job recovery documentation.
## Brief change log
Update the batch job recovery documentation.
## Verify
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850610#comment-17850610
]
Jing Ge commented on FLINK-34379:
-
release-1.19: 663eeaf4092ed8c393b03ff6425f66559d97dc6
JunRuiLee commented on PR #24871:
URL: https://github.com/apache/flink/pull/24871#issuecomment-2138842524
@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.
flinkbot commented on PR #24872:
URL: https://github.com/apache/flink/pull/24872#issuecomment-2138847340
## CI report:
* 58afe98f5c86b46cc7ee5e774b3d1cef256d5ff9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
showuon commented on code in PR #24863:
URL: https://github.com/apache/flink/pull/24863#discussion_r1620118257
##
docs/content.zh/docs/dev/configuration/maven.md:
##
@@ -28,7 +28,7 @@ under the License.
## 要求
-- Maven 3.8.6 (推荐或者使用更高版本)
Review Comment:
My bad. Didn't ge
monologuist commented on PR #2959:
URL: https://github.com/apache/flink-cdc/pull/2959#issuecomment-2138861809
@lvyanquan hi，请问您这个PR，所预期的从savepoint重启Flink CDC Pipeline作业的规范命令是这样吗？
```
在${FLINK_CDC_HOME}目录下执行：
$ ./bin/flink-cdc.sh mysql-to-doris.yaml -s
/tmp/flink-savepoints/savep
[
https://issues.apache.org/jira/browse/FLINK-34613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34613:
---
Labels: pull-request-available (was: )
> allow specifing a savepoint file to restart using
XComp commented on PR #24471:
URL: https://github.com/apache/flink/pull/24471#issuecomment-2138868656
I'm not gonna wait for another CI round. Looks like the CI bot didn't pick
up the rerun command. Anyway, I verified that the test ran (see
[logs](https://dev.azure.com/apache-flink/apache-f
XComp commented on PR #24471:
URL: https://github.com/apache/flink/pull/24471#issuecomment-2138886095
One final thing: I wasn't able to do it myself somehow. Can you change the
commit message prefix from `[refactor]` to `[FLINK-20398]`? "refactor" isn't a
prefix the Flink community usually
Nicolas Fraison created FLINK-35489:
---
Summary: Add capability to set min taskmanager.memory.managed.size
when enabling autotuning
Key: FLINK-35489
URL: https://issues.apache.org/jira/browse/FLINK-35489
JunRuiLee commented on PR #24871:
URL: https://github.com/apache/flink/pull/24871#issuecomment-2138906588
@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.
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35121:
---
Labels: pull-request-available (was: )
> CDC pipeline connector should verify requiredOptio
morazow commented on PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#issuecomment-2139025700
Hey @loserwang1024,
Thanks for the suggestions! I was actually wondering about it.
Since this is only feature for Postgres, initially I considered adding it in
PostgresSQL
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850635#comment-17850635
]
Rui Fan commented on FLINK-35489:
-
Hi [~nfraison.datadog]
{quote}because we are relying
affo commented on PR #24471:
URL: https://github.com/apache/flink/pull/24471#issuecomment-2139041576
@XComp done!
Don't worry in any case, I loved the review process. This is my first
contribution and this is part of learning for next ones 🤝
--
This is an automated message from th
[
https://issues.apache.org/jira/browse/FLINK-33937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850604#comment-17850604
]
Pinrui Dong edited comment on FLINK-33937 at 5/30/24 8:40 AM:
eskabetxe commented on code in PR #123:
URL:
https://github.com/apache/flink-connector-jdbc/pull/123#discussion_r1620277111
##
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcFactory.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache
eskabetxe commented on code in PR #123:
URL:
https://github.com/apache/flink-connector-jdbc/pull/123#discussion_r1620277111
##
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcFactory.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache
jeyhunkarimov commented on code in PR #24845:
URL: https://github.com/apache/flink/pull/24845#discussion_r1620282539
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/SetSerializer.java:
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed to the Apache Software Foundation
eskabetxe commented on code in PR #123:
URL:
https://github.com/apache/flink-connector-jdbc/pull/123#discussion_r1620277111
##
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcFactory.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache
yuxiqian commented on PR #3364:
URL: https://github.com/apache/flink-cdc/pull/3364#issuecomment-2139108465
Hi @hk-lrzy, I've compiled Flink CDC on your branch and tried to verify this
patch by doing the following steps:
1. Create a MySQL source with tables (`alice`, `bob`, and `chris`
leonardBang commented on PR #24870:
URL: https://github.com/apache/flink/pull/24870#issuecomment-2139125612
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850662#comment-17850662
]
Muhammet Orazov commented on FLINK-34585:
-
Hey all,
Since this is lots of effor
Muhammet Orazov created FLINK-35490:
---
Summary: [JUnit5 Migration] Module: Flink CDC
flink-cdc-connect/flink-cdc-source-connectors
Key: FLINK-35490
URL: https://issues.apache.org/jira/browse/FLINK-35490
[
https://issues.apache.org/jira/browse/FLINK-35490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850663#comment-17850663
]
Muhammet Orazov commented on FLINK-35490:
-
I would be happy to work on this, ple
[
https://issues.apache.org/jira/browse/FLINK-32384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850664#comment-17850664
]
Kartikey Pant commented on FLINK-32384:
---
Hello [~zhuzh], I am eager to start contr
Muhammet Orazov created FLINK-35491:
---
Summary: [JUnit5 Migration] Module: Flink CDC modules
Key: FLINK-35491
URL: https://issues.apache.org/jira/browse/FLINK-35491
Project: Flink
Issue Type
1996fanrui commented on code in PR #119:
URL:
https://github.com/apache/flink-connector-jdbc/pull/119#discussion_r1620372109
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/ContinuousUnBoundingSettings.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to th
hk-lrzy commented on PR #3364:
URL: https://github.com/apache/flink-cdc/pull/3364#issuecomment-2139205095
> exception
got it, let me do the double check and give you reply asap.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
eskabetxe commented on code in PR #123:
URL:
https://github.com/apache/flink-connector-jdbc/pull/123#discussion_r1620403861
##
flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/JdbcFactory.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache
leonardBang merged PR #24870:
URL: https://github.com/apache/flink/pull/24870
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35484.
Resolution: Fixed
Fixed via master: b1841c0ff34b6e8d118139f6f87b7fdf06afacd3
> Flink document fil
kumar-mallikarjuna commented on PR #24544:
URL: https://github.com/apache/flink/pull/24544#issuecomment-2139268835
Done, @reswqa .
--
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 com
[
https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678
]
Naci Simsek edited comment on FLINK-33001 at 5/30/24 10:40 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678
]
Naci Simsek edited comment on FLINK-33001 at 5/30/24 10:41 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678
]
Naci Simsek commented on FLINK-33001:
-
Just be able to try with the *flink-connector
caicancai commented on code in PR #3383:
URL: https://github.com/apache/flink-cdc/pull/3383#discussion_r1620475491
##
.github/ISSUE_TEMPLATE/issue-notice.yml:
##
@@ -47,6 +50,8 @@ body:
感谢您选择 Flink CDC!
由于 Apache Flink 的要求，请在 [Apache Jira](https://issues.apa
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850694#comment-17850694
]
Nicolas Fraison commented on FLINK-35489:
-
Thks [~fanrui] for the feedback it he
twalthr commented on code in PR #24818:
URL: https://github.com/apache/flink/pull/24818#discussion_r1620578309
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java:
##
@@ -62,7 +62,7 @@ public boolean canFail(
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Fraison updated FLINK-35489:
Summary: Metaspace size can be too little after autotuning change memory
setting (was: Ad
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Fraison updated FLINK-35489:
Description:
We have enable the autotuning feature on one of our flink job with below conf
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Fraison updated FLINK-35489:
Description:
We have enable the autotuning feature on one of our flink job with below conf
[
https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850694#comment-17850694
]
Nicolas Fraison edited comment on FLINK-35489 at 5/30/24 12:07 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850700#comment-17850700
]
Weijie Guo commented on FLINK-30719:
{code:java}
The archive file
/__w/1/.m2/reposi
Mate Czagany created FLINK-35492:
Summary: Add metrics for FlinkStateSnapshot resources
Key: FLINK-35492
URL: https://issues.apache.org/jira/browse/FLINK-35492
Project: Flink
Issue Type: Sub-
Mate Czagany created FLINK-35493:
Summary: Make max history age and count configurable for
FlinkStateSnapshot resources
Key: FLINK-35493
URL: https://issues.apache.org/jira/browse/FLINK-35493
Project:
lsyldliu commented on code in PR #24866:
URL: https://github.com/apache/flink/pull/24866#discussion_r1620385497
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/materializedtable/MaterializedTableManager.java:
##
@@ -640,10 +750,15 @@ private
Zakelly commented on PR #90:
URL: https://github.com/apache/flink-benchmarks/pull/90#issuecomment-2139458543
> @Zakelly I've pushed
[decdc8e](https://github.com/apache/flink-benchmarks/commit/decdc8e2d161584a798461b4f381adba7cee731f)
which restores the JMH defaults from 1.19. Hopefully that
[
https://issues.apache.org/jira/browse/FLINK-33001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850678#comment-17850678
]
Naci Simsek edited comment on FLINK-33001 at 5/30/24 1:07 PM:
RocMarshal commented on PR #117:
URL:
https://github.com/apache/flink-connector-jdbc/pull/117#issuecomment-2139538600
Hi, @1996fanrui .
Kafka introduced KafkaSource API in the Flink 1.12 branch
https://issues.apache.org/jira/browse/FLINK-18323
Afterwards, in Flink version 1.14, Kafk
RocMarshal commented on code in PR #830:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1620723423
##
docs/content/docs/custom-resource/pod-template.md:
##
@@ -113,10 +112,10 @@ arr1: [{name: a, p2: v2}, {name: c, p2: v2}]
merged: [{name: a, p1:
uce merged PR #24859:
URL: https://github.com/apache/flink/pull/24859
--
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.or
hlteoh37 commented on PR #190:
URL: https://github.com/apache/flink-docker/pull/190#issuecomment-2139649509
Backport for Flink 1.19: https://github.com/apache/flink-docker/pull/191
Backport for Flink 1.18: https://github.com/apache/flink-docker/pull/192
Backport for Flink 1.17: https://
hlteoh37 commented on PR #190:
URL: https://github.com/apache/flink-docker/pull/190#issuecomment-2139650422
Appreciate if I could get your review please! @MartijnVisser or @lincoln-lil
:)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
hlteoh37 merged PR #24792:
URL: https://github.com/apache/flink/pull/24792
--
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.apac
hlteoh37 merged PR #24791:
URL: https://github.com/apache/flink/pull/24791
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850727#comment-17850727
]
Hong Liang Teoh commented on FLINK-35358:
-
merged commit
[{{853989b}}|https://
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850729#comment-17850729
]
Hong Liang Teoh commented on FLINK-35358:
-
merged commit
[{{90a71a1}}|https://g
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-35358:
Fix Version/s: 1.20.0
> Breaking change when loading artifacts
> -
[
https://issues.apache.org/jira/browse/FLINK-35367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
João Boto updated FLINK-35367:
--
Summary: Reorganize sinks (was: Reorganize datastream sink and source)
> Reorganize sinks
> -
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh closed FLINK-34379.
---
Resolution: Fixed
> table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError
> ---
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-35358.
-
Resolution: Fixed
> Breaking change when loading artifacts
> ---
[
https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850730#comment-17850730
]
Hong Liang Teoh commented on FLINK-34379:
-
Closing Jira as patch has been comple
hlteoh37 commented on PR #191:
URL: https://github.com/apache/flink-docker/pull/191#issuecomment-2139676975
Thanks @MartijnVisser. Merging the PR
--
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 t
hlteoh37 merged PR #191:
URL: https://github.com/apache/flink-docker/pull/191
--
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.a
hlteoh37 merged PR #192:
URL: https://github.com/apache/flink-docker/pull/192
--
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.a
hlteoh37 merged PR #193:
URL: https://github.com/apache/flink-docker/pull/193
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-34746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850732#comment-17850732
]
Hong Liang Teoh commented on FLINK-34746:
-
merged commit
[{{7f63237}}|https://
[
https://issues.apache.org/jira/browse/FLINK-32384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850734#comment-17850734
]
Zhu Zhu commented on FLINK-32384:
-
Thanks for volunteering to contribute to Flink. [~kar
zhuzhurk merged PR #24872:
URL: https://github.com/apache/flink/pull/24872
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850739#comment-17850739
]
Zhu Zhu commented on FLINK-35399:
-
56cd9607713d0da874dcc54c4cf6d5b3b52b1050 refined the
potterxu commented on PR #24858:
URL: https://github.com/apache/flink/pull/24858#issuecomment-2139841619
Hi @swuferhong @luoyuxia , would you mind take a look at the above changes
in doc? Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
zhuzhurk commented on code in PR #24871:
URL: https://github.com/apache/flink/pull/24871#discussion_r1620899559
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java:
##
@@ -257,6 +260,11 @@ void testRecoverFromJMFailover() thr
reta commented on code in PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#discussion_r1621010106
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java:
##
@@ -21,86 +21,144 @
reta commented on code in PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#discussion_r1621010106
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java:
##
@@ -21,86 +21,144 @
João Boto created FLINK-35494:
-
Summary: Reorganize sources
Key: FLINK-35494
URL: https://issues.apache.org/jira/browse/FLINK-35494
Project: Flink
Issue Type: Sub-task
Reporter: João
liuml07 commented on code in PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#discussion_r1621057382
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java:
##
@@ -21,86 +21,14
reta commented on code in PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#discussion_r1621068383
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java:
##
@@ -21,86 +21,144 @
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850841#comment-17850841
]
Brad Atcheson commented on FLINK-34023:
---
[Here's](https://github.com/brada/flink-c
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850841#comment-17850841
]
Brad Atcheson edited comment on FLINK-34023 at 5/30/24 7:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850841#comment-17850841
]
Brad Atcheson edited comment on FLINK-34023 at 5/30/24 7:28 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-34023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850841#comment-17850841
]
Brad Atcheson edited comment on FLINK-34023 at 5/30/24 7:28 PM:
--
GOODBOY008 commented on PR #24685:
URL: https://github.com/apache/flink/pull/24685#issuecomment-2140991378
@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
GOODBOY008 commented on PR #24685:
URL: https://github.com/apache/flink/pull/24685#issuecomment-2141075315
@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
monologuist commented on PR #2959:
URL: https://github.com/apache/flink-cdc/pull/2959#issuecomment-2141075378
> @lvyanquan hi，请问您这个PR，所预期的从savepoint重启Flink CDC Pipeline作业的规范命令是这样吗？
>
> ```
> 在${FLINK_CDC_HOME}目录下执行：
> $ ./bin/flink-cdc.sh mysql-to-doris.yaml -s
/tmp/flink-savepo
[
https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850890#comment-17850890
]
Zhongqiang Gong commented on FLINK-35484:
-
After build document ci scheduled，I c
[
https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850890#comment-17850890
]
Zhongqiang Gong edited comment on FLINK-35484 at 5/31/24 1:31 AM:
[
https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850890#comment-17850890
]
Zhongqiang Gong edited comment on FLINK-35484 at 5/31/24 1:31 AM:
1996fanrui commented on PR #117:
URL:
https://github.com/apache/flink-connector-jdbc/pull/117#issuecomment-2141086375
> Maybe we should revert this commit and re-commit it in the next second or
third version
Sounds make sense to me. The JdbcSource is introduced in the current
versio
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850892#comment-17850892
]
Rui Fan commented on FLINK-33463:
-
After discuss with [~RocMarshal] , it's better to sup
[
https://issues.apache.org/jira/browse/FLINK-35483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850894#comment-17850894
]
Weijie Guo commented on FLINK-35483:
https://dev.azure.com/apache-flink/apache-flink
1 - 100 of 124 matches
Mail list logo
