Dawid Wysakowicz created FLINK-22129:
Summary: OrcFileSystemITCase hangs on azure
Key: FLINK-22129
URL: https://issues.apache.org/jira/browse/FLINK-22129
Project: Flink
Issue Type: Bug
Hi,
Yes, you can use `isBackPressured` to monitor a task's back-pressure.
However keep in mind:
a) You are going to miss some nice way to visualize this information, which
is present in 1.13's WebUI.
b) `isBackPressured` is a sampling based metric. If your job has varying
load, for example all win
Hi Yuval,
I think you are good to go, since there is no objection from PMC.
Best,
Kurt
On Wed, Apr 7, 2021 at 12:48 AM Yuval Itzchakov wrote:
> Hi Guowei,
>
> Who should I speak to regarding this? I am at the final stages of the PR I
> believe (Shengkai is kindly helping me make things work)
Jingsong Lee created FLINK-22128:
Summary: Window aggregation should have unique keys
Key: FLINK-22128
URL: https://issues.apache.org/jira/browse/FLINK-22128
Project: Flink
Issue Type: Bug
Yingjie Cao created FLINK-22127:
---
Summary: Enrich error message of read buffer request timeout
exception
Key: FLINK-22127
URL: https://issues.apache.org/jira/browse/FLINK-22127
Project: Flink
tonychan created FLINK-22126:
Summary: when i set ssl ,the jobmanager got certificate_unknown
exception
Key: FLINK-22126
URL: https://issues.apache.org/jira/browse/FLINK-22126
Project: Flink
Iss
Hi, Piotr
Thanks for replying!
We don't have a plan to upgrade to 1.13 in short term. We are using flink
1.11 and I notice there is a metric called isBackpressured. Is that enough
to solve 1? If not, would backporting patches regarding
backPressuredTimeMsPerSecond, busyTimeMsPerSecond and idleTim
Friendly ping, the fix for entropy marker is ready.
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Dian Fu created FLINK-22125:
---
Summary: Revisit the return value of MapState.get when the key
doesn't exists
Key: FLINK-22125
URL: https://issues.apache.org/jira/browse/FLINK-22125
Project: Flink
I
Dian Fu created FLINK-22124:
---
Summary: The job finished without any exception if error was
thrown during state access
Key: FLINK-22124
URL: https://issues.apache.org/jira/browse/FLINK-22124
Project: Flink
Dian Fu created FLINK-22123:
---
Summary: Test state access in Python DataStream API
Key: FLINK-22123
URL: https://issues.apache.org/jira/browse/FLINK-22123
Project: Flink
Issue Type: Test
C
Guowei Ma created FLINK-22122:
-
Summary: StreamingKafkaITCase Fail due to TestTimedOutException
Key: FLINK-22122
URL: https://issues.apache.org/jira/browse/FLINK-22122
Project: Flink
Issue Type:
Caizhi Weng created FLINK-22121:
---
Summary: FlinkLogicalRankRuleBase should check if name of
rankNumberType already exists in the input
Key: FLINK-22121
URL: https://issues.apache.org/jira/browse/FLINK-22121
Zou created FLINK-22120:
---
Summary: Bug when generate code for map get
Key: FLINK-22120
URL: https://issues.apache.org/jira/browse/FLINK-22120
Project: Flink
Issue Type: Improvement
Components
Rui Li created FLINK-22119:
--
Summary: Update document for hive dialect
Key: FLINK-22119
URL: https://issues.apache.org/jira/browse/FLINK-22119
Project: Flink
Issue Type: Sub-task
Component
Shengkai Fang created FLINK-22118:
-
Summary: Always apply projection push down in blink planner
Key: FLINK-22118
URL: https://issues.apache.org/jira/browse/FLINK-22118
Project: Flink
Issue Ty
Yun Gao created FLINK-22117:
---
Summary: Not print stack trace for checkpoint trigger failure if
not all tasks are started.
Key: FLINK-22117
URL: https://issues.apache.org/jira/browse/FLINK-22117
Project: Fli
Chesnay Schepler created FLINK-22116:
Summary: Setup .asf.yaml in flink-web
Key: FLINK-22116
URL: https://issues.apache.org/jira/browse/FLINK-22116
Project: Flink
Issue Type: Task
The vote has passed with 3 binding votes.
Votes:
Dawid (+1)
Robert (+1)
Gordon (+1)
On 3/31/2021 2:07 PM, Chesnay Schepler wrote:
Hi everyone,
Please review and vote on the release candidate #1 for the version
13.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (p
wym_maozi created FLINK-22115:
-
Summary: JobManager dies with IllegalStateException SharedSlot
(physical request SlotRequestId{%}) has been released
Key: FLINK-22115
URL: https://issues.apache.org/jira/browse/FLINK-22
Guowei Ma created FLINK-22114:
-
Summary: Streaming File Sink s3 end-to-end test fail because the
test did not finish after 900 seconds.
Key: FLINK-22114
URL: https://issues.apache.org/jira/browse/FLINK-22114
Fu Kai created FLINK-22113:
--
Summary: UniqueKey constraint is lost with multiple sources join
in SQL
Key: FLINK-22113
URL: https://issues.apache.org/jira/browse/FLINK-22113
Project: Flink
Issue Typ
Guowei Ma created FLINK-22112:
-
Summary: EmulatedPubSubSinkTest fail due to pull docker image
failure
Key: FLINK-22112
URL: https://issues.apache.org/jira/browse/FLINK-22112
Project: Flink
Issue
Hi,
this should be posted on the user mailing list not the dev.
Apart from that, this looks like normal/standard behaviour of JVM, and has
very little to do with Flink. Garbage Collector (GC) is kicking in when
memory usage is approaching some threshold:
https://www.google.com/search?q=jvm+heap+m
Hi,
Lately we overhauled the backpressure detection [1] and a screenshot
preview of those efforts is attached here [2]. I encourage you to check the
1.13 RC0 build and how the current mechanism works for you [3]. To support
those WebUI changes we have added a couple of new metrics:
backPressuredTi
25 matches
Mail list logo
