Zhilong Hong created FLINK-24295:
Summary: Too many requestPartitionState may jam the JobManager
during task deployment
Key: FLINK-24295
URL: https://issues.apache.org/jira/browse/FLINK-24295
Thanks Leonard for the announcement. I guess that is helpful.
@Robert is there any way we can change the default setting to something
else (e.g. greater than 0 days)? Only having the last month available as a
default is kind of annoying considering that the time setting is quite
hidden.
Matthias
Hi all,
DongLin, ZhiPeng and I are opening this thread to propose designing and
implementing a new iteration library inside the Flink-ML project, as described
in
FLIP-176[1].
Iteration serves as a fundamental functionality required to support the
implementation
of ML algorithms. Previously
Martijn Visser created FLINK-24296:
--
Summary: Refactor Google PubSub to new Source/Sink interfaces
Key: FLINK-24296
URL: https://issues.apache.org/jira/browse/FLINK-24296
Project: Flink
Martijn Visser created FLINK-24299:
--
Summary: Make Google PubSub available as Source and Sink for Table
API
Key: FLINK-24299
URL: https://issues.apache.org/jira/browse/FLINK-24299
Project: Flink
Martijn Visser created FLINK-24298:
--
Summary: Refactor Google PubSub sink to use Unified Sink API
Key: FLINK-24298
URL: https://issues.apache.org/jira/browse/FLINK-24298
Project: Flink
Zhilong Hong created FLINK-24300:
Summary: MultipleInputOperator is running much more slowly in TPCDS
Key: FLINK-24300
URL: https://issues.apache.org/jira/browse/FLINK-24300
Project: Flink
Martijn Visser created FLINK-24297:
--
Summary: Refactor Google PubSub source to use Source API
Key: FLINK-24297
URL: https://issues.apache.org/jira/browse/FLINK-24297
Project: Flink
Issue
Seth Wiesman created FLINK-24301:
Summary: use Async transport on all statefun playground examples
Key: FLINK-24301
URL: https://issues.apache.org/jira/browse/FLINK-24301
Project: Flink
I have solved this problem because when I created the Flink local environment
in test, I did not add the configuration
`execution.checkpointing.checkpoints-after-tasks-finish.enabled=true`.
Jianyun Zhao
2021-09-15
2021年9月14日 14:52，赵 建云
mailto:zhaojianyu...@outlook.com>> 写道：
Hi flink users,
Yufan Sheng created FLINK-24302:
---
Summary: Direct buffer memory leak on Pulsar connector with Java 11
Key: FLINK-24302
URL: https://issues.apache.org/jira/browse/FLINK-24302
Project: Flink
Seth Wiesman created FLINK-24303:
Summary: SourceCoordinator exception may fail Session Cluster
Key: FLINK-24303
URL: https://issues.apache.org/jira/browse/FLINK-24303
Project: Flink
Issue
Hi,
The issue FLINK-24300 was noticed on our internal daily TPCDS yesterday
evening, we are currently
looking at this issue and should approximate the reason, from the current
observation it should affect
the MultipleInputStreamOperator with chained sources in both stream and batch
mode,
zlzhang0122 created FLINK-24306:
---
Summary: group by index throw SqlValidatorException
Key: FLINK-24306
URL: https://issues.apache.org/jira/browse/FLINK-24306
Project: Flink
Issue Type: Bug
Xintong Song created FLINK-24304:
Summary:
ProcessFailureCancelingITCase.testCancelingOnProcessFailure fails due to leader
retrieval timeout
Key: FLINK-24304
URL:
Xintong Song created FLINK-24305:
Summary:
BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure
Key: FLINK-24305
URL: https://issues.apache.org/jira/browse/FLINK-24305
Project:
I noticed that a serious performance degradation has been reported [1],
shall we wait
for the conclusion for that issue?
[1] https://issues.apache.org/jira/browse/FLINK-24300
Best,
Kurt
On Wed, Sep 15, 2021 at 3:29 PM Dawid Wysakowicz
wrote:
> Hi everyone,
> Please review and vote on the
Thanks for reporting this, @Kurt and @Yun.
In addition, python tests are failing in all branches [1], potentially
related to the new protobuf release.
Let's wait for the conclusion of both issues.
Thank you~
Xintong Song
[1] https://issues.apache.org/jira/browse/FLINK-24305
On Thu, Sep
Xintong Song created FLINK-24288:
Summary: YARNITCase.testPerJobWithArchive fails on azure
Key: FLINK-24288
URL: https://issues.apache.org/jira/browse/FLINK-24288
Project: Flink
Issue Type:
Fabian Paul created FLINK-24292:
---
Summary: Update Flink's Kafka examples to use KafkaSink
Key: FLINK-24292
URL: https://issues.apache.org/jira/browse/FLINK-24292
Project: Flink
Issue Type:
Spongebob created FLINK-24289:
-
Summary: Load data repeatedly between different jobs
Key: FLINK-24289
URL: https://issues.apache.org/jira/browse/FLINK-24289
Project: Flink
Issue Type:
|Hi everyone,|
|Please review and vote on the release candidate #1 for the version
1.14.0, as follows:|
|[ ] +1, Approve the release|
|[ ] -1, Do not approve the release (please provide specific comments)|
|The complete staging area is available for your review, which includes:|
|* JIRA
Ingo Bürk created FLINK-24290:
-
Summary: Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY
Key: FLINK-24290
URL: https://issues.apache.org/jira/browse/FLINK-24290
Project: Flink
Issue Type:
xuyangzhong created FLINK-24291:
---
Summary: Decimal precision is lost when deserializing
Key: FLINK-24291
URL: https://issues.apache.org/jira/browse/FLINK-24291
Project: Flink
Issue Type: Bug
Anton Kalashnikov created FLINK-24294:
-
Summary: Resources leak in the StreamTask constructor
Key: FLINK-24294
URL: https://issues.apache.org/jira/browse/FLINK-24294
Project: Flink
Issue
huntercc created FLINK-24293:
Summary: Tasks share
Key: FLINK-24293
URL: https://issues.apache.org/jira/browse/FLINK-24293
Project: Flink
Issue Type: Improvement
Reporter: huntercc
26 matches
Mail list logo
