Dian Fu created FLINK-23936:
---
Summary: Python UDFs instances are released and reinitialized if
there is no input for more than 1 minute
Key: FLINK-23936
URL: https://issues.apache.org/jira/browse/FLINK-23936
Liu created FLINK-23937:
---
Summary: Fix PQ comment in KeyGroupPartitionedPriorityQueue
Key: FLINK-23937
URL: https://issues.apache.org/jira/browse/FLINK-23937
Project: Flink
Issue Type: Improvement
Yun Gao created FLINK-23938:
---
Summary: Do not resume channels if the barrier is received via RPC
Key: FLINK-23938
URL: https://issues.apache.org/jira/browse/FLINK-23938
Project: Flink
Issue Type: S
Carl created FLINK-23939:
Summary: The result of validation and parsing failure does not
match the document description
Key: FLINK-23939
URL: https://issues.apache.org/jira/browse/FLINK-23939
Project: Flink
Hi all,
Since Flink 1.14 is already code freeze, we'd like to merge
FLINK-23755 [1]. PR is [2]
We think FLINK-23755 is not a new feature, but it is a behavior
changer and an usability improvement. It's disappointing to wait for
one more release for users.
What do you think?
[1]https://issues.ap
Hi everyone,
Details about FLINK-23755:
Before this JIRA, the below SQL will throw an exception:
"SELECT * FROM kafka_table /*+ OPTIONS('group.id'='new_id') */".
Before, we introduced the feature of dynamic table options, but in
order to avoid user abuse, we turned it off by default, so the abov
+1 to merge this PR for 1.14 release.
This is a widely used and stable feature, so it would be nice to be enabled
by default.
Best,
Jark
On Tue, 24 Aug 2021 at 17:02, Jingsong Li wrote:
> Hi everyone,
>
> Details about FLINK-23755:
>
> Before this JIRA, the below SQL will throw an exception:
>
Dian Fu created FLINK-23940:
---
Summary: Improve the documentation about how to use logging in
PyFlink jobs
Key: FLINK-23940
URL: https://issues.apache.org/jira/browse/FLINK-23940
Project: Flink
Iss
Hi Flink Community!
A quick heads-up: We suggest removing the setting
"CheckpointConfig.setPreferCheckpointForRecovery()" [1].
The setting has been deprecated since Flink 1.12 and is strongly
discouraged, because it can lead to data loss or data duplication in
different scenarios.
Please see also
Chesnay Schepler created FLINK-23941:
Summary: pyflink.datastream.connectors module not documented in
PyDocs
Key: FLINK-23941
URL: https://issues.apache.org/jira/browse/FLINK-23941
Project: Flink
Chesnay Schepler created FLINK-23942:
Summary: Python documentation redirects to shared pages should
activate python tabs
Key: FLINK-23942
URL: https://issues.apache.org/jira/browse/FLINK-23942
Pr
Roc Marshal created FLINK-23943:
---
Summary: "/jobs/:jobid/stop" in REST API can't stop the target job.
Key: FLINK-23943
URL: https://issues.apache.org/jira/browse/FLINK-23943
Project: Flink
Issu
Great, thanks Danny.
On Mon, Aug 23, 2021 at 9:41 PM Danny Cranmer
wrote:
> Thanks Till!
>
> +1 making Scala 2.12 the default. I will raise a Jira tomorrow, not at the
> laptop today.
>
> On Mon, 23 Aug 2021, 09:43 Martijn Visser, wrote:
>
> > +1 to switch to 2.12 by default
> >
> > On Sat, 21
Dian Fu created FLINK-23944:
---
Summary: PulsarSourceITCase.testTaskManagerFailure is instable
Key: FLINK-23944
URL: https://issues.apache.org/jira/browse/FLINK-23944
Project: Flink
Issue Type: Impro
Thanks Seth for spotting and fixing the issue. In that case this vote will
be cancelled in favor of a new RC.
Since this doesn’t affect functionality / testing efforts, RC2 will have
the same ending vote time as the original RC1.
Any ongoing testing efforts can continue while RC2 is rolling out.
钟洋洋 created FLINK-23945:
---
Summary: 无法打开Flink dashboard界面
Key: FLINK-23945
URL: https://issues.apache.org/jira/browse/FLINK-23945
Project: Flink
Issue Type: Technical Debt
Components: Deployme
Till Rohrmann created FLINK-23946:
-
Summary: Application mode fails fatally when being shut down
Key: FLINK-23946
URL: https://issues.apache.org/jira/browse/FLINK-23946
Project: Flink
Issue T
Till Rohrmann created FLINK-23947:
-
Summary: DefaultDispatcherRunner does not log when the Dispatcher
gains and loses leadership
Key: FLINK-23947
URL: https://issues.apache.org/jira/browse/FLINK-23947
Hi everyone,
Please review and vote on the release candidate #2 for the version 3.1.0 of
Apache Flink Stateful Functions, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the projec
Dear Apache Flink community,
Today we moved from the two week sync rhythm to a one week one as we entered
the stabilisation phase last week.
*Status check:*
All features got the state of "done" or "done done". There have been two
features that have no cross team testing ticket, but they will be
Sorry, the subject of the previous message should have said "[VOTE] Apache
Flink Stateful Functions 3.1.0, release candidate #2".
On Tue, Aug 24, 2021 at 3:24 PM Igal Shilman wrote:
> Hi everyone,
>
> Please review and vote on the release candidate #2 for the version 3.1.0
> of Apache Flink Sta
Mika Naylor created FLINK-23948:
---
Summary: Python Client Executable priority incorrect for
PYFLINK_CLIENT_EXECUTABLE environment variable
Key: FLINK-23948
URL: https://issues.apache.org/jira/browse/FLINK-23948
Feifan Wang created FLINK-23949:
---
Summary: first incremental checkpoint after a savepoint will
degenerate into a full checkpoint
Key: FLINK-23949
URL: https://issues.apache.org/jira/browse/FLINK-23949
P
Roman Khachatryan created FLINK-23950:
-
Summary: Revert FLINK-23738 (i.e. unhide config, API, docs)
Key: FLINK-23950
URL: https://issues.apache.org/jira/browse/FLINK-23950
Project: Flink
Seth Wiesman created FLINK-23951:
Summary: Add golang examples to playground
Key: FLINK-23951
URL: https://issues.apache.org/jira/browse/FLINK-23951
Project: Flink
Issue Type: Improvement
Leonid Ilyevsky created FLINK-23952:
---
Summary: Taskmanager fails to start complaining about missing
configuration option
Key: FLINK-23952
URL: https://issues.apache.org/jira/browse/FLINK-23952
Proje
Iaroslav Zeigerman created FLINK-23953:
--
Summary: AvroSerializerSnapshot causes state migration even though
the old and the new schemas are compatible
Key: FLINK-23953
URL: https://issues.apache.org/jira/brow
Agree that this sounds more like a behavior change of an existing stable
feature, rather than a new feature.
No concern from my side. I'd respect your component expertise on whether
this change should happen.
Thank you~
Xintong Song
On Tue, Aug 24, 2021 at 5:09 PM Jark Wu wrote:
> +1 to mer
Xintong Song created FLINK-23954:
Summary: Queryable state (rocksdb) with TM restart end-to-end test
fails on azure
Key: FLINK-23954
URL: https://issues.apache.org/jira/browse/FLINK-23954
Project: Fli
Jun Zhang created FLINK-23955:
-
Summary: submit flink sql job error when flink HA on yarn is
configured
Key: FLINK-23955
URL: https://issues.apache.org/jira/browse/FLINK-23955
Project: Flink
Iss
Xintong Song created FLINK-23956:
Summary: KafkaITCase.testOneSourceMultiplePartitions fails due to
"The topic metadata failed to propagate to Kafka broker"
Key: FLINK-23956
URL: https://issues.apache.org/jira/bro
waywtdcc created FLINK-23958:
Summary: parent-first class orders configuration not effect
Key: FLINK-23958
URL: https://issues.apache.org/jira/browse/FLINK-23958
Project: Flink
Issue Type: Bug
Xintong Song created FLINK-23957:
Summary:
KafkaProducerAtLeastOnceITCase.testOneToOneAtLeastOnceRegularSink fails on azure
Key: FLINK-23957
URL: https://issues.apache.org/jira/browse/FLINK-23957
Proj
Dong Lin created FLINK-23959:
Summary: FLIP-175: Add GraphBuilder to compose
Estimator/Transformer/AlgoOperator from a DAG of stages
Key: FLINK-23959
URL: https://issues.apache.org/jira/browse/FLINK-23959
Xintong Song created FLINK-23960:
Summary: StreamTaskTimerTest.checkScheduledTimestamps fails on
azure
Key: FLINK-23960
URL: https://issues.apache.org/jira/browse/FLINK-23960
Project: Flink
David Morávek created FLINK-23961:
-
Summary: Give a more descriptive exception message for unset
kubernetes options
Key: FLINK-23961
URL: https://issues.apache.org/jira/browse/FLINK-23961
Project: Fli
36 matches
Mail list logo
