[DISCUSS] Multi-topics consuming from KafkaTableSource

Hi, all. I want to propose an improvement of KafkaTableSource which can consume multiple topics at the same time. Here is proposal, https://issues.apache.org/jira/browse/FLINK-14729 Best, Leo

Re: [DISCUSS] Multi-topics consuming from KafkaTableSource

On 11/26/2019 08:53??leo <mailto:leozhangs...@qq.com> wrote?? Hi, all. I want to propose an improvement of KafkaTableSource which can consume multiple topics at the same time. Here is proposal, https://issues.apache.org/jira/browse/FLINK-14729 Best, Leo

Re: [DISCUSS] Multi-topics consuming from KafkaTableSource

FlinkKafkaConsumer and it is also easy to achieve this goal just leveraging on the existed APIs. I'll open a VOTE for this feature now and please join this. Best, Leo On 11/27/19 3:12 PM, Gyula Fóra wrote: Hi all, I think the same reasoning applies here as with the regular Kafka consumer so

[VOTE] Multi-topics consuming from KafkaTableSource

#a35570 The vote will be open until it gets enough votes. Best, Leo

[jira] [Created] (FLINK-22616) flink1.13提交任务后，出现以下问题

Leo created FLINK-22616: --- Summary: flink1.13提交任务后，出现以下问题 Key: FLINK-22616 URL: https://issues.apache.org/jira/browse/FLINK-22616 Project: Flink Issue Type: Bug Environment: CloseableIterator

[jira] [Created] (FLINK-22629) table api sql ask

Leo created FLINK-22629: --- Summary: table api sql ask Key: FLINK-22629 URL: https://issues.apache.org/jira/browse/FLINK-22629 Project: Flink Issue Type: Bug Reporter: Leo

[jira] [Created] (FLINK-22634) tableEnvironment executeSql

Leo created FLINK-22634: --- Summary: tableEnvironment executeSql Key: FLINK-22634 URL: https://issues.apache.org/jira/browse/FLINK-22634 Project: Flink Issue Type: Bug Reporter: Leo

Slack invite link

Hey, could I get a Slack invite for this email (he...@leoxiong.com). Thanks! https://flink.apache.org/community.html#slack

[jira] [Created] (FLINK-33449) Support array_contains_seq function

leo cheng created FLINK-33449: - Summary: Support array_contains_seq function Key: FLINK-33449 URL: https://issues.apache.org/jira/browse/FLINK-33449 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

Leo Zhang created FLINK-14319: - Summary: Register user jar files in {Stream}ExecutionEnvironment Key: FLINK-14319 URL: https://issues.apache.org/jira/browse/FLINK-14319 Project: Flink Issue

[jira] [Created] (FLINK-14729) Multi-topics consuming from KafkaTableSource

Leo Zhang created FLINK-14729: - Summary: Multi-topics consuming from KafkaTableSource Key: FLINK-14729 URL: https://issues.apache.org/jira/browse/FLINK-14729 Project: Flink Issue Type: New

[jira] [Created] (FLINK-5221) Checkpointed workless in Window Operator

Syinchwun Leo created FLINK-5221: Summary: Checkpointed workless in Window Operator Key: FLINK-5221 URL: https://issues.apache.org/jira/browse/FLINK-5221 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5387) Lightweight Event Time Window

Syinchwun Leo created FLINK-5387: Summary: Lightweight Event Time Window Key: FLINK-5387 URL: https://issues.apache.org/jira/browse/FLINK-5387 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5546) When multiple users run test, /tmp/cacheFile conflicts

Syinchwun Leo created FLINK-5546: Summary: When multiple users run test, /tmp/cacheFile conflicts Key: FLINK-5546 URL: https://issues.apache.org/jira/browse/FLINK-5546 Project: Flink Issue

[jira] [Created] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

Syinchwun Leo created FLINK-5572: Summary: ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization Key: FLINK-5572 URL: https://issues.apache.org/jira/browse/FLINK-5572

[jira] [Created] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

Syinchwun Leo created FLINK-5756: Summary: When there are many values under the same key in ListState, RocksDBStateBackend performances poor Key: FLINK-5756 URL: https://issues.apache.org/jira/browse/FLINK-5756

[jira] [Created] (FLINK-6106) Blob Server doesn't delete tmp fold when exit in HA mode.

Syinchwun Leo created FLINK-6106: Summary: Blob Server doesn't delete tmp fold when exit in HA mode. Key: FLINK-6106 URL: https://issues.apache.org/jira/browse/FLINK-6106 Project:

[jira] [Created] (FLINK-6202) YarnSessionCli couldn't submit jobs when using -z option

Syinchwun Leo created FLINK-6202: Summary: YarnSessionCli couldn't submit jobs when using -z option Key: FLINK-6202 URL: https://issues.apache.org/jira/browse/FLINK-6202 Project: Flink

[jira] [Created] (FLINK-28475) kafka connector won't stop when the stopping offset is zero

Leo zhang created FLINK-28475: - Summary: kafka connector won't stop when the stopping offset is zero Key: FLINK-28475 URL: https://issues.apache.org/jira/browse/FLINK-28475 Project: Flink

[jira] [Created] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

Leo zhang created FLINK-29128: - Summary: Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader Key: FLINK-29128 URL: https://issues.apache.org/jira/browse/FLINK-29128