[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811156#comment-17811156
]
Mason Chen commented on FLINK-33545:
I do think this issue here is not with the Flin
Jiabao-Sun closed pull request #24092: [FLINK-34087][tests][JUnit5 Migration]
Migarate to junit5 of flink-dist module
URL: https://github.com/apache/flink/pull/24092
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-34087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-34087.
Resolution: Duplicate
Resolved by FLIK-33577
> [JUnit5 Migration] Module: flink-dist
> --
[
https://issues.apache.org/jira/browse/FLINK-34087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811158#comment-17811158
]
Jiabao Sun edited comment on FLINK-34087 at 1/26/24 8:10 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811160#comment-17811160
]
Martijn Visser commented on FLINK-34237:
[~leonard] I know, I just wanted to hig
Jiabao-Sun commented on code in PR #88:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/88#discussion_r1467341955
##
pom.xml:
##
@@ -339,6 +339,13 @@ under the License.
2.1
+
+
yunfengzhou-hub commented on PR #24151:
URL: https://github.com/apache/flink/pull/24151#issuecomment-1911659275
Hi @reswqa could you please take a look at this PR?
--
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-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34225:
---
Labels: github-actions pull-request-available test-stability (was:
github-actions test-stab
[
https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-31953:
---
Release Note: In kafka-3.1.0, we enable partition discovery by default and
set EARLIEST offs
[
https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-31953:
---
Fix Version/s: kafka-3.1.0
(was: kafka-4.0.0)
> FLIP-288: Enable Dyna
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25509:
---
Fix Version/s: kafka-4.0.0
> FLIP-208: Add RecordEvaluator to dynamically stop source based
[
https://issues.apache.org/jira/browse/FLINK-32020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32020:
---
Fix Version/s: kafka-3.1.0
(was: kafka-4.0.0)
> Enable Dynamic Partit
[
https://issues.apache.org/jira/browse/FLINK-32021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32021:
---
Fix Version/s: kafka-3.1.0
(was: kafka-4.0.0)
> Improvement the Javad
[
https://issues.apache.org/jira/browse/FLINK-32019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32019:
---
Fix Version/s: kafka-3.1.0
(was: kafka-4.0.0)
> EARLIEST offset strat
reswqa commented on code in PR #24151:
URL: https://github.com/apache/flink/pull/24151#discussion_r1467354290
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/UnionResultSubpartitionView.java:
##
@@ -71,18 +73,35 @@ public class UnionResultSubpartitio
reswqa commented on PR #24187:
URL: https://github.com/apache/flink/pull/24187#issuecomment-1911677206
Thanks for the review. 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 speci
reswqa merged PR #24187:
URL: https://github.com/apache/flink/pull/24187
--
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-34204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34204:
---
Fix Version/s: 1.19.0
> Dispatch legacy serializer related methods in ExecutionConfig to
> Serializ
[
https://issues.apache.org/jira/browse/FLINK-34204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34204:
---
Component/s: API / Type Serialization System
> Dispatch legacy serializer related methods in Executi
[
https://issues.apache.org/jira/browse/FLINK-34204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34204:
---
Description: Since we already support set serializer related things via
config options, we need to d
[
https://issues.apache.org/jira/browse/FLINK-34204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34204.
--
Resolution: Done
master(1.19) via 8d5071984a8543a81574dc69c0c9849a8a4a
> Dispatch legacy serializ
[
https://issues.apache.org/jira/browse/FLINK-34204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-34204:
--
Assignee: Weijie Guo
> Dispatch legacy serializer related methods in ExecutionConfig to
> Se
[
https://issues.apache.org/jira/browse/FLINK-34217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-34217:
--
Assignee: Zhanghao Chen
> Update Serialization-related doc with the new way of configuration
[
https://issues.apache.org/jira/browse/FLINK-34122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-34122:
--
Assignee: Zhanghao Chen (was: Weijie Guo)
> Deprecate old serialization config methods and o
[
https://issues.apache.org/jira/browse/FLINK-34122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34122:
---
Fix Version/s: 1.19.0
> Deprecate old serialization config methods and options
> ---
[
https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811167#comment-17811167
]
xuyang commented on FLINK-34129:
If the upstream CDC data is incomplete, such as receivi
[
https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811170#comment-17811170
]
Leonard Xu commented on FLINK-34237:
[~martijnvisser] Got you. Btw, I think external
[
https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811171#comment-17811171
]
Martijn Visser commented on FLINK-34237:
[~leonard] I think that makes sense. In
pvary commented on PR #24191:
URL: https://github.com/apache/flink/pull/24191#issuecomment-1911704026
@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.
To
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1467385245
##
.github/workflows/ci.yml:
##
@@ -49,8 +50,18 @@ jobs:
-Plicense-check \
| tee ${{ env.MVN_BUILD_OUTPUT_FILE }}
+ mvn ${MVN
[
https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811178#comment-17811178
]
Leonard Xu commented on FLINK-34237:
+1 to record this to release wiki docs, I'll cr
swuferhong commented on code in PR #24077:
URL: https://github.com/apache/flink/pull/24077#discussion_r1467388040
##
docs/content.zh/docs/dev/table/sql/queries/hints.md:
##
@@ -108,6 +108,39 @@ hintOption:
| stringLiteral
```
+### 查询提示使用中的冲突
+ Key-value 类型查询提示的冲突处理
swuferhong commented on code in PR #24077:
URL: https://github.com/apache/flink/pull/24077#discussion_r1467389305
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -114,6 +114,42 @@ hintOption:
| stringLiteral
```
+### Conflict Cases In Query Hints
+ Resol
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1467389710
##
.github/workflows/ci.yml:
##
@@ -49,8 +50,18 @@ jobs:
-Plicense-check \
| tee ${{ env.MVN_BUILD_OUTPUT_FILE }}
+ mvn ${MVN
snuyanzin commented on PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#issuecomment-1911714197
rebased since have to extract license related update into a separate commit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Leonard Xu created FLINK-34241:
--
Summary: Transfer external connectors's CI result to Flink Slack
#builds channel
Key: FLINK-34241
URL: https://issues.apache.org/jira/browse/FLINK-34241
Project: Flink
swuferhong commented on code in PR #24077:
URL: https://github.com/apache/flink/pull/24077#discussion_r1467393456
##
docs/content.zh/docs/dev/table/sql/queries/hints.md:
##
@@ -108,6 +108,39 @@ hintOption:
| stringLiteral
```
+### 查询提示使用中的冲突
+ Key-value 类型查询提示的冲突处理
[
https://issues.apache.org/jira/browse/FLINK-34238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811180#comment-17811180
]
Benchao Li commented on FLINK-34238:
Make sense to me. Another general way is to let
Jiabao-Sun commented on PR #88:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/88#issuecomment-1911718884
CI passes locally
https://github.com/Jiabao-Sun/flink-connector-elasticsearch/actions/runs/7665812325/job/20892471652.
@MartijnVisser please help take a look. Than
TanYuxin-tyx commented on code in PR #24151:
URL: https://github.com/apache/flink/pull/24151#discussion_r1467398883
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/UnionResultSubpartitionView.java:
##
@@ -71,18 +73,35 @@ public class UnionResultSubpa
TanYuxin-tyx commented on PR #24151:
URL: https://github.com/apache/flink/pull/24151#issuecomment-1911725587
@yunfengzhou-hub Thanks for the fix. I left some minor comments. PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Leonard Xu created FLINK-34242:
--
Summary: External connector should bump its flink version timely
after a new flink release
Key: FLINK-34242
URL: https://issues.apache.org/jira/browse/FLINK-34242
Proje
hlteoh37 commented on PR #22614:
URL: https://github.com/apache/flink/pull/22614#issuecomment-1911735572
@elphastori Thanks for the contribution - have we done any form of
validation in the final artifact produced to verify the plugin works the same
way in the new version?
Overall
[
https://issues.apache.org/jira/browse/FLINK-34241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34241:
---
Description:
As we discussed in FLINK-34237, we could timely found some blocker issue by
monitoring
leonardBang commented on PR #23777:
URL: https://github.com/apache/flink/pull/23777#issuecomment-1911749157
> @leonardBang , thanks for sharing your concerns, I understand where they
are coming from. Here are my thoughts:
>
> * This is probably the trickiest source to migrate, since i
[
https://issues.apache.org/jira/browse/FLINK-34241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811184#comment-17811184
]
Zhongqiang Gong commented on FLINK-34241:
-
[~leonard] I'm willing to take this i
leonardBang merged PR #24195:
URL: https://github.com/apache/flink/pull/24195
--
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
davidradl commented on PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#issuecomment-1911754647
> > @libenchao a question to you before merging `squash` also removed the
info about all the authors, are you ok if I add you as a co-author since it is
based on your work? Or
xintongsong closed pull request #24197: [FLINK-34237] Revert the breaking
changes to SourceReaderContext
URL: https://github.com/apache/flink/pull/24197
--
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
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-34117.
Fix Version/s: 1.18.2
Resolution: Fixed
Fixed via
master: 1d0f34e5a4a9127724bd09ecd0d9c0c0
[
https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-34237.
Resolution: Fixed
master (1.19): d0829ba3b162c24f2655b35258c9a8dc61cdba67
> MongoDB connector com
leonardBang merged PR #5:
URL: https://github.com/apache/flink/pull/5
--
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-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-31511.
Resolution: Implemented
Resolved via master: 36feab0fb6db9ba2e284352a19db8925cb6e8874
> Translate
[
https://issues.apache.org/jira/browse/FLINK-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-31511:
---
Affects Version/s: 1.18.1
(was: 1.17.0)
> Translate documentation sql_fun
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811194#comment-17811194
]
Stefan Richter commented on FLINK-34200:
[~fanrui] I think you misunderstood my
[
https://issues.apache.org/jira/browse/FLINK-34241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811195#comment-17811195
]
Zhongqiang Gong commented on FLINK-34241:
-
Hi [~leonard] ,
This should add bot
[
https://issues.apache.org/jira/browse/FLINK-34241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34241:
--
Assignee: Zhongqiang Gong
> Transfer external connectors's CI result to Flink Slack #builds c
XComp commented on PR #24133:
URL: https://github.com/apache/flink/pull/24133#issuecomment-1911798162
@X-czh thanks for discovering the compilation error that was merged into
`master`. Could you merge the hotfix commit separately from the bigger change
of this PR? The hotfix commit doesn't
zhuzhurk commented on PR #24186:
URL: https://github.com/apache/flink/pull/24186#issuecomment-1911805813
@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.
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1467476574
##
.github/workflows/ci.yml:
##
@@ -49,8 +50,18 @@ jobs:
-Plicense-check \
| tee ${{ env.MVN_BUILD_OUTPUT_FILE }}
+ mvn ${MVN
echauchot commented on PR #24079:
URL: https://github.com/apache/flink/pull/24079#issuecomment-1911828089
I finally had time to take a look at this PR (reduced availability
nowadays). Thanks for all the diagnostics and chained fixes @dmvk and sorry for
missing the fact that pos was not upda
mxm commented on PR #755:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/755#issuecomment-1911834062
This looks good. Any further comments @gyfora?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
X-czh commented on PR #24133:
URL: https://github.com/apache/flink/pull/24133#issuecomment-1911838497
@XComp Thanks for the notice. We've already prepared another separate PR:
#24200 on it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
gyfora commented on PR #755:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/755#issuecomment-1911839594
🚢
--
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
gyfora merged PR #755:
URL: https://github.com/apache/flink-kubernetes-operator/pull/755
--
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
zhuzhurk commented on PR #24186:
URL: https://github.com/apache/flink/pull/24186#issuecomment-1911841522
@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-33803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33803.
--
Fix Version/s: kubernetes-operator-1.8.0
Resolution: Fixed
merged to main 0fa78d350bd4a6cf2ea5e
XComp merged PR #24200:
URL: https://github.com/apache/flink/pull/24200
--
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.
XComp commented on PR #24133:
URL: https://github.com/apache/flink/pull/24133#issuecomment-1911845153
Ah I see, thanks for the pointer. I approved and merge 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
U
zhuzhurk closed pull request #24194: [FLINK-34232][dist] Fix unsupported
env.java.home in configuration file.
URL: https://github.com/apache/flink/pull/24194
--
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 t
zhuzhurk closed pull request #24185: [FLINK-34223][dist] Introduce a migration
tool to transfer legacy config file to new config file.
URL: https://github.com/apache/flink/pull/24185
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/FLINK-34223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34223.
---
Assignee: Junrui Li
Resolution: Done
master/release-1.19:
8fceb101e7e45f3fdc9357019757230bd8c16aa7
>
[
https://issues.apache.org/jira/browse/FLINK-34232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34232.
---
Assignee: Junrui Li
Resolution: Fixed
Fixed in master/release-1.19:
e623c07f4e56fdef1bd8514ccd02df347a
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811220#comment-17811220
]
Rui Fan commented on FLINK-34200:
-
Sorry for the bother. If so, let us follow it in this
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467504153
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElectorITCase.java:
##
@@ -110,4 +114,67 @@ void testMultipleKubernetes
xishuaidelin commented on PR #24161:
URL: https://github.com/apache/flink/pull/24161#issuecomment-1911877304
@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 comme
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1467507163
##
flink-shaded-zookeeper-parent/flink-shaded-zookeeper-38/pom.xml:
##
@@ -128,6 +131,7 @@ under the License.
org.apache.zookeeper
snuyanzin commented on code in PR #136:
URL: https://github.com/apache/flink-shaded/pull/136#discussion_r1467507163
##
flink-shaded-zookeeper-parent/flink-shaded-zookeeper-38/pom.xml:
##
@@ -128,6 +131,7 @@ under the License.
org.apache.zookeeper
SinBex opened a new pull request, #24201:
URL: https://github.com/apache/flink/pull/24201
## What is the purpose of the change
* In order not to block the CI, we should to temporarily disable
CacheITCase#testRetryOnCorruptedClusterDataset, and it will be fixed in 1.19
test phase.*
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34206:
---
Labels: pull-request-available test-stability (was: test-stability)
> CacheITCase.testRetry
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811227#comment-17811227
]
xingbe commented on FLINK-34206:
[~mapohl] [~lincoln.86xy] [~zhuzh] We have located the
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34206:
---
Assignee: xingbe
> CacheITCase.testRetryOnCorruptedClusterDataset(Path) failed
> --
flinkbot commented on PR #24201:
URL: https://github.com/apache/flink/pull/24201#issuecomment-1911933355
## CI report:
* fbc5f514ab951067381a4e90e10244cd8a7c4943 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhuzhurk closed pull request #24201: [FLINK-34206][test] Temporarily disable
CacheITCase#testRetryOnCorruptedClusterDataset
URL: https://github.com/apache/flink/pull/24201
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
Matthias Pohl created FLINK-34243:
-
Summary: Update fabric8io:kubernetes-client to v6.9.0+ to allow
the usage of ReleaseOnCall
Key: FLINK-34243
URL: https://issues.apache.org/jira/browse/FLINK-34243
P
[
https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811231#comment-17811231
]
Zhu Zhu commented on FLINK-34206:
-
Disabled {{CacheITCase.testRetryOnCorruptedClusterDat
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467558102
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderElector(
[
https://issues.apache.org/jira/browse/FLINK-32609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811233#comment-17811233
]
dalongliu commented on FLINK-32609:
---
assigned to you
> Kafka table source supports pr
[
https://issues.apache.org/jira/browse/FLINK-32609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-32609:
-
Assignee: SuDewei
> Kafka table source supports projection push down
>
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467558102
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderElector(
wangyang0918 commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467574472
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderEle
[
https://issues.apache.org/jira/browse/FLINK-34193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34193:
---
Priority: Blocker (was: Critical)
> Remove usage of Flink-Shaded Jackson and Snakeyaml in f
wangyang0918 commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467574472
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderEle
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467582561
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderElector(
wangyang0918 commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467583895
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderEle
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467590709
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderElector(
MartijnVisser commented on PR #22320:
URL: https://github.com/apache/flink/pull/22320#issuecomment-1911985635
@zzzs Are you still working on this PR, or should someone take this over?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
MartijnVisser commented on PR #19873:
URL: https://github.com/apache/flink/pull/19873#issuecomment-1911986863
@snuyanzin Are you still working on finalizing this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467610608
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderElector(
XComp commented on code in PR #24132:
URL: https://github.com/apache/flink/pull/24132#discussion_r1467610608
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderElector.java:
##
@@ -86,12 +117,38 @@ public KubernetesLeaderElector(
1 - 100 of 212 matches
Mail list logo
