[
https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646483#comment-17646483
]
Sergey Nuyanzin commented on FLINK-26603:
-
I'm playing around this area.
I also
[
https://issues.apache.org/jira/browse/FLINK-30395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30395:
---
Labels: pull-request-available (was: )
> Refactor module name and documentation for filesys
JingsongLi opened a new pull request, #434:
URL: https://github.com/apache/flink-table-store/pull/434
- flink-table-store-filesystem => flink-table-store-filesystems
- flink-table-store-fs-oss-hadoop => flink-table-store-oss
- introduce a new page for oss only
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-30395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-30395:
-
Description:
* flink-table-store-filesystem => flink-table-store-filesystems
* flink-table-store
Jingsong Lee created FLINK-30395:
Summary: Refactor module name and documentation for filesystems
Key: FLINK-30395
URL: https://issues.apache.org/jira/browse/FLINK-30395
Project: Flink
Issue
Jingsong Lee created FLINK-30394:
Summary: [umbrella] Refactor filesystem support in table store
Key: FLINK-30394
URL: https://issues.apache.org/jira/browse/FLINK-30394
Project: Flink
Issue T
mas-chen commented on PR #1:
URL:
https://github.com/apache/flink-connector-kafka/pull/1#issuecomment-1347881826
@zentol It's failing after I un-ignored the e2e test. There's an issue
related with initializing the Docker image--I'm actively looking at it
--
This is an automated message f
tsreaper commented on code in PR #433:
URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046746710
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreCompactOperator.java:
##
@@ -18,99 +18,70 @@
package org.apach
[
https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646407#comment-17646407
]
Jane Chan edited comment on FLINK-30386 at 12/13/22 7:23 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-27284:
---
Affects Version/s: 1.15.0
> KafkaSinkITCase$IntegrationTests.testScaleUp failed on azures due to fai
[
https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646472#comment-17646472
]
Leonard Xu commented on FLINK-27284:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-27284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646472#comment-17646472
]
Leonard Xu edited comment on FLINK-27284 at 12/13/22 7:21 AM:
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646471#comment-17646471
]
Leonard Xu commented on FLINK-29859:
https://dev.azure.com/apache-flink/apache-flink
Qingsheng Ren created FLINK-30393:
-
Summary: PulsarSourceUnorderedE2ECase.testScaleDown failed with
TimeoutException
Key: FLINK-30393
URL: https://issues.apache.org/jira/browse/FLINK-30393
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646470#comment-17646470
]
Leonard Xu commented on FLINK-29755:
https://dev.azure.com/apache-flink/apache-flink
flinkbot commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1347844200
## CI report:
* 05ff3323e5988e809d1270ecb691e04365b0bc4b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30370:
---
Labels: pull-request-available (was: )
> Move existing delegation token framework authentic
gaborgsomogyi commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1347836663
cc @mbalassi
--
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.
gaborgsomogyi opened a new pull request, #21499:
URL: https://github.com/apache/flink/pull/21499
## What is the purpose of the change
In order to make a generic delegation token manager all authentication
specific things must be extracted. This is such a step. In this PR I've moved
K
[
https://issues.apache.org/jira/browse/FLINK-30381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30381:
---
Labels: pull-request-available (was: )
> Bump minikube kubernetes version for operator
> --
gaborgsomogyi commented on PR #483:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/483#issuecomment-1347835044
cc @mbalassi @gyfora
--
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
gaborgsomogyi opened a new pull request, #483:
URL: https://github.com/apache/flink-kubernetes-operator/pull/483
## What is the purpose of the change
The operator uses a quite old version of kubernetes for minikube. The latest
supported version is v1.25.3. I've bumped it.
## Br
1996fanrui commented on PR #21447:
URL: https://github.com/apache/flink/pull/21447#issuecomment-1347816498
Hi @xintongsong , the PR is ready, and I have updated some pictures here.
Please help take a look in your free time, thanks~
I will update the doc after you think it's ok.
--
1996fanrui commented on PR #21447:
URL: https://github.com/apache/flink/pull/21447#issuecomment-1347814792
The flame graph with this PR:
FlameGraph of all subtasks:
https://user-images.githubusercontent.com/38427477/207243774-9fc3ff2d-5c39-4643-81e4-b9387367d6fd.png";>
c
swathic95 commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046639775
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconciler.java:
##
@@ -96,6 +96,19 @@ p
swathic95 commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046706450
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -171,11 +170,6 @@ protecte
huwh commented on PR #21496:
URL: https://github.com/apache/flink/pull/21496#issuecomment-1347807741
@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
huwh commented on PR #21496:
URL: https://github.com/apache/flink/pull/21496#issuecomment-1347802296
@xintongsong Could you please help review this PR in your free time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
flinkbot commented on PR #21498:
URL: https://github.com/apache/flink/pull/21498#issuecomment-1347801647
## CI report:
* 42ea3e7ac469f3f133cb3672953e675286193a9d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30392:
---
Labels: pull-request-available (was: )
> Increase the default value of cluster.thread-dump.
yuchen-ecnu opened a new pull request, #21498:
URL: https://github.com/apache/flink/pull/21498
## What is the purpose of the change
Currently, the thread dump function still have the default stack-trace depth
as 8, which is the same as before. However, the default value is really too
mattfysh commented on PR #21254:
URL: https://github.com/apache/flink/pull/21254#issuecomment-1347782454
Is there a desire within the Flink team to ensure that PyFlink achieves
similar uptake and robustness as PySpark?
--
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/FLINK-30253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-30253.
Resolution: Invalid
[~masteryhx] Thanks for your information, this ticket has been outdated.
> Introduce
flinkbot commented on PR #21497:
URL: https://github.com/apache/flink/pull/21497#issuecomment-1347775653
## CI report:
* e4b1f9b8078d9904f2b92f55de472a4fe6089d62 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingsongLi commented on code in PR #433:
URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046677047
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriteImpl.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-30377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30377:
---
Labels: pull-request-available (was: )
> CommonExecSink does not use ClientWrapperClassLoad
Samrat002 opened a new pull request, #21497:
URL: https://github.com/apache/flink/pull/21497
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
JingsongLi commented on code in PR #433:
URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046674425
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreCompactOperator.java:
##
@@ -18,99 +18,70 @@
package org.apa
JingsongLi commented on code in PR #433:
URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046673855
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreCompactOperator.java:
##
@@ -18,99 +18,70 @@
package org.apa
KarlManong commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1347767412
@Samrat002 will this patch port to 1.15, I see
https://issues.apache.org/jira/browse/FLINK-28729 reported
--
This is an automated message from the Apache Git Service.
To respond to t
Myasuka commented on code in PR #21485:
URL: https://github.com/apache/flink/pull/21485#discussion_r1046670197
##
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html:
##
@@ -181,7 +186,19 @@
{{ subTask['unaligne
[
https://issues.apache.org/jira/browse/FLINK-29998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-29998.
--
Resolution: Fixed
merged in master: b6c5534efc8a4b59c3f0993777aa8119af205f0c
> Make the backpressure
Myasuka merged PR #21466:
URL: https://github.com/apache/flink/pull/21466
--
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-30392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-30392:
Assignee: Yu Chen
> Increase the default value of cluster.thread-dump.stacktrace-max-depth
>
Yun Tang created FLINK-30392:
Summary: Increase the default value of
cluster.thread-dump.stacktrace-max-depth
Key: FLINK-30392
URL: https://issues.apache.org/jira/browse/FLINK-30392
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-30367.
Resolution: Duplicate
> Enrich the thread dump info with deeper stack
> --
[
https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646443#comment-17646443
]
Yun Tang commented on FLINK-30367:
--
[~pvary] Thanks for the information, I did not noti
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb closed FLINK-30318.
--
Resolution: Invalid
> sql-client failed to load jar passed with -j args in flink 1.16.0
> ---
[
https://issues.apache.org/jira/browse/FLINK-30391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-30391:
---
Description:
passing custom jars for sql-client using -j and -l doesn't gets listed in `show
jars`
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29419.
Resolution: Fixed
> HybridShuffleITCase.testHybridFullExchangesRestart hangs
> ---
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646422#comment-17646422
]
Xintong Song commented on FLINK-29419:
--
Both FLINK-29298 and FLINK-30189 have been
JingsongLi commented on code in PR #433:
URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046652886
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWrite.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-29419:
-
Fix Version/s: 1.17.0
1.16.1
> HybridShuffleITCase.testHybridFullExchangesRes
[
https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29923.
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
Should have been fixed by
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29298.
Fix Version/s: 1.16.1
Resolution: Fixed
- master (1.17): 875f27ef38af20d2548d225c0583ebffe0
xintongsong closed pull request #20924: [FLINK-29298] LocalBufferPool request
buffer from NetworkBufferPool hanging.
URL: https://github.com/apache/flink/pull/20924
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
swathic95 commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046639775
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconciler.java:
##
@@ -96,6 +96,19 @@ p
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646412#comment-17646412
]
Samrat Deb edited comment on FLINK-30318 at 12/13/22 4:05 AM:
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646412#comment-17646412
]
Samrat Deb edited comment on FLINK-30318 at 12/13/22 4:04 AM:
Samrat Deb created FLINK-30391:
--
Summary: show jars command doesn't list client wrapper classloader
loaded jars
Key: FLINK-30391
URL: https://issues.apache.org/jira/browse/FLINK-30391
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646412#comment-17646412
]
Samrat Deb commented on FLINK-30318:
Thank you [~luoyuxia] , for spending time and l
[
https://issues.apache.org/jira/browse/FLINK-30373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30373.
Resolution: Fixed
master: 3e47657054e75d714cd941f502a899e5059cffac
> Flink-table-runtime free for
JingsongLi merged PR #432:
URL: https://github.com/apache/flink-table-store/pull/432
--
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-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646407#comment-17646407
]
Jane Chan commented on FLINK-30386:
---
Would you help verify this issue, is it a bug or
[
https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29461.
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
Merged into master via 4d
HuangXingBo closed pull request #21491: [FLINK-29461][python] Make the
test_process_function more stable
URL: https://github.com/apache/flink/pull/21491
--
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
flinkbot commented on PR #21496:
URL: https://github.com/apache/flink/pull/21496#issuecomment-1347680384
## CI report:
* 04536f0f108d0fd0e16257aa94cbdb272420f10e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhipeng93 merged PR #190:
URL: https://github.com/apache/flink-ml/pull/190
--
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
zhipeng93 commented on PR #190:
URL: https://github.com/apache/flink-ml/pull/190#issuecomment-1347676182
Thanks for the PR. LGTM.
--
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
[
https://issues.apache.org/jira/browse/FLINK-29869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29869:
---
Labels: pull-request-available (was: )
> make ResourceActions declarative
> --
huwh opened a new pull request, #21496:
URL: https://github.com/apache/flink/pull/21496
## What is the purpose of the change
This pull request makes ResourceAllocator declarative in order to reduce the
coupling between the SlotManager and the ResourceManager
## Brief ch
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646402#comment-17646402
]
luoyuxia commented on FLINK-30318:
--
[~samrat007] Hi, thanks for investigation. To me, s
yuzelin commented on code in PR #21187:
URL: https://github.com/apache/flink/pull/21187#discussion_r1046601074
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/context/SessionContextTest.java:
##
@@ -133,6 +139,70 @@ public void testSetAndRes
zjureel commented on PR #432:
URL:
https://github.com/apache/flink-table-store/pull/432#issuecomment-1347661426
> > Hi @JingsongLi Left one minor comment
> > In addition, I found that `flink-table-store-codegen` module still
depends on `flink-table-runtime` in `pom.xml`, is it OK?
>
yuzelin commented on code in PR #21187:
URL: https://github.com/apache/flink/pull/21187#discussion_r1046600712
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -405,4 +444,22 @@ private Set listViews(St
lindong28 merged PR #171:
URL: https://github.com/apache/flink-ml/pull/171
--
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
lindong28 commented on PR #171:
URL: https://github.com/apache/flink-ml/pull/171#issuecomment-1347660877
Thanks for the PR! LGTM.
--
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
yuzelin commented on code in PR #21187:
URL: https://github.com/apache/flink/pull/21187#discussion_r1046600266
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -144,19 +145,29 @@ public ResultFetcher ex
yuzelin commented on code in PR #21187:
URL: https://github.com/apache/flink/pull/21187#discussion_r1046600050
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java:
##
@@ -128,6 +137,26 @@ public SessionState getSessio
yuzelin commented on code in PR #21187:
URL: https://github.com/apache/flink/pull/21187#discussion_r1046597242
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java:
##
@@ -128,6 +137,26 @@ public SessionState getSessio
Jingsong Lee created FLINK-30390:
Summary: Ensure that no compaction is in progress before closing
the writer
Key: FLINK-30390
URL: https://issues.apache.org/jira/browse/FLINK-30390
Project: Flink
yunfengzhou-hub commented on code in PR #189:
URL: https://github.com/apache/flink-ml/pull/189#discussion_r1046592801
##
docs/content/docs/operators/feature/randomsplitter.md:
##
@@ -34,6 +34,7 @@ An AlgoOperator which splits a table into N tables according
to the given weight
[
https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646395#comment-17646395
]
Jane Chan edited comment on FLINK-30386 at 12/13/22 2:18 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646395#comment-17646395
]
Jane Chan commented on FLINK-30386:
---
Re [~dwysakowicz] . The `NOT ENFORCED` check only
swuferhong commented on PR #21490:
URL: https://github.com/apache/flink/pull/21490#issuecomment-1347641325
Caicite jira link: https://issues.apache.org/jira/browse/CALCITE-5431
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-30389:
-
Description:
For the oss (object store) filesystem. When writing hint file, delete it first
and
Jingsong Lee created FLINK-30389:
Summary: Add retry to read hints
Key: FLINK-30389
URL: https://issues.apache.org/jira/browse/FLINK-30389
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Echo Lee updated FLINK-30371:
-
Description:
When writing to the target table fails for some reason, for example, the target
table does
[
https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Echo Lee updated FLINK-30371:
-
Description:
When writing to the target table fails for some reason, for example, the target
table does
[
https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Echo Lee updated FLINK-30371:
-
Description:
When writing to the target table fails for some reason, for example, the target
table does
JingsongLi commented on PR #432:
URL:
https://github.com/apache/flink-table-store/pull/432#issuecomment-1347634926
> Hi @JingsongLi Left one minor comment
>
> In addition, I found that `flink-table-store-codegen` module still depends
on `flink-table-runtime` in `pom.xml`, is it OK?
JingsongLi commented on code in PR #432:
URL: https://github.com/apache/flink-table-store/pull/432#discussion_r1046583371
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/codegen/Projection.java:
##
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software F
[
https://issues.apache.org/jira/browse/FLINK-30360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646391#comment-17646391
]
Jichao Wang commented on FLINK-30360:
-
cc [~jark] , Can you help me confirm if this
[
https://issues.apache.org/jira/browse/FLINK-29655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-29655:
-
Assignee: Márton Balassi (was: Zhenqiu Huang)
> Split Flink CRD from flink-kubernates-
[
https://issues.apache.org/jira/browse/FLINK-29632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-29632:
-
Assignee: Jeesmon Jacob
> Support nodeSelector in helm template for flink operator depl
[
https://issues.apache.org/jira/browse/FLINK-29853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-29853:
-
Assignee: James Busche
> Older jackson-databind found in flink-kubernetes-operator-1.2.
zjureel commented on PR #432:
URL:
https://github.com/apache/flink-table-store/pull/432#issuecomment-1347626712
Hi @JingsongLi Left one minor comment
In addition, I found that `flink-table-store-codegen` module still depends
on `flink-table-runtime` in `pom.xml`, is it OK?
--
This
[
https://issues.apache.org/jira/browse/FLINK-29794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-29794:
-
Assignee: Zhou Jiang
> Flink Operator Need to Include Cause for Exceptions If Possible
[
https://issues.apache.org/jira/browse/FLINK-29744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-29744:
-
Assignee: Matyas Orhidi
> Throw DeploymentFailedException on ImagePullBackOff
> ---
[
https://issues.apache.org/jira/browse/FLINK-27852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-27852:
-
Assignee: Ted Chang (was: James Busche)
> Contribute k8s operator to OperatorHub
> ---
1 - 100 of 313 matches
Mail list logo