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
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
Hey, could I get a Slack invite for this email (he...@leoxiong.com). Thanks!
https://flink.apache.org/community.html#slack
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
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
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
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
#a35570
The vote will be open until it gets enough votes.
Best,
Leo
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
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
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
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
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
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
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:
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
Syinchwun Leo created FLINK-5572:
Summary: ListState in SlidingEventTimeWindow and
SlidingProcessingTimeWindow optimization
Key: FLINK-5572
URL: https://issues.apache.org/jira/browse/FLINK-5572
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
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
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
20 matches
Mail list logo
