[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694913#comment-17694913
]
Shammon commented on FLINK-31275:
-
Hi [~jark] [~lzljs3620320] What do you think of this
[
https://issues.apache.org/jira/browse/FLINK-25986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694915#comment-17694915
]
Jane Chan commented on FLINK-25986:
---
Is there any update? cc [~nicholasjiang]. If you'
Gyula Fora created FLINK-31277:
--
Summary: JM Deployment recovery logic inconsistent with health
related restart
Key: FLINK-31277
URL: https://issues.apache.org/jira/browse/FLINK-31277
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694916#comment-17694916
]
Zhipeng Zhang commented on FLINK-31276:
---
I repeated running it for 1000 times and
Zhipeng Zhang created FLINK-31276:
-
Summary: VectorIndexerTest#testFitAndPredictWithHandleInvalid fails
Key: FLINK-31276
URL: https://issues.apache.org/jira/browse/FLINK-31276
Project: Flink
Fanoid commented on PR #210:
URL: https://github.com/apache/flink-ml/pull/210#issuecomment-1449544787
Hi, @lindong28 , thanks for your valuable comments. I've update the PR based
on comments and offline discussions. Please take a look.
--
This is an automated message from the Apache Git
rkhachatryan commented on PR #21981:
URL: https://github.com/apache/flink/pull/21981#issuecomment-1449550098
Thanks a lot for the thorough review @dmvk!
I've cleaned up the commit history and I think all concerns are now
resolved, PTAL.
--
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/FLINK-30391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30391:
-
Assignee: Samrat Deb
> show jars command doesn't list client wrapper classloader loaded
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694929#comment-17694929
]
Matthias Pohl commented on FLINK-26974:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694930#comment-17694930
]
Matthias Pohl commented on FLINK-18356:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-31210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694932#comment-17694932
]
Matthias Pohl commented on FLINK-31210:
---
[20230301.2|https://dev.azure.com/apache-
[
https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694934#comment-17694934
]
Matthias Pohl commented on FLINK-30978:
---
https://dev.azure.com/apache-flink/apache
gyfora commented on code in PR #539:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121350581
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java:
##
@@ -59,18 +63,54 @@ public String to
tamirsagi commented on code in PR #539:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121282661
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java:
##
@@ -59,18 +63,48 @@ public String
Matthias Pohl created FLINK-31278:
-
Summary: exit code 137 (i.e. OutOfMemoryError) in core module
Key: FLINK-31278
URL: https://issues.apache.org/jira/browse/FLINK-31278
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31278:
--
Description:
The following build failed due to a 137 exit code indicating an
OutOfMemoryError
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31278:
--
Component/s: Runtime / Coordination
> exit code 137 (i.e. OutOfMemoryError) in core module
> -
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31278:
--
Affects Version/s: 1.17.0
> exit code 137 (i.e. OutOfMemoryError) in core module
> ---
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31278:
--
Description:
The following build failed due to a 137 exit code indicating an
OutOfMemoryError
tamirsagi commented on code in PR #539:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121362177
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java:
##
@@ -59,18 +63,48 @@ public String
gyfora commented on code in PR #539:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121365076
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java:
##
@@ -59,18 +63,48 @@ public String to
tamirsagi commented on code in PR #539:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121372774
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java:
##
@@ -59,18 +63,48 @@ public String
jackylau created FLINK-31279:
Summary: fix times using number and interval type bug
Key: FLINK-31279
URL: https://issues.apache.org/jira/browse/FLINK-31279
Project: Flink
Issue Type: Bug
Aff
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694943#comment-17694943
]
Matthias Pohl commented on FLINK-31278:
---
There is no heapdump provide due to a fai
[
https://issues.apache.org/jira/browse/FLINK-31274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-31274:
Component/s: API / Python
> Python code examples in documentation are not complete
> -
liuyongvs opened a new pull request, #22050:
URL: https://github.com/apache/flink/pull/22050
## What is the purpose of the change
*fix builtin function of times wrong check.*
## Brief change log
Flink SQL> select interval 3 day * 2;
[ERROR] Could not execute S
[
https://issues.apache.org/jira/browse/FLINK-31279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31279:
---
Labels: pull-request-available (was: )
> fix times using number and interval type bug
> --
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694950#comment-17694950
]
Matthias Pohl commented on FLINK-31278:
---
[~roman] [~chesnay] can you help with the
flinkbot commented on PR #22050:
URL: https://github.com/apache/flink/pull/22050#issuecomment-1449653612
## CI report:
* 6b8df99036883a834960ef6f3de50157112a7acd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694943#comment-17694943
]
Matthias Pohl edited comment on FLINK-31278 at 3/1/23 9:16 AM:
---
slfan1989 commented on PR #22020:
URL: https://github.com/apache/flink/pull/22020#issuecomment-1449661411
> Hi @slfan1989 , could you rebase the master branch? I see other CI works
well, and your change shouldn't affect the CI.
@1996fanrui Thanks for your suggestion! I rebase the code
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694943#comment-17694943
]
Matthias Pohl edited comment on FLINK-31278 at 3/1/23 9:18 AM:
---
tsreaper merged PR #562:
URL: https://github.com/apache/flink-table-store/pull/562
--
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...@fl
[
https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694954#comment-17694954
]
Qingsheng Ren commented on FLINK-31208:
---
Thanks for reporting this [~loserwang1024
[
https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-31208:
--
Labels: starter (was: )
> KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSpl
dmvk opened a new pull request, #22051:
URL: https://github.com/apache/flink/pull/22051
https://issues.apache.org/jira/browse/FLINK-30444
--
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
[
https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30444:
---
Labels: pull-request-available (was: )
> State recovery error not handled correctly and alw
echauchot commented on PR #21636:
URL: https://github.com/apache/flink/pull/21636#issuecomment-1449683305
@dawidwys sorry for the delay, I had to finish [this other
PR](https://github.com/apache/flink-connector-cassandra/pull/3) after my
vacations. Resuming the work on this PR ...
--
Thi
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-31275:
Summary: Generate planner id in planner (was: Generate job id in planner)
> Generate planner id in planne
flinkbot commented on PR #22051:
URL: https://github.com/apache/flink/pull/22051#issuecomment-1449688650
## CI report:
* 2975ad05e87770adef981f66d973ab5284e6e33b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-31275:
Description: Currently flink generates job id in `JobGraph` which can
identify a job. On the other hand, f
JingsongLi merged PR #547:
URL: https://github.com/apache/flink-table-store/pull/547
--
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-31128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31128.
Assignee: Jun Zhang
Resolution: Fixed
master: 4adf18df258bc3c55026053d94cd3e4a6c281896
> Ad
Matthias Pohl created FLINK-31280:
-
Summary: Make core surefire plugin configuration stricter
Key: FLINK-31280
URL: https://issues.apache.org/jira/browse/FLINK-31280
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-31280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-31280.
-
Resolution: Won't Fix
having subtasks for this is overkill.
> Make core surefire plugin configu
[
https://issues.apache.org/jira/browse/FLINK-31280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31280:
--
Parent: (was: FLINK-31278)
Issue Type: Technical Debt (was: Sub-task)
> Make core
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1449717547
@MartijnVisser PTAL:)
--
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
XComp opened a new pull request, #22052:
URL: https://github.com/apache/flink/pull/22052
## What is the purpose of the change
This is meant as a temporary change to support investigating the OOM in
flink-core.
## Brief change log
It overrides the surefire plugin configur
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31278:
---
Labels: pull-request-available test-stability (was: test-stability)
> exit code 137 (i.e. O
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694968#comment-17694968
]
Jun Qin commented on FLINK-26088:
-
[~mtfelisb] This is a hot ticket and is being watched
XComp commented on code in PR #22052:
URL: https://github.com/apache/flink/pull/22052#discussion_r1121429475
##
flink-core/pom.xml:
##
@@ -146,6 +146,30 @@ under the License.
+
+
XComp commented on code in PR #22052:
URL: https://github.com/apache/flink/pull/22052#discussion_r1121429475
##
flink-core/pom.xml:
##
@@ -146,6 +146,30 @@ under the License.
+
+
flinkbot commented on PR #22052:
URL: https://github.com/apache/flink/pull/22052#issuecomment-1449736293
## CI report:
* 90925bfa3697f09d8984e1d40aa978c4cb66076e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[ https://issues.apache.org/jira/browse/FLINK-26945 ]
jackylau deleted comment on FLINK-26945:
--
was (Author: jackylau):
and there is a bug is times bultin function, which supports this type i can fix
by the way
{code:java}
// code placeholder
publ
[
https://issues.apache.org/jira/browse/FLINK-31279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694970#comment-17694970
]
Martijn Visser commented on FLINK-31279:
[~jackylau] Why is this is a bug, the d
[
https://issues.apache.org/jira/browse/FLINK-31125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-31125.
--
Resolution: Fixed
> Flink ML benchmark framework should minimize the source operator overhead
> --
[
https://issues.apache.org/jira/browse/FLINK-31127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-31127.
--
Resolution: Fixed
> Add public API classes for FLIP-289
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694971#comment-17694971
]
Dong Lin commented on FLINK-31127:
--
Merged to flink-ml master branch f0c1ce7440ff3b5cb4
[
https://issues.apache.org/jira/browse/FLINK-31126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694973#comment-17694973
]
Dong Lin commented on FLINK-31126:
--
Merged to flink-ml master branch b032ebdb122f32ba04
[
https://issues.apache.org/jira/browse/FLINK-31125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694972#comment-17694972
]
Dong Lin commented on FLINK-31125:
--
Merged to flink-ml master branch 5bcbd01169a3bfce0c
[
https://issues.apache.org/jira/browse/FLINK-31126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-31126.
--
Resolution: Fixed
> Move classes not depending on Flink runtime from flink-ml-core to
> flink-ml-serv
[
https://issues.apache.org/jira/browse/FLINK-31279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694974#comment-17694974
]
jackylau commented on FLINK-31279:
--
[~martijnvisser] i say the times function with args
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-31246:
---
Summary: Beautify the SpecChange message (was: Remove PodTemplate
description from the SpecChange m
[
https://issues.apache.org/jira/browse/FLINK-31191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang reassigned FLINK-31191:
-
Assignee: Zhipeng Zhang
> VectorIndexer should check whether doublesByColumn is null be
lindong28 commented on PR #217:
URL: https://github.com/apache/flink-ml/pull/217#issuecomment-1449773584
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
lindong28 merged PR #217:
URL: https://github.com/apache/flink-ml/pull/217
--
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-31279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31279:
-
Description:
{code:java}
// code placeholder
Flink SQL> select 2 * interval '3' day;
[ERROR] Could not
[
https://issues.apache.org/jira/browse/FLINK-31191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-31191:
-
Fix Version/s: ml-2.2.0
> VectorIndexer should check whether doublesByColumn is null before snapshot
> -
[
https://issues.apache.org/jira/browse/FLINK-31191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-31191.
--
Resolution: Fixed
> VectorIndexer should check whether doublesByColumn is null before snapshot
> -
[
https://issues.apache.org/jira/browse/FLINK-31191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694977#comment-17694977
]
Dong Lin commented on FLINK-31191:
--
Merged to flink-ml master branch 10c08277fd7c03faef
pvary commented on PR #539:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/539#issuecomment-1449784091
After some discussion with @gyfora, the message looks like this:
> Diff: FlinkDeploymentSpec[image : img1 -> img2, ingress : {..} -> null,
podTemplate.apiVersion : v1
liuyongvs commented on PR #22050:
URL: https://github.com/apache/flink/pull/22050#issuecomment-1449800908
@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-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694990#comment-17694990
]
Timo Walther commented on FLINK-25217:
--
[~yunta] due to multiple switches of my emp
dianfu opened a new pull request, #22053:
URL: https://github.com/apache/flink/pull/22053
…
## 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-transferrin
[
https://issues.apache.org/jira/browse/FLINK-31272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31272:
---
Labels: pull-request-available (was: )
> Duplicate operators appear in the StreamGraph for
tsreaper commented on code in PR #550:
URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1121407946
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableWrite.java:
##
@@ -18,39 +18,42 @@
package org.apache.flink.table.store
flinkbot commented on PR #22053:
URL: https://github.com/apache/flink/pull/22053#issuecomment-1449850433
## CI report:
* 3b875295e94aff98662db50d2c4210091e3106e6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuyongvs commented on PR #22050:
URL: https://github.com/apache/flink/pull/22050#issuecomment-1449875147
@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-30935 ]
Ran Tao deleted comment on FLINK-30935:
-
was (Author: lemonjing):
[~becket_qin] [~renqs] Hi, Can u help me to review the PR when you are free?
thanks.
> Add KafkaSerializer deserialize check wh
[
https://issues.apache.org/jira/browse/FLINK-30935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695014#comment-17695014
]
Ran Tao commented on FLINK-30935:
-
@[~mapohl] [~Leonard] Can u help me to review this P
[
https://issues.apache.org/jira/browse/FLINK-31281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31281:
Component/s: API / Python
> PythonFunctionRunner doesn't extend AutoCloseable but implements close
> -
Ran Tao created FLINK-31281:
---
Summary: PythonFunctionRunner doesn't extend AutoCloseable but
implements close
Key: FLINK-31281
URL: https://issues.apache.org/jira/browse/FLINK-31281
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-30863:
---
Attachment: tm-log_fail_cl_local_recovery.txt
> Do not delete the local changelog file of aborted ch
[
https://issues.apache.org/jira/browse/FLINK-31281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695021#comment-17695021
]
Ran Tao commented on FLINK-31281:
-
[~mapohl] Hi, Matthias. We fix the FLINK-31015. But
pocockn opened a new pull request, #325:
URL: https://github.com/apache/flink-statefun/pull/325
If you don't pass a function type to the builders `WithSpec` method it
doesn't error within the Go SDK but the function isn't registered within Flink
and doesn't run correctly.
You can se
[
https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695028#comment-17695028
]
Hongshun Wang commented on FLINK-31208:
---
Of course, I’d like to take over this iss
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695034#comment-17695034
]
Shengkai Fang commented on FLINK-31092:
---
Hi, all. I think [~luoyuxia] is right.
`
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695034#comment-17695034
]
Shengkai Fang edited comment on FLINK-31092 at 3/1/23 12:14 PM:
--
shenyue created FLINK-31282:
---
Summary: Create and Close the zookeeper connection frequently
Key: FLINK-31282
URL: https://issues.apache.org/jira/browse/FLINK-31282
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-31282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-31282:
---
Priority: Major (was: Critical)
> Create and Close the zookeeper connection frequently
> --
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695042#comment-17695042
]
Yanfei Lei commented on FLINK-30863:
Looking back at the fileNotFound problem of loc
[
https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695043#comment-17695043
]
Martijn Visser commented on FLINK-31082:
[~godfrey] Thank you!
> Setting maven
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-30863:
---
Description: (was: Do not delete the local changelog file of aborted
checkpoint, because this ch
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-30863:
---
Summary: Register local recovery files of changelog before
notifyCheckpointComplete() (was: Do not
tamirsagi commented on code in PR #536:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/536#discussion_r1121652649
##
Dockerfile:
##
@@ -36,13 +36,16 @@ RUN cd /app/tools/license; mkdir jars; cd jars; \
# stage
FROM eclipse-temurin:11-jre-jammy
ENV FLINK_HOME=/
[
https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-30863:
---
Description:
If TM is materialized before receiving confirm(), the previously uploaded queue
in `Fs
jhkkhtd opened a new pull request, #22054:
URL: https://github.com/apache/flink/pull/22054
[FLINK-31282][Componets: Client]
## What is the purpose of the change
Fix the Problem to **create and close zookeepr connections frequently**
when executing sql **Select** , In the n
flinkbot commented on PR #22054:
URL: https://github.com/apache/flink/pull/22054#issuecomment-1450095545
## CI report:
* 36ae45b448760acb79f4ac6195fd1238d08092ef UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31282:
---
Labels: pull-request-available (was: )
> Create and Close the zookeeper connection frequent
[
https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695055#comment-17695055
]
Jark Wu commented on FLINK-31259:
-
Sorry, for the "global catalog", I mean the catalog d
1 - 100 of 269 matches
Mail list logo
