Corey Shaw created FLINK-25916:
--
Summary: Using upsert-kafka with a flush buffer results in Null
Pointer Exception
Key: FLINK-25916
URL: https://issues.apache.org/jira/browse/FLINK-25916
Project: Flink
Hi Jeff,
I think the class you're looking for is StatusWatermarkValve. Note that
this is fairly deep into the runtime stack.
Seth
On Tue, Feb 1, 2022 at 2:34 PM Jeff Carter wrote:
> Thanks, Till.
>
> That definitely helps a bit. I'm still not seeing where there is some idle
> variable that the
Thanks, Till.
That definitely helps a bit. I'm still not seeing where there is some idle
variable that the output.markIdle is setting to true (or whatever it sets).
Like the ideal thing would be if there is just some "output.isIdle()" that
could be called to know if the stream is or isnt idle. Sin
Hi Marco,
Thanks for volunteering! It would be great if you could help with
contributions, they are much appreciated.
The plan is indeed to move connectors to its own individual repository, for
Cassandra that most likely would be something like
https://github.com/apache/flink-connector-cassandra.
Martijn Visser created FLINK-25915:
--
Summary: Implement Matomo on Statefun website
Key: FLINK-25915
URL: https://issues.apache.org/jira/browse/FLINK-25915
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-25914:
--
Summary: Performance regression in checkpointSingleInput.UNALIGNED
on 31.01.2022
Key: FLINK-25914
URL: https://issues.apache.org/jira/browse/FLINK-25914
Project:
Hi team,
Thank you for the great feedback, Thomas has updated the FLIP page
accordingly. If you are comfortable with the currently existing design and
depth in the FLIP [1] I suggest moving forward to the voting stage - once
that reaches a positive conclusion it lets us create the separate code
re
Chesnay Schepler created FLINK-25913:
Summary: Disable japicmp binary compatibility check
Key: FLINK-25913
URL: https://issues.apache.org/jira/browse/FLINK-25913
Project: Flink
Issue Type
Piotr Nowojski created FLINK-25912:
--
Summary: HashMapStateBackend performance regression on 31.01.2022
Key: FLINK-25912
URL: https://issues.apache.org/jira/browse/FLINK-25912
Project: Flink
Gabor Somogyi created FLINK-25911:
-
Summary: Add delegation token framework documentation
Key: FLINK-25911
URL: https://issues.apache.org/jira/browse/FLINK-25911
Project: Flink
Issue Type: Su
Gabor Somogyi created FLINK-25910:
-
Summary: Propagate obtained delegation tokens to TaskManagers
Key: FLINK-25910
URL: https://issues.apache.org/jira/browse/FLINK-25910
Project: Flink
Issue
Gabor Somogyi created FLINK-25909:
-
Summary: Move HBase token obtain functionality into
HBaseDelegationTokenProvider
Key: FLINK-25909
URL: https://issues.apache.org/jira/browse/FLINK-25909
Project: Fl
Gabor Somogyi created FLINK-25908:
-
Summary: Move Hadoop FS token obtain functionality into
HadoopFSDelegationTokenProvider
Key: FLINK-25908
URL: https://issues.apache.org/jira/browse/FLINK-25908
Proj
Gabor Somogyi created FLINK-25907:
-
Summary: Add pluggable delegation token manager
Key: FLINK-25907
URL: https://issues.apache.org/jira/browse/FLINK-25907
Project: Flink
Issue Type: Sub-task
Jing Ge created FLINK-25906:
---
Summary: Remove the ExecutionEnvironment dependency in
LocalStreamEnvironment
Key: FLINK-25906
URL: https://issues.apache.org/jira/browse/FLINK-25906
Project: Flink
I
Hi Dario,
I've seen this pop-up in multiple places indeed and it should be fixed.
However, I do think it should be fixed after or while porting the JDBC Sink
to the target Sink API interface [1].
Best regards,
Martijn
[1] https://issues.apache.org/jira/browse/FLINK-25421
On Mon, 31 Jan 2022 at
Hi Konstantin,
Thanks for volunteering! There are no Blockers for 1.13.6 so you should be
good to go for creating a release candidate.
Best regards,
Martijn
On Wed, 26 Jan 2022 at 08:32, Jing Zhang wrote:
> +1 for releasing Flink 1.13.6
> Thanks Martijn and Konstantin for driving this.
>
> B
The updated FLIP looks good to me. Thanks Gabor for addressing the comments
and updating the FLIP.
+1 (non-binding)
D.
On Mon, Jan 31, 2022 at 10:16 AM Márton Balassi
wrote:
> +1 (binding)
>
> Given [1] I consider the issue David raised resolved. Thanks David and
> please confirm here.
>
> [1]
The Apache Flink community is very happy to announce the release of Apache
Flink Stateful Functions 3.2.0.
Stateful Functions is an API that simplifies building distributed stateful
applications.
It's based on functions with persistent state that can interact dynamically
with strong consistency gu
Hi Xintong, Hi Yang, Hi everyone,
Thank you for speaking up. The vote is formally only about the deprecation
in Flink 1.15.
We can and should continue to collect blockers for the deletion of per-job
mode on YARN. Then there should be one release that allows users to switch.
So, Flink 1.16 indeed
Chesnay Schepler created FLINK-25905:
Summary: Promoting Experimental methods is marked as a violation
Key: FLINK-25905
URL: https://issues.apache.org/jira/browse/FLINK-25905
Project: Flink
Sergey Nuyanzin created FLINK-25904:
---
Summary: NullArgumentException in case of increasing number of
nodes for the job
Key: FLINK-25904
URL: https://issues.apache.org/jira/browse/FLINK-25904
Projec
Matthias Pohl created FLINK-25903:
-
Summary: Heartbeat timeout in BoundedSourceITCase.test[complex
graph]
Key: FLINK-25903
URL: https://issues.apache.org/jira/browse/FLINK-25903
Project: Flink
Matthias Pohl created FLINK-25902:
-
Summary: NullPointerException in
RescalingITCase.testSavepointRescalingOutKeyedState
Key: FLINK-25902
URL: https://issues.apache.org/jira/browse/FLINK-25902
Project
24 matches
Mail list logo
