Thanks for the feedback!
>
> # 1 Flink Native vs Standalone integration
> Maybe we should make this more clear in the FLIP but we agreed to do the
> first version of the operator based on the native integration.
> While this clearly does not cover all use-cases and requirements, it seems
> this wo
Caizhi Weng created FLINK-25861:
---
Summary: Move states of AbstractAvroBulkFormat into its reader
Key: FLINK-25861
URL: https://issues.apache.org/jira/browse/FLINK-25861
Project: Flink
Issue Typ
Yingjie Cao created FLINK-25860:
---
Summary: Move read buffer allocation and output file creation to
setup method for sort-shuffle result partition to avoid blocking main thread
Key: FLINK-25860
URL: https://issues.ap
+1 (non-binding)
- verified checksum and signatures
- build from source code
- version checked
- test docker PR
- test flink-statefun-playground/greeter with 3.2.0
Misc, do we want to upgrade flink-statefun-playground together? Currently
the README information is a little behind.
B.R.
Mingmin
Yuri Gusev created FLINK-25859:
--
Summary: Add documentation for DynamoDB Async Sink
Key: FLINK-25859
URL: https://issues.apache.org/jira/browse/FLINK-25859
Project: Flink
Issue Type: New Feature
Jing Ge created FLINK-25858:
---
Summary: Remove ArchUnit rules for JUnit 4 in ITCaseRules the
JUnit 4->5 migration is closed
Key: FLINK-25858
URL: https://issues.apache.org/jira/browse/FLINK-25858
Project: Fl
As there have been only votes in favour of pushing the feature freeze we pushed
it to the 14th of February.
The bi-weekly sync meeting will happen every week now.
A nice holiday to all the Chinese contributors.
Best,
Joe
> On 26.01.2022, at 09:26, David Morávek wrote:
>
> +1, especially for t
Hi All!
Thanks for the questions, there are still quite a few unknowns and
decisions to be made but here are my current thoughts:
# 1 Flink Native vs Standalone integration
Maybe we should make this more clear in the FLIP but we agreed to do the
first version of the operator based on the native i
Fabian Paul created FLINK-25857:
---
Summary: Add committer metrics to track the status of committables
Key: FLINK-25857
URL: https://issues.apache.org/jira/browse/FLINK-25857
Project: Flink
Issue
Huang Xingbo created FLINK-25856:
Summary: Fix use of UserDefinedType in from_elements
Key: FLINK-25856
URL: https://issues.apache.org/jira/browse/FLINK-25856
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25855:
-
Summary: DefaultDeclarativeSlotPool rejects offered slots when the
job is restarting
Key: FLINK-25855
URL: https://issues.apache.org/jira/browse/FLINK-25855
Project
Martijn Visser created FLINK-25854:
--
Summary: Annotate legacy FileSource as deprecated
Key: FLINK-25854
URL: https://issues.apache.org/jira/browse/FLINK-25854
Project: Flink
Issue Type: Tech
Martijn Visser created FLINK-25853:
--
Summary: Annotate current JDBC connector as deprecated to prepare
for new JDBC connector
Key: FLINK-25853
URL: https://issues.apache.org/jira/browse/FLINK-25853
P
Martijn Visser created FLINK-25852:
--
Summary: Annotate SourceFunction and SinkFunction as deprecated
Key: FLINK-25852
URL: https://issues.apache.org/jira/browse/FLINK-25852
Project: Flink
Is
Etienne Chauchot created FLINK-25851:
Summary: CassandraConnectorITCase.testRetrialAndDropTables shows
table already exists errors on AZP
Key: FLINK-25851
URL: https://issues.apache.org/jira/browse/FLINK-25851
Hi,
FLIP-203 [1] Has been accepted. There were 4 binding votes and 2
non-binding in favor. None against.
Binding:
Till Rohrmann
Dawid Wysakowicz
Konstantin Knauf
Yu Li
Non-binding:
David Moravek
Anton Kalashnikov
Best,
Piotrek
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-203%3A+I
Hi,
Thank you for casting your votes. I have forgotten to set the voting
period, but let's implicitly assume it was 3 days from the creation of the
voting thread.
FLIP-203 [1] Has been accepted. There were 4 binding votes and 2
non-binding in favor. None against.
Best,
Piotrek
[1]
https://cwiki
Roman Khachatryan created FLINK-25850:
-
Summary: Consider notifying nested state backend about checkpoint
abortion
Key: FLINK-25850
URL: https://issues.apache.org/jira/browse/FLINK-25850
Project:
Till Rohrmann created FLINK-25849:
-
Summary: Differentiate TaskManager sessions
Key: FLINK-25849
URL: https://issues.apache.org/jira/browse/FLINK-25849
Project: Flink
Issue Type: Sub-task
Thanks a lot for driving this release Chesnay!
Cheers,
Till
On Thu, Jan 27, 2022 at 10:33 AM Francesco Guardiani <
france...@ververica.com> wrote:
> Thanks Chesnay for this!
>
> FG
>
> On Mon, Jan 24, 2022 at 11:20 AM David Morávek wrote:
>
> > That's a great news Chesnay, thanks for driving th
Thanks Chesnay for this!
FG
On Mon, Jan 24, 2022 at 11:20 AM David Morávek wrote:
> That's a great news Chesnay, thanks for driving this! This should unblock
> some ongoing Flink efforts +1
>
> Best,
> D.
>
> On Mon, Jan 24, 2022 at 10:58 AM Chesnay Schepler
> wrote:
>
> > Hello everyone,
> >
Danny Cranmer created FLINK-25848:
-
Summary: [FLIP-171] KDS Sink does not fast fail when invalid
configuration supplied
Key: FLINK-25848
URL: https://issues.apache.org/jira/browse/FLINK-25848
Project:
Yun Gao created FLINK-25847:
---
Summary: KubernetesHighAvailabilityRecoverFromSavepointITCase.
testRecoverFromSavepoint failed on azure
Key: FLINK-25847
URL: https://issues.apache.org/jira/browse/FLINK-25847
Danny Cranmer created FLINK-25846:
-
Summary: Async Sink does not gracefully shutdown on Cancel
Key: FLINK-25846
URL: https://issues.apache.org/jira/browse/FLINK-25846
Project: Flink
Issue Typ
Timo Walther created FLINK-25845:
Summary: Expose plan via SQL COMPILE / EXECUTE PLAN
Key: FLINK-25845
URL: https://issues.apache.org/jira/browse/FLINK-25845
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-25844:
Summary: Expose plan via StatementSet.compilePlan
Key: FLINK-25844
URL: https://issues.apache.org/jira/browse/FLINK-25844
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-25843:
Summary: Expose plan via
Table.compilePlan/TableEnvironment.fromPlan
Key: FLINK-25843
URL: https://issues.apache.org/jira/browse/FLINK-25843
Project: Flink
Roman Khachatryan created FLINK-25842:
-
Summary: [v2] FLIP-158: Generalized incremental checkpoints
Key: FLINK-25842
URL: https://issues.apache.org/jira/browse/FLINK-25842
Project: Flink
Timo Walther created FLINK-25841:
Summary: Expose plan via
TableEnvironment.compilePlanSql/executePlan
Key: FLINK-25841
URL: https://issues.apache.org/jira/browse/FLINK-25841
Project: Flink
Hang Ruan created FLINK-25840:
-
Summary: Add semantic test support in the connector testframe
Key: FLINK-25840
URL: https://issues.apache.org/jira/browse/FLINK-25840
Project: Flink
Issue Type: Su
30 matches
Mail list logo
