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
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
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
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
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
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
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
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:
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
wym_maozi created FLINK-22115:
-
Summary: JobManager dies with IllegalStateException SharedSlot
(physical request SlotRequestId{%}) has been released
Key: FLINK-22115
URL:
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
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
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:
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:
Guowei Ma created FLINK-22111:
-
Summary: ClientTest.testSimpleRequests fail
Key: FLINK-22111
URL: https://issues.apache.org/jira/browse/FLINK-22111
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22110:
-
Summary: KinesisTableApiITCase.testTableApiSourceAndSink failed
due to download docker image throw IOException
Key: FLINK-22110
URL: https://issues.apache.org/jira/browse/FLINK-22110
23 matches
Mail list logo