Zhilong Hong created FLINK-23833:
Summary: Cache of ShuffleDescriptors should be individually
cleaned up
Key: FLINK-23833
URL: https://issues.apache.org/jira/browse/FLINK-23833
Project: Flink
Timo Walther created FLINK-23834:
Summary: Test StreamTableEnvironment batch mode manually
Key: FLINK-23834
URL: https://issues.apache.org/jira/browse/FLINK-23834
Project: Flink
Issue Type: I
Jingsong Lee created FLINK-23835:
Summary: Test upsert sink with upsert keys
Key: FLINK-23835
URL: https://issues.apache.org/jira/browse/FLINK-23835
Project: Flink
Issue Type: Improvement
Hi all,
Since Flink 1.14 is already code freeze, but for FLIP-147 we still have the
last piece of work left,
thus we would like to start a discussion about merging them after code freeze.
Currently there are two non-bug-fix issues left and since
1. FLINK-23512: The PR is in fact approved before
wuguihu created FLINK-23836:
---
Summary: [doc-zh]Translate
"/dev/datastream/execution/execution_configuration.md" into Chinese
Key: FLINK-23836
URL: https://issues.apache.org/jira/browse/FLINK-23836
Project:
For the record, this has been brought up on the release testing sync
earlier today, without objections from the meeting. Per the previous email
[1], we brought this to the mailing list discussion.
If you need to merge a new feature after the freeze, please open a
> discussion on the dev@ list. If
Wawrzyniec Nowak created FLINK-23837:
Summary: Differences between documentation and implementation for
taskmanager.memory.network.max
Key: FLINK-23837
URL: https://issues.apache.org/jira/browse/FLINK-23837
Fabian Paul created FLINK-23838:
---
Summary: Add FLIP-33 metrics to new KafkaSink
Key: FLINK-23838
URL: https://issues.apache.org/jira/browse/FLINK-23838
Project: Flink
Issue Type: Sub-task
Hi,
We have a small UI change [1][2] that we'd like to get merged into 1.14
[3]. The change allows displaying concurrent exceptions alongside the main
exception in job's exception history (these were already present in the
Rest API). This could bring a nice improvement for debugging of failed jobs
Nico Kruber created FLINK-23839:
---
Summary: Unclear severity of Kafka transaction recommit warning in
logs
Key: FLINK-23839
URL: https://issues.apache.org/jira/browse/FLINK-23839
Project: Flink
David Anderson created FLINK-23840:
--
Summary: Confusing message from
MemCheckpointStreamFactory#checkSize
Key: FLINK-23840
URL: https://issues.apache.org/jira/browse/FLINK-23840
Project: Flink
One addition: The change only affects the job-exceptions component of
Flink's web ui and is, thus, quite isolated.
Cheers,
Till
On Tue, Aug 17, 2021 at 4:42 PM David Morávek wrote:
> Hi,
>
> We have a small UI change [1][2] that we'd like to get merged into 1.14
> [3]. The change allows display
wuguihu created FLINK-23841:
---
Summary: [doc]Modify incorrect English statements for page
'execution_configuration'
Key: FLINK-23841
URL: https://issues.apache.org/jira/browse/FLINK-23841
Project: Flink
Stephan Ewen created FLINK-23842:
Summary: Add log messages for reader registrations and split
requests.
Key: FLINK-23842
URL: https://issues.apache.org/jira/browse/FLINK-23842
Project: Flink
Stephan Ewen created FLINK-23843:
Summary: Exceptions during
"SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure
instead of Process Kill
Key: FLINK-23843
URL: https://issues.apache.org/j
wuguihu created FLINK-23844:
---
Summary: Fix spelling mistakes for "async"
Key: FLINK-23844
URL: https://issues.apache.org/jira/browse/FLINK-23844
Project: Flink
Issue Type: Bug
Reporter:
camilesing created FLINK-23845:
--
Summary: [DOCS]PushGateway metrics group not delete when job
shutdown
Key: FLINK-23845
URL: https://issues.apache.org/jira/browse/FLINK-23845
Project: Flink
Iss
Thanks for the effort, David.
I think this is indeed isolated and helpful.
Let's give it 48 hours, and merge it if there's no objections from PMC
members.
Thank you~
Xintong Song
On Tue, Aug 17, 2021 at 11:31 PM Till Rohrmann wrote:
> One addition: The change only affects the job-exception
camilesing created FLINK-23846:
--
Summary: [DOCS]PushGatewayReporter config description obscure
Key: FLINK-23846
URL: https://issues.apache.org/jira/browse/FLINK-23846
Project: Flink
Issue Type:
camilesing created FLINK-23847:
--
Summary: [DOCS] Error msg are obscure when KafkaConsumer init,
valueDeserializer is null
Key: FLINK-23847
URL: https://issues.apache.org/jira/browse/FLINK-23847
Project:
Jark Wu created FLINK-23848:
---
Summary: PulsarSourceITCase is failed on Azure
Key: FLINK-23848
URL: https://issues.apache.org/jira/browse/FLINK-23848
Project: Flink
Issue Type: Improvement
Hi Till,
Since it has been a little bit while, I would like to restart this discussion.
Would you please share some ideas about this? Will it become a
stability problem if we create a "surefire" listener to prevent the
exception thrown from those custom listeners? [1]
By the way, as you have ment
zlzhang0122 created FLINK-23849:
---
Summary: Support react to the node decommissioning change state on
yarn and do graceful restart
Key: FLINK-23849
URL: https://issues.apache.org/jira/browse/FLINK-23849
Qingsheng Ren created FLINK-23850:
-
Summary: Test Kafka table connector with new runtime provider
Key: FLINK-23850
URL: https://issues.apache.org/jira/browse/FLINK-23850
Project: Flink
Issue
Xintong Song created FLINK-23851:
Summary: AggregationsITCase.testDistinctAfterAggregate fails due
to AskTimeoutException
Key: FLINK-23851
URL: https://issues.apache.org/jira/browse/FLINK-23851
Projec
25 matches
Mail list logo
