Hi David,
I didn't mean "best effort". It's just that we would be relaying on a 3rd
party system, which quoting [1]:
> RocksDB goes to great lengths to ensure data remains both forward- and
backward-compatible
But it's still a 3rd party system that we do not control. It's the same
with KafkaClie
Thanks for bringing this up, +1 to merge the modules to simplify the
landscape for the users.
Best regards, Martijn
On Wed, 19 Jan 2022 at 04:30, Jingsong Li wrote:
> +1 to merge the two modules.
>
> Merging them I don't see any problem, not merging them I feel will
> only increase the complexi
Hi,
Thanks Xuannan for the clarification, I also have no other issues~
Best,
Yun
--Original Mail --
Sender:Xuannan Su
Send Date:Wed Jan 19 11:35:13 2022
Recipients:Flink Dev
Subject:Re: [DISCUSS] FLIP-205: Support cache in DataStream for Batch Processing
Hi
>
> For some users canonical savepoints are prohibitively expensive either to
> take or to recover from. To a point where the system is unable to complete
> them before some timeout/failure happens.
I'd say the same logic applies for re-scaling the job from the RDB based
checkpoint / savepoint. I
Till Rohrmann created FLINK-25698:
-
Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments
fails on AZP
Key: FLINK-25698
URL: https://issues.apache.org/jira/browse/FLINK-25698
Project: Flink
Timo Walther created FLINK-25699:
Summary: Use HashMap for MAP value constructors
Key: FLINK-25699
URL: https://issues.apache.org/jira/browse/FLINK-25699
Project: Flink
Issue Type: Sub-task
simenliuxing created FLINK-25700:
Summary: flinksql Cascading Window TVF Aggregation exception
Key: FLINK-25700
URL: https://issues.apache.org/jira/browse/FLINK-25700
Project: Flink
Issue Ty
Hi Chang,
I think the TableEnvironment is not designed to be used by multiple
threads. If you want to share state between the different instances, then
you have to either duplicate this information or put a synchronization
mechanism into place (e.g. by creating a thread safe CatalogManager or
sync
Hello,
We are using Apache Flink 1.12 version. Due to log4j security
vulnerabilities(CVE-2021-44228) we have upgraded to Flink 1.12.7 which contains
the fix for CVE-2021-44228(Critical) and CVE-2021-45046(Critical). Later two
more vulnerabilities are reported CVE-2021-45105(Moderate) and
CVE-2
Jing Ge created FLINK-25701:
---
Summary: Add API annotation to some Kafka connector core classes
and interface
Key: FLINK-25701
URL: https://issues.apache.org/jira/browse/FLINK-25701
Project: Flink
Jing Ge created FLINK-25702:
---
Summary: Remove the usage of Configurable
Key: FLINK-25702
URL: https://issues.apache.org/jira/browse/FLINK-25702
Project: Flink
Issue Type: Improvement
Re
shizhengchao created FLINK-25703:
Summary: In Batch, I think .stagingPath should be created when the
task is running to prevent permission issues caused by inconsistency of hadoop
usernames
Key: FLINK-25703
URL:
Piotr Nowojski created FLINK-25704:
--
Summary: Performance regression on 18.01.2022 in batch network
benchmarks
Key: FLINK-25704
URL: https://issues.apache.org/jira/browse/FLINK-25704
Project: Flink
+1 (binding)
I checked the diff between 14.0..15.0-rc2, and 15.0-rc1..15.0-rc2, and
didn't find anything suspicious.
Best,
Piotrek
wt., 18 sty 2022 o 14:37 Chesnay Schepler napisał(a):
> Hi everyone,
> Please review and vote on the release candidate #2 for the version 15.0,
> as follows:
> [
Hi everyone,
I'd like to start a vote on creating external repositories [1]. Since the
thread is fairly long, I've also previously summarised it [2].
The vote will be open for at least 72 hours unless there is an objection or
not enough votes.
If the vote passes, I'll document the outcome on a n
Hi everyone,
I'd like to start a vote on moving connectors from Flink to external
connector repositories [1].
The vote will be open for at least 72 hours unless there is an objection or
not enough votes.
If the vote passes, I'll document the outcome on a new page under
https://cwiki.apache.org/c
ChengKai Yang created FLINK-25705:
-
Summary: Translate "Metric Reporters" page of "Deployment" in to
Chinese
Key: FLINK-25705
URL: https://issues.apache.org/jira/browse/FLINK-25705
Project: Flink
Martijn Visser created FLINK-25706:
--
Summary: Add idleness to Kafka Source documentation
Key: FLINK-25706
URL: https://issues.apache.org/jira/browse/FLINK-25706
Project: Flink
Issue Type: Im
+1 (binding)
I think this will speed up connector evolution and core development
experience.
Regards,
Timo
On 19.01.22 14:47, Martijn Visser wrote:
Hi everyone,
I'd like to start a vote on moving connectors from Flink to external
connector repositories [1].
The vote will be open for at lea
+1 (binding)
Regards,
Timo
On 19.01.22 14:47, Martijn Visser wrote:
Hi everyone,
I'd like to start a vote on creating external repositories [1]. Since the
thread is fairly long, I've also previously summarised it [2].
The vote will be open for at least 72 hours unless there is an objection or
+1 (binding)
Cheers,
Till
On Wed, Jan 19, 2022 at 3:58 PM Timo Walther wrote:
> +1 (binding)
>
> I think this will speed up connector evolution and core development
> experience.
>
> Regards,
> Timo
>
> On 19.01.22 14:47, Martijn Visser wrote:
> > Hi everyone,
> >
> > I'd like to start a vote o
+1
Cheers,
Till
On Wed, Jan 19, 2022 at 4:01 PM Timo Walther wrote:
> +1 (binding)
>
> Regards,
> Timo
>
> On 19.01.22 14:47, Martijn Visser wrote:
> > Hi everyone,
> >
> > I'd like to start a vote on creating external repositories [1]. Since the
> > thread is fairly long, I've also previously
+1 (binding)
* Checked checksums and signatures
* Looked at the diff between this RC and 14.0 and everything looked good
Cheers,
Till
On Wed, Jan 19, 2022 at 2:30 PM Piotr Nowojski wrote:
> +1 (binding)
>
> I checked the diff between 14.0..15.0-rc2, and 15.0-rc1..15.0-rc2, and
> didn't find a
+1 (binding)
Best,
Matthias
On Mon, Jan 10, 2022 at 2:53 PM Till Rohrmann wrote:
> +1 (binding)
>
> Cheers,
> Till
>
> On Mon, Jan 10, 2022 at 2:30 PM Etienne Chauchot
> wrote:
>
> > +1
> >
> > Best
> >
> > Etienne Chauchot
> >
> > Le 10/01/2022 à 10:22, Till Rohrmann a écrit :
> > > Hi everyo
Chesnay Schepler created FLINK-25707:
Summary: AdaptiveScheduler never transitions executions into
SCHEDULED state
Key: FLINK-25707
URL: https://issues.apache.org/jira/browse/FLINK-25707
Project:
Till Rohrmann created FLINK-25708:
-
Summary: Upgrade Flink dependency to 1.14.3
Key: FLINK-25708
URL: https://issues.apache.org/jira/browse/FLINK-25708
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-25709:
-
Summary: GlueSchemaRegistryAvroKinesisITCase fails on AZP
Key: FLINK-25709
URL: https://issues.apache.org/jira/browse/FLINK-25709
Project: Flink
Issue Type
Roman Khachatryan created FLINK-25710:
-
Summary: Multiple Kafka IT cases fail with "ContainerLaunch
Container startup failed"
Key: FLINK-25710
URL: https://issues.apache.org/jira/browse/FLINK-25710
+1 (binding)
On Wed, Jan 19, 2022 at 7:57 AM Till Rohrmann wrote:
> +1
>
> Cheers,
> Till
>
> On Wed, Jan 19, 2022 at 4:01 PM Timo Walther wrote:
>
> > +1 (binding)
> >
> > Regards,
> > Timo
> >
> > On 19.01.22 14:47, Martijn Visser wrote:
> > > Hi everyone,
> > >
> > > I'd like to start a vot
+1 (binding)
I think it would be a good idea to test the new infrastructure with a
sample connector for the next release before moving existing connectors.
On Wed, Jan 19, 2022 at 7:56 AM Till Rohrmann wrote:
> +1 (binding)
>
> Cheers,
> Till
>
> On Wed, Jan 19, 2022 at 3:58 PM Timo Walther w
Jordan Moore created FLINK-25711:
Summary: OOM / buffer-overflow on KafkaIO SpecificRecord
Key: FLINK-25711
URL: https://issues.apache.org/jira/browse/FLINK-25711
Project: Flink
Issue Type: B
+1(non-binding)
Thomas Weise 于2022年1月20日周四 05:02写道：
> +1 (binding)
>
>
> On Wed, Jan 19, 2022 at 7:57 AM Till Rohrmann
> wrote:
>
> > +1
> >
> > Cheers,
> > Till
> >
> > On Wed, Jan 19, 2022 at 4:01 PM Timo Walther wrote:
> >
> > > +1 (binding)
> > >
> > > Regards,
> > > Timo
> > >
> > > On 19
Hi community,
I'd like to start a vote on FLIP-204: Introduce Hash Lookup Join [1] which
has been discussed in the thread [2].
The vote will be open for at least 72 hours unless there is an objection or
not enough votes.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-204%3A+Introduce
Qingsheng Ren created FLINK-25712:
-
Summary: Merge flink-connector-testing into
flink-connector-test-utils
Key: FLINK-25712
URL: https://issues.apache.org/jira/browse/FLINK-25712
Project: Flink
Thank you all for the feedback!
I created FLINK-25712 [1] for merging these two modules.
[1] https://issues.apache.org/jira/browse/FLINK-25712
Best,
Qingsheng
> On Jan 19, 2022, at 4:14 PM, Martijn Visser wrote:
>
> Thanks for bringing this up, +1 to merge the modules to simplify the
> la
Hi everyone,
Thanks for all the comments. If there are no further comments, we plan to
start the voting thread on 1/24.
Cheers,
Dong
On Fri, Jan 14, 2022 at 8:26 AM Dong Lin wrote:
> Hi Qingsheng,
>
> Thank you for extending this FLIP to support this feature with Table/SQL.
> I also prefer the
+1
Thanks Martijn for driving
Best,
Jingsong
On Thu, Jan 20, 2022 at 5:06 AM Thomas Weise wrote:
>
> +1 (binding)
>
> I think it would be a good idea to test the new infrastructure with a
> sample connector for the next release before moving existing connectors.
>
>
> On Wed, Jan 19, 2022 at 7
Hi devs,
I would like to start the vote for FLIP-205 [1], which was discussed and
reached a consensus in the discussion thread [2].
The vote will be open for at least 72h, unless there is an objection or not
enough votes.
Best,
Xuannan
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP
+1 (non-binding)
Thanks Martijn for driving this!
Best,
Qingsheng Ren
> On Jan 19, 2022, at 9:47 PM, Martijn Visser wrote:
>
> Hi everyone,
>
> I'd like to start a vote on moving connectors from Flink to external
> connector repositories [1].
>
> The vote will be open for at least 72 hours
+1 (non-binding)
Thanks for driving this Martijn!
Best,
Qingsheng
> On Jan 20, 2022, at 8:55 AM, heng du wrote:
>
> +1(non-binding)
>
> Thomas Weise 于2022年1月20日周四 05:02写道：
>
>> +1 (binding)
>>
>>
>> On Wed, Jan 19, 2022 at 7:57 AM Till Rohrmann
>> wrote:
>>
>>> +1
>>>
>>> Cheers,
>>>
+1
Thanks for driving this Martijn!
Best,
Jingsong
On Thu, Jan 20, 2022 at 12:17 PM Qingsheng Ren wrote:
>
> +1 (non-binding)
>
> Thanks for driving this Martijn!
>
> Best,
>
> Qingsheng
>
> > On Jan 20, 2022, at 8:55 AM, heng du wrote:
> >
> > +1(non-binding)
> >
> > Thomas Weise 于2022年1月20日
The Apache Flink community is very happy to announce the release of
Apache Flink 1.14.3, which is the second bugfix release for the Apache
Flink 1.14 series.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
streaming
weibo zhao created FLINK-25713:
--
Summary: Support VectorNormalize in FlinkML
Key: FLINK-25713
URL: https://issues.apache.org/jira/browse/FLINK-25713
Project: Flink
Issue Type: New Feature
Hi, Jing,
Sorry for the late reply! The previous discussion for the hint syntax
left a minor difference there: whether to use both sides of join table
names or just one 'build' side table name only. I would prefer the later
one.
Users only need to pass the `build` side table(usually the smalle
Hi Suchithra
I don't think there is a plan to release 1.12.7 for this. But I think you
could build it from the source.[1]
[1]
https://github.com/apache/flink/tree/release-1.12#building-apache-flink-from-source
Best,
Guowei
On Wed, Jan 19, 2022 at 7:11 PM V N, Suchithra (Nokia - IN/Bangalore) <
Hi Guowei,
Flink 1.12.7 is already released. Request is for 1.12.8 release with log4j
2.17.1. You meant 1.12.8 here?
Regards,
Suchithra
-Original Message-
From: Guowei Ma
Sent: Thursday, January 20, 2022 11:26 AM
To: dev
Subject: Re: Request for Flink 1.12.8 release
Hi Suchithra
I
Hi Jing,
Sorry for the late reply!
Is there a conclusion about naming here? (Maybe I missed something?)
Use USE_HASH or some other names. Slightly confusing in the FLIP.
And the problem of what to write inside the hint, as mentioned by lincoln.
I think maybe we can list the grammars of other di
Hi Jing,
About `SHUFFLE_HASH(left_table, right_table)`, one case can be shared:
SELECT * FROM left_t
JOIN right_1 ON ...
JOIN right_2 ON ...
JOIN right_3 ON ...
What if we want to use shuffle_hash for all three joints?
SELECT /*+ SHUFFLE_HASH('left_t', 'right_1', 'right_2', 'right_3') */
+1 (non-binding)
D.
On Thu 20. 1. 2022 at 4:09, Xuannan Su wrote:
> Hi devs,
>
> I would like to start the vote for FLIP-205 [1], which was discussed and
> reached a consensus in the discussion thread [2].
>
> The vote will be open for at least 72h, unless there is an objection or not
> enough
+1
Thanks for driving this topic, Martijn
Best,
Yun Tang
From: Jingsong Li
Sent: Thursday, January 20, 2022 12:18
To: dev
Subject: Re: [VOTE] Creating external connector repositories
+1
Thanks for driving this Martijn!
Best,
Jingsong
On Thu, Jan 20, 2022 at
+1
Thanks Martijn for the efforts!
Best,
Yun
--
From:Yun Tang
Send Time:2022 Jan. 20 (Thu.) 15:22
To:dev
Subject:Re: [VOTE] Creating external connector repositories
+1
Thanks for driving this topic, Martijn
Best,
Yun Tang
+1 (binding)
Thanks Xuannan for driving this!
Best,
Yun
--
From:David Morávek
Send Time:2022 Jan. 20 (Thu.) 15:12
To:dev
Subject:Re: [VOTE] FLIP-205: Support cache in DataStream for Batch Processing
+1 (non-binding)
D.
On Thu
52 matches
Mail list logo
