[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747310#comment-17747310
]
Yanfei Lei commented on FLINK-32677:
Thanks for the response, I got the reason, the
[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-32677.
Resolution: Fixed
> flink-benchmarks-regression-check failed to send slack messages since
> 2023.
[
https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747317#comment-17747317
]
Matthias Pohl commented on FLINK-32678:
---
[~wangyang0918] I'm wondering whether we
[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747319#comment-17747319
]
Martijn Visser commented on FLINK-32677:
That makes sense [~Yanfei Lei] - Thanks
[
https://issues.apache.org/jira/browse/FLINK-32677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-32677:
--
Assignee: Yanfei Lei
> flink-benchmarks-regression-check failed to send slack message
[
https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747330#comment-17747330
]
Konstantin Knauf commented on FLINK-31634:
--
Thanks, [~tanyuxin].
> FLIP-301: H
[
https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747331#comment-17747331
]
Konstantin Knauf commented on FLINK-32402:
--
[~zjureel] Great. There is a PR tha
[
https://issues.apache.org/jira/browse/FLINK-32468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32468:
--
Release Note: Flink's RPC framework is now based on Apache Pekko instead of
Akka. Any Akka dep
[
https://issues.apache.org/jira/browse/FLINK-32666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747333#comment-17747333
]
lizhiqiang commented on FLINK-32666:
I found that this is a jdk bug, I think we shou
Lijie Wang created FLINK-32680:
--
Summary: Job vertex names get messed up once there is a source
vertex chained with a MultipleInput vertex in job graph
Key: FLINK-32680
URL: https://issues.apache.org/jira/browse/FLIN
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-32680:
---
Description:
Take the following test(put it to {{{}MultipleInputITCase{}}}) as example:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-32680:
---
Attachment: (was: image-2023-07-26-15-01-51-886.png)
> Job vertex names get messed up once there
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747334#comment-17747334
]
Konstantin Knauf commented on FLINK-28045:
--
[~airblader] What we still need to
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-32680:
---
Description:
Take the following test(put it to {{MultipleInputITCase}}) as example:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747337#comment-17747337
]
Chesnay Schepler commented on FLINK-15736:
--
There should be a troubleshooting e
Chesnay Schepler created FLINK-32681:
Summary:
RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie
Key: FLINK-32681
URL: https://issues.apache.org/jira/browse/FLINK-32681
Project:
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32681:
-
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5171
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747360#comment-17747360
]
Kelu Tao commented on FLINK-27054:
--
[~martijnvisser] OK, assign it to me plz. Thanks.
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-27054:
--
Assignee: Kelu Tao
> Elasticsearch SQL connector SSL issue
>
gyfora commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1274542988
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -409,24 +417,
patricklucas commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1274549521
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +210,40 @@ public void testRestClientClosedHandling() throws
Except
Dawid Wysakowicz created FLINK-32682:
Summary: Introduce option for choosing time function evaluation
methods
Key: FLINK-32682
URL: https://issues.apache.org/jira/browse/FLINK-32682
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-32682:
-
Description:
In [FLIP-162|https://cwiki.apache.org/confluence/x/KAxRCg] as future plans
XComp commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1274576162
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +210,40 @@ public void testRestClientClosedHandling() throws
Exception {
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32670:
-
Assignee: Alexander Fedulov
> Annotate interfaces that inherit from SourceFunct
XComp commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1274576162
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +210,40 @@ public void testRestClientClosedHandling() throws
Exception {
[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-32645:
-
Assignee: Zili Chen
> Flink pulsar sink is having poor performance
> --
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1274603164
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void obse
gyfora commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1274612726
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void observ
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1274616976
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -409,24 +41
patricklucas commented on PR #22987:
URL: https://github.com/apache/flink/pull/22987#issuecomment-1651315710
@XComp Made the following changes:
- Updated `testCloseClientWhileProcessingRequest` to check that
`responseChannelFutures` is empty before and size 1 after the call to
`sendReque
Matthew de Detrich created FLINK-32683:
--
Summary: Update Pekko from 1.0.0 to 1.0.1
Key: FLINK-32683
URL: https://issues.apache.org/jira/browse/FLINK-32683
Project: Flink
Issue Type: Impr
afedulov opened a new pull request, #23079:
URL: https://github.com/apache/flink/pull/23079
This is a trivial change that marks sub-interfaces of SourceFunction as
`@Deprecated` and adjusts an example to fix the strict deprecation complier
check failure.
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32670:
---
Labels: pull-request-available (was: )
> Annotate interfaces that inherit from SourceFuncti
flinkbot commented on PR #23079:
URL: https://github.com/apache/flink/pull/23079#issuecomment-1651344213
## CI report:
* f3a2c5c03093627082969da5e3b46cef4443fd5b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mdedetrich opened a new pull request, #23080:
URL: https://github.com/apache/flink/pull/23080
## What is the purpose of the change
This PR bumps Pekko from v1.0.0 to 1.0.1. The main and hence only change
from Pekko 1.0.0 to Pekko 1.0.1 is
https://github.com/apache/incubator-pekko/pul
[
https://issues.apache.org/jira/browse/FLINK-32683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32683:
---
Labels: pull-request-available (was: )
> Update Pekko from 1.0.0 to 1.0.1
> ---
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747409#comment-17747409
]
Junrui Li commented on FLINK-32680:
---
This bug is because the global ChainedSources are
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747411#comment-17747411
]
Lijie Wang commented on FLINK-32680:
Thanks [~JunRuiLi] , assiged to you.
> Job ver
[
https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-32680:
--
Assignee: Junrui Li
> Job vertex names get messed up once there is a source vertex chained wi
flinkbot commented on PR #23080:
URL: https://github.com/apache/flink/pull/23080#issuecomment-1651353523
## CI report:
* 8e2e4705345c21e24c40c882cc24d74d7f094be6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747425#comment-17747425
]
Feng Jin commented on FLINK-32653:
--
[~Leonard] please assign this task to me when you a
[
https://issues.apache.org/jira/browse/FLINK-32270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747427#comment-17747427
]
Qingsheng Ren commented on FLINK-32270:
---
Downgraded to Major as only it only appea
[
https://issues.apache.org/jira/browse/FLINK-32270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-32270:
--
Priority: Major (was: Critical)
> Heartbeat timeout in AggregateReduceGroupingITCase.testAggO
[
https://issues.apache.org/jira/browse/FLINK-32683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32683:
--
Affects Version/s: 1.18.0
> Update Pekko from 1.0.0 to 1.0.1
> ---
[
https://issues.apache.org/jira/browse/FLINK-32683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32683:
--
Component/s: Runtime / Coordination
> Update Pekko from 1.0.0 to 1.0.1
> -
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747428#comment-17747428
]
shizhengchao commented on FLINK-26541:
--
Why do not use session mode？If application
[
https://issues.apache.org/jira/browse/FLINK-32604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747430#comment-17747430
]
Huang Xingbo commented on FLINK-32604:
--
It is a downloading error. We can keep obse
[
https://issues.apache.org/jira/browse/FLINK-32653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-32653:
--
Assignee: Feng Jin
> Add doc for catalog store
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-32683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32683:
-
Assignee: Matthew de Detrich
> Update Pekko from 1.0.0 to 1.0.1
> -
flinkbot commented on PR #23081:
URL: https://github.com/apache/flink/pull/23081#issuecomment-1651494255
## CI report:
* 2e3b4d260f097087f6bfb32568db15388af8898b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747441#comment-17747441
]
Matthias Pohl commented on FLINK-32668:
---
As far as I see it, this failure can only
snuyanzin commented on PR #23045:
URL: https://github.com/apache/flink/pull/23045#issuecomment-1651505210
Thanks for having a look
yes, sure, backports are created
once they pass ci will merge them
--
This is an automated message from the Apache Git Service.
To respond to the message
luoyuxia commented on code in PR #23075:
URL: https://github.com/apache/flink/pull/23075#discussion_r1274747812
##
docs/content/docs/dev/table/sql/insert.md:
##
@@ -208,7 +208,9 @@ column_list:
**COLUMN LIST**
Given a table T(a INT, b INT, c INT), Flink supports INSERT INTO
flinkbot commented on PR #23082:
URL: https://github.com/apache/flink/pull/23082#issuecomment-1651513201
## CI report:
* 58f22d778efa8ea4170919ba61ffe3f234097bf6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1274823122
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -594,6 +638,58 @@ public Save
HuangXingBo closed pull request #23045: [FLINK-32628][tests][ci] Fix
build_wheels_on_macos fails on AZP
URL: https://github.com/apache/flink/pull/23045
--
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
afedulov commented on code in PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#discussion_r1274827242
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java:
##
@@ -74,8 +80,32 @@ public void obse
afedulov commented on PR #637:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/637#issuecomment-1651622614
@mxm @gyfora thanks for the review. I addressed the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
Matthias Pohl created FLINK-32684:
-
Summary: Renaming AkkaOptions into PekkoOptions
Key: FLINK-32684
URL: https://issues.apache.org/jira/browse/FLINK-32684
Project: Flink
Issue Type: Technica
Martijn Visser created FLINK-32685:
--
Summary: Benchmark regression on sortedMultiInput and
sortedTwoInput since 2023-07-18
Key: FLINK-32685
URL: https://issues.apache.org/jira/browse/FLINK-32685
Proj
Martijn Visser created FLINK-32686:
--
Summary: Benchmark regression on startScheduling.BATCH and
startScheduling.STREAMING since 2023-07-24
Key: FLINK-32686
URL: https://issues.apache.org/jira/browse/FLINK-32686
[
https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32686:
---
Summary: Performance regression on startScheduling.BATCH and
startScheduling.STREAMING since
[
https://issues.apache.org/jira/browse/FLINK-32685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32685:
---
Summary: Performance regression on sortedMultiInput and sortedTwoInput
since 2023-07-18 (wa
Martijn Visser created FLINK-32687:
--
Summary: Performance regression on
handleGlobalFailureAndRestartAllTasks.BATCH_EVENLY since 2023-07-23
Key: FLINK-32687
URL: https://issues.apache.org/jira/browse/FLINK-32687
Matthias Pohl created FLINK-32688:
-
Summary: Remove deprecated exception history fields
Key: FLINK-32688
URL: https://issues.apache.org/jira/browse/FLINK-32688
Project: Flink
Issue Type: Sub-
lincoln-lil commented on code in PR #23075:
URL: https://github.com/apache/flink/pull/23075#discussion_r1274930002
##
docs/content/docs/dev/table/sql/insert.md:
##
@@ -208,7 +208,9 @@ column_list:
**COLUMN LIST**
Given a table T(a INT, b INT, c INT), Flink supports INSERT IN
[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-32645:
--
Fix Version/s: pulsar-3.0.2
> Flink pulsar sink is having poor performance
> -
XComp commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1274946566
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +218,120 @@ public void testRestClientClosedHandling() throws
Exception {
[
https://issues.apache.org/jira/browse/FLINK-28050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-28050:
-
Assignee: Alexander Fedulov
> Introduce Source API alternative to SourceExecuti
gyfora merged PR #638:
URL: https://github.com/apache/flink-kubernetes-operator/pull/638
--
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-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747530#comment-17747530
]
Ferenc Csaky commented on FLINK-29281:
--
[~chesnay] is this annulates the Akka Arter
dawidwys opened a new pull request, #23083:
URL: https://github.com/apache/flink/pull/23083
## What is the purpose of the change
This PR introduces the option as discussed in FLIP-162 future work section
to choose how time based functions should be evaluated.
## Verifying t
[
https://issues.apache.org/jira/browse/FLINK-32682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32682:
---
Labels: pull-request-available (was: )
> Introduce option for choosing time function evalua
[
https://issues.apache.org/jira/browse/FLINK-32687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747533#comment-17747533
]
Weihua Hu commented on FLINK-32687:
---
[~martijnvisser] Thanks for reporting this. This
flinkbot commented on PR #23083:
URL: https://github.com/apache/flink/pull/23083#issuecomment-1651874232
## CI report:
* 259010ae232c9677a1aff9d7c2103bb73c477db1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747539#comment-17747539
]
Martijn Visser commented on FLINK-32687:
[~huwh] Thanks for the explainer, let's
[
https://issues.apache.org/jira/browse/FLINK-32682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-32682:
Assignee: Dawid Wysakowicz
> Introduce option for choosing time function evaluati
[
https://issues.apache.org/jira/browse/FLINK-32687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32687.
--
Resolution: Not A Problem
> Performance regression on handleGlobalFailureAndRestartAllTasks.BA
[
https://issues.apache.org/jira/browse/FLINK-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747553#comment-17747553
]
Claude Warren commented on FLINK-29281:
---
Pekko v1.0.1 was just released.
[d...@pe
[
https://issues.apache.org/jira/browse/FLINK-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31400:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Add autoscaler integration for Iceberg source
[
https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31998:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Flink Operator Deadlock on run job Failure
> -
[
https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32120:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Add autoscaler config option to disable parall
[
https://issues.apache.org/jira/browse/FLINK-31867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-31867:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Enforce a minimum number of observations withi
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32119:
---
Fix Version/s: (was: kubernetes-operator-1.6.0)
> Revise source partition skew logic
>
Timo Walther created FLINK-32689:
Summary: Insufficient validation for table.local-time-zone
Key: FLINK-32689
URL: https://issues.apache.org/jira/browse/FLINK-32689
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747557#comment-17747557
]
Timo Walther commented on FLINK-32689:
--
[~leonard] Could you give more context why
[
https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747559#comment-17747559
]
Timo Walther commented on FLINK-32689:
--
Update: I could confirm it with this progra
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747575#comment-17747575
]
Chesnay Schepler commented on FLINK-32684:
--
Related to FLINK-14052.
> Renaming
hanyuzheng7 commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1652083503
@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-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
re
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
re
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
re
[
https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32684:
--
Description:
FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved
re
[
https://issues.apache.org/jira/browse/FLINK-31611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-31611:
-
Assignee: (was: Matyas Orhidi)
> Add delayed restart to failed jobs
> -
Matyas Orhidi created FLINK-32690:
-
Summary: Report Double.NAN instead of null for missing autoscaler
metrics
Key: FLINK-32690
URL: https://issues.apache.org/jira/browse/FLINK-32690
Project: Flink
patricklucas commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1275249702
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java:
##
@@ -207,6 +218,120 @@ public void testRestClientClosedHandling() throws
Excep
patricklucas commented on PR #22987:
URL: https://github.com/apache/flink/pull/22987#issuecomment-1652189416
Great, I'll get to this tomorrow, thanks for the reviews @XComp.
Regarding the commit organization, I'm happy to break out another hotfix
commit—wasn't sure if the branch would
morhidi opened a new pull request, #639:
URL: https://github.com/apache/flink-kubernetes-operator/pull/639
## What is the purpose of the change
Change null values to Double.NAN for autoscaler metrics during blackout
periods when no data is gathered. This appears to be a more common pr
[
https://issues.apache.org/jira/browse/FLINK-32690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32690:
---
Labels: pull-request-available (was: )
> Report Double.NAN instead of null for missing auto
1 - 100 of 179 matches
Mail list logo
