[jira] [Created] (FLINK-22817) About flink1.13 hive integration Kafka SQL

xingyuan cheng created FLINK-22817: -- Summary: About flink1.13 hive integration Kafka SQL Key: FLINK-22817 URL: https://issues.apache.org/jira/browse/FLINK-22817 Project: Flink Issue Type: N

[jira] [Created] (FLINK-22816) Investigate feasibility of supporting multiple RM leader sessions within JM process

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 P

How to use or configure flink checkpointing with siddhi internal state

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

[jira] [Created] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

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

[jira] [Created] (FLINK-22814) New sources are not defining/exposing checkpointStartDelayNanos metric

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: F

[jira] [Created] (FLINK-22813) Drop usages of legacy planner in Hive module

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: Sub-

[DISCUSS] Dashboard/HistoryServer authentication

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 securi

[jira] [Created] (FLINK-22812) Fix hive issues in sql-connector-hive jars

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

Re: [ANNOUNCE] Apache Flink 1.13.1 released

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 (김영우) >

[jira] [Created] (FLINK-22811) Drop usages of legacy planner in Avro module

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: Sub-

[jira] [Created] (FLINK-22810) Drop usages of flink-table-planner in Elasticsearch modules

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

[jira] [Created] (FLINK-22809) Improve the exception message when a KafkaIngress receives a NULL key.

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: Flink

Re: [DISCUSS][Statebackend][Runtime] Changelog Statebackend Configuration Proposal

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. state.backen

Re: [ANNOUNCE] Apache Flink 1.13.1 released

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, >> >> Usua

Re: [ANNOUNCE] Apache Flink 1.13.1 released

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 to

Re: [ANNOUNCE] Apache Flink 1.13.1 released

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 official

[jira] [Created] (FLINK-22808) Log metadata

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 Compone

[jira] [Created] (FLINK-22807) AttributeError: 'Builder' object has no attribute 'is_streaming_mode'

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 Is