Jingsong Lee created FLINK-11949:
Summary: Introduce DeclarativeAggregateFunction and
AggsHandlerCodeGenerator to blink planner
Key: FLINK-11949
URL: https://issues.apache.org/jira/browse/FLINK-11949
qi quan created FLINK-11948:
---
Summary: When kafka sink parallelismhttps://issues.apache.org/jira/browse/FLINK-11948
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.7.2, 1.6.4, 1.6.3
Hi all,
We found that Flink's Kafka connector does not expose the per-partition
Kafka lag. The metric is available in KafkaConsumer after Kafka 0.10.2. And
it's an important metric to diagnose which Kafka partition is lagging in
production. I've created a JIRA (
https://issues.apache.org/jira/brow
Tzu-Li (Gordon) Tai created FLINK-11947:
---
Summary: Support MapState key / value schema evolution for RocksDB
Key: FLINK-11947
URL: https://issues.apache.org/jira/browse/FLINK-11947
Project: Flink
Jing Zhang created FLINK-11946:
--
Summary: Introduce Exec nodes
Key: FLINK-11946
URL: https://issues.apache.org/jira/browse/FLINK-11946
Project: Flink
Issue Type: Task
Reporter: Jing
Jark Wu created FLINK-11945:
---
Summary: Support Over aggregation for SQL
Key: FLINK-11945
URL: https://issues.apache.org/jira/browse/FLINK-11945
Project: Flink
Issue Type: New Feature
Comp
Jark Wu created FLINK-11944:
---
Summary: Support FirstRow and LastRow for SQL
Key: FLINK-11944
URL: https://issues.apache.org/jira/browse/FLINK-11944
Project: Flink
Issue Type: New Feature
Jark Wu created FLINK-11943:
---
Summary: Support TopN feature for Flink SQL
Key: FLINK-11943
URL: https://issues.apache.org/jira/browse/FLINK-11943
Project: Flink
Issue Type: New Feature
Co
indraneel r created FLINK-11942:
---
Summary: Flink kinesis connector throws kinesis producer daemon
fatalError
Key: FLINK-11942
URL: https://issues.apache.org/jira/browse/FLINK-11942
Project: Flink
