Xintong Song created FLINK-22816:
Summary: Investigate feasibility of supporting multiple RM leader
sessions within JM process
Key: FLINK-22816
URL: https://issues.apache.org/jira/browse/FLINK-22816
Hi ,
I was trying to do checkpointing while using siddhi as the CEP engine
running on flink. While using siddhi windowing , it uses an internal state to
aggregated or perform operation on a bucket of events pertaining to a specific
time window. But what i am not sure is how can that state be
Dawid Wysakowicz created FLINK-22815:
Summary: Disable unaligned checkpoints for broadcast partitioning
Key: FLINK-22815
URL: https://issues.apache.org/jira/browse/FLINK-22815
Project: Flink
Piotr Nowojski created FLINK-22814:
--
Summary: New sources are not defining/exposing
checkpointStartDelayNanos metric
Key: FLINK-22814
URL: https://issues.apache.org/jira/browse/FLINK-22814
Project:
Timo Walther created FLINK-22813:
Summary: Drop usages of legacy planner in Hive module
Key: FLINK-22813
URL: https://issues.apache.org/jira/browse/FLINK-22813
Project: Flink
Issue Type:
Hi team,
Firstly I would like to introduce Gabor or G [1] for short to the
community, he is a Spark committer who has recently transitioned to the
Flink Engineering team at Cloudera and is looking forward to contributing
to Apache Flink. Previously G primarily focused on Spark Streaming and
Rui Li created FLINK-22812:
--
Summary: Fix hive issues in sql-connector-hive jars
Key: FLINK-22812
URL: https://issues.apache.org/jira/browse/FLINK-22812
Project: Flink
Issue Type: Improvement
Thanks for the great work Dawid and to everyone who has contributed to this
release.
Cheers,
Till
On Mon, May 31, 2021 at 10:25 AM Yangze Guo wrote:
> Thanks, Dawid for the great work, thanks to everyone involved.
>
> Best,
> Yangze Guo
>
> On Mon, May 31, 2021 at 4:14 PM Youngwoo Kim (김영우)
>
Timo Walther created FLINK-22811:
Summary: Drop usages of legacy planner in Avro module
Key: FLINK-22811
URL: https://issues.apache.org/jira/browse/FLINK-22811
Project: Flink
Issue Type:
Timo Walther created FLINK-22810:
Summary: Drop usages of flink-table-planner in Elasticsearch
modules
Key: FLINK-22810
URL: https://issues.apache.org/jira/browse/FLINK-22810
Project: Flink
Igal Shilman created FLINK-22809:
Summary: Improve the exception message when a KafkaIngress
receives a NULL key.
Key: FLINK-22809
URL: https://issues.apache.org/jira/browse/FLINK-22809
Project:
Hey Yuan, thanks for the proposal
I think Option 3 is the simplest to use and exposes less details than any other.
It's also consistent with the current way of configuring state
backends, as long as we treat change logging as a common feature
applicable to any state backend, like e.g.
Thanks, Dawid for the great work, thanks to everyone involved.
Best,
Yangze Guo
On Mon, May 31, 2021 at 4:14 PM Youngwoo Kim (김영우) wrote:
>
> Got it.
> Thanks Dawid for the clarification.
>
> - Youngwoo
>
> On Mon, May 31, 2021 at 4:50 PM Dawid Wysakowicz
> wrote:
>>
>> Hi Youngwoo,
>>
>>
Got it.
Thanks Dawid for the clarification.
- Youngwoo
On Mon, May 31, 2021 at 4:50 PM Dawid Wysakowicz
wrote:
> Hi Youngwoo,
>
> Usually we publish the docker images a day after the general release, so
> that the artifacts are properly distributed across Apache mirrors. You
> should be able
Hi Youngwoo,
Usually we publish the docker images a day after the general release, so
that the artifacts are properly distributed across Apache mirrors. You
should be able to download the docker images from apache/flink now. It
may take a few extra days to have the images published as the
Roman Khachatryan created FLINK-22808:
-
Summary: Log metadata
Key: FLINK-22808
URL: https://issues.apache.org/jira/browse/FLINK-22808
Project: Flink
Issue Type: Sub-task
Yao Li created FLINK-22807:
--
Summary: AttributeError: 'Builder' object has no attribute
'is_streaming_mode'
Key: FLINK-22807
URL: https://issues.apache.org/jira/browse/FLINK-22807
Project: Flink
Hey all,
We would like to start a discussion on how to enable/config Changelog
Statebakcend.
As part of FLIP-158[1], Changelog state backend wraps on top of existing
state backend (HashMapStateBackend, EmbeddedRocksDBStateBackend and may
expect more) and delegates state changes to the underlying
Afaik everyone can start a [VOTE] thread [1]. For example, here a
non-committer started a successful thread [2].
If you start it, I can already cast a binding vote and we just need 2 more
for the FLIP to be accepted.
[1]
Great work! Thank you Dawid and all of the contributors.
I'm eager to adopt the new release, however can't find docker images for
that from https://hub.docker.com/_/flink
Hope it'll be available soon.
Thanks,
Youngwoo
On Sat, May 29, 2021 at 1:49 AM Dawid Wysakowicz
wrote:
> The Apache Flink
20 matches
Mail list logo
