Hi everyone,
We're looking for community members, who would like to maintain Flink's
Cassandra connector [1] going forward. The connector currently is only
available as a Sink for DataStream users and the original contributors are
unable to work on further improvements.
An overview of some of the
Piotr Nowojski created FLINK-25744:
--
Summary: Support native savepoints (w/o modifying the statebackend
specific snapshot strategies)
Key: FLINK-25744
URL: https://issues.apache.org/jira/browse/FLINK-25744
Piotr Nowojski created FLINK-25745:
--
Summary: Support RocksDB incremental native savepoints
Key: FLINK-25745
URL: https://issues.apache.org/jira/browse/FLINK-25745
Project: Flink
Issue Type:
Hi Robert,
I agree with you, I mean that's why I was writing a K8s operator, but the
restriction wasn't decided by me, it was imposed on me. I guess my thinking was
rather that an operator wouldn't necessarily supersede standalone+reactive, at
least not in my case, but that certainly doesn't me
Dear Community,
I hope this email finds you well.
I am a beginner and I had some points that needed clarification.
I am working on multiple flink pipelines, and need to deploy those pipelines on
kubernetes but I am not sure if I should deploy these pipelines in one
repository (one application
Hi everyone,
We're looking for community members, who would like to maintain Flink's
NiFi connector [1] going forward. The connector currently is available as a
Source and Sink for DataStream users and it hasn't been maintained in the
past couple of years.
An overview of some of the things that a
Hi everyone,
I would like to discuss deprecating Flinks' Twitter connector [1]. This was
one of the first connectors that was added to Flink, which could be used to
access the tweets from Twitter. Given the evolution of Flink over Twitter,
I don't think that:
* Users are still using this connecto
Thanks Thomas & Biao for your feedback.
Any additional opinions on how we should proceed with per job-mode? As you
might have guessed, I am leaning towards proposing to deprecate per-job
mode.
On Thu, Jan 13, 2022 at 5:11 PM Thomas Weise wrote:
> Regarding session mode:
>
> ## Session Mode
> *
Jane Chan created FLINK-25746:
-
Summary: Failed to run ITCase locally with IDEA under flink-orc
and flink-parquet module
Key: FLINK-25746
URL: https://issues.apache.org/jira/browse/FLINK-25746
Project: Fl
Thanks a lot for your votes. I am closing the vote now and will post the
result as a separate email thread.
Cheers,
Till
On Fri, Jan 21, 2022 at 5:06 AM Yang Wang wrote:
> +1 (binding)
>
> This would be useful especially for K8s users.
>
> Best,
> Yang
>
> David Morávek 于2022年1月20日周四 18:19写道：
Hi everyone,
I am happy to announce that FLIP-201 [1] has been accepted by this vote [2].
* Etienne Chauchot (non-binding)
* Till Rohrmann (binding)
* Matthias Pohl (binding)
* Chesnay Schepler (binding)
* David Moravek (non-binding)
* Yang Wang (binding)
[1] https://cwiki.apache.org/confluence/
As per offline discussion with Piotr: we have some ways to deal with
possible incompatibilities (hiding them behind a feature flag, new state
backend implementation). Having faster adoption of the new Flink releases
is more valuable in this context, than a possible overhead on the
implementation si
Till Rohrmann created FLINK-25747:
-
Summary: UdfStreamOperatorCheckpointingITCase hangs on AZP
Key: FLINK-25747
URL: https://issues.apache.org/jira/browse/FLINK-25747
Project: Flink
Issue Typ
Konstantin Knauf created FLINK-25748:
Summary: Website misses some Repositories
Key: FLINK-25748
URL: https://issues.apache.org/jira/browse/FLINK-25748
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-25749:
-
Summary: YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP
Key: FLINK-25749
URL: https://issues.apache.org/jira/browse/FLINK-25749
Project: Flink
Roman Khachatryan created FLINK-25750:
-
Summary: Performance regression on 20.01.2021 in globalWindow and
stateBackend benchmarks
Key: FLINK-25750
URL: https://issues.apache.org/jira/browse/FLINK-25750
+1 (binding)
Thanks for driving this. Looking forward to this feature.
Regards,
Dian
On Thu, Jan 20, 2022 at 5:57 PM Gen Luo wrote:
> +1 (non-binding)
>
> On Thu, Jan 20, 2022 at 3:26 PM Yun Gao
> wrote:
>
> > +1 (binding)
> >
> > Thanks Xuannan for driving this!
> >
> > Best,
> > Yun
> >
> >
Niklas Semmler created FLINK-25751:
--
Summary: flink-table tests exit with code 137
Key: FLINK-25751
URL: https://issues.apache.org/jira/browse/FLINK-25751
Project: Flink
Issue Type: Bug
Igal Shilman created FLINK-25752:
Summary: Create a migration e2e test
Key: FLINK-25752
URL: https://issues.apache.org/jira/browse/FLINK-25752
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-25753:
-
Summary: KafkaTableITCase.testStartFromGroupOffsetsLatest fails on
AZP
Key: FLINK-25753
URL: https://issues.apache.org/jira/browse/FLINK-25753
Project: Flink
Sergey Nuyanzin created FLINK-25754:
---
Summary: Drop unused private class
org.apache.flink.connector.elasticsearch.table.KeyExtractor.ColumnWithIndex
Key: FLINK-25754
URL: https://issues.apache.org/jira/browse/FL
+1 (non-binding)
Thanks for driving this. Looking forward to this feature.
Best,
Roc.
At 2022-01-21 17:22:36, "Dian Fu" wrote:
>+1 (binding)
>
>Thanks for driving this. Looking forward to this feature.
>
>Regards,
>Dian
>
>On Thu, Jan 20, 2022 at 5:57 PM Gen Luo wrote:
>
>> +1 (non-bindin
+1 (binding)
On 19/01/2022 17:03, Till Rohrmann wrote:
+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..
The vote time has passed and we have unanimously approved this release.
binding votes:
* piotr
* till
* chesnay
On 21/01/2022 15:30, Chesnay Schepler wrote:
+1 (binding)
On 19/01/2022 17:03, Till Rohrmann wrote:
+1 (binding)
* Checked checksums and signatures
* Looked at the diff between thi
Hi devs,
I would like to start the vote for FLIP-211 [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.
BR,
G
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-211%3A+K
+1
Thanks for driving this. By the way does the process of voting is only for
Flink committer and not contributors? I’m not familiar and it’s my first voting.
Best,
JunFan.
On Jan 21, 2022, 10:57 PM +0800, Gabor Somogyi ,
wrote:
> Hi devs,
>
> I would like to start the vote for FLIP-211 [1], whi
David Morávek created FLINK-25755:
-
Summary: Introduce shared interface for adaptive scheduler state
transitions
Key: FLINK-25755
URL: https://issues.apache.org/jira/browse/FLINK-25755
Project: Flink
Hi Gabor,
thanks for drafting the FLIP, I think having a solid Kerberos support is
crucial for many enterprise deployments.
I have multiple questions regarding the implementation (note that I have
very limited knowledge of Kerberos):
1) If I understand it correctly, we'll only obtain tokens in t
Andriy Redko created FLINK-25756:
Summary: Dedicated Opensearch connectors
Key: FLINK-25756
URL: https://issues.apache.org/jira/browse/FLINK-25756
Project: Flink
Issue Type: Improvement
1. One thing is important, token management is planned to be done
generically within Flink and not scattered in RM specific code. JobManager
has a DelegationTokenManager which obtains tokens time-to-time (if
configured properly). JM knows which TaskManagers are in place so it can
distribute it to a
Oh and one more thing. I'm planning to add this feature in small chunk of
PRs because security is super hairy area. That way reviewers can be more
easily obtains the concept.
On Fri, 21 Jan 2022, 18:03 David Morávek, wrote:
> Hi Gabor,
>
> thanks for drafting the FLIP, I think having a solid Ker
Hi Gabor,
1. One thing is important, token management is planned to be done
> generically within Flink and not scattered in RM specific code. JobManager
> has a DelegationTokenManager which obtains tokens time-to-time (if
> configured properly). JM knows which TaskManagers are in place so it can
>
Michael Bailey created FLINK-25757:
--
Summary: Fix this security issue related to this exploit:
https://www.exploit-db.com/exploits/48978
Key: FLINK-25757
URL: https://issues.apache.org/jira/browse/FLINK-25757
> I think we might both mean something different by the RM.
You feel it well, I've not specified these terms well in the explanation.
RM I meant resource management framework. JobManager is the Flink class.
This means that inside JM instance there will be a DTM instance, so they
would have the sam
>
> JobManager is the Flink class.
There is no such class in Flink. The closest thing to the JobManager is a
ClusterEntrypoint. The cluster entrypoint spawns new RM Runner & Dispatcher
Runner that start participating in the leader election. Once they gain
leadership they spawn the actual underlyi
Here is the exact class, I'm from mobile so not had a look at the exact
class name:
https://github.com/gaborgsomogyi/flink/blob/8ab75e46013f159778ccfce52463e7bc63e395a9/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java#L176
That keeps track of TMs where the tokens can be
36 matches
Mail list logo
