[jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

Lakshmi Rao created FLINK-9691: -- Summary: Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Key: FLINK-9691 URL: https://issues.apache.org/jira/browse/FLINK-9691 Proje

[jira] [Created] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails

Ufuk Celebi created FLINK-9690: -- Summary: Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails Key: FLINK-9690 URL: https://issues.apache.org/jira/browse/FLINK-9690 Project: Flink

[jira] [Created] (FLINK-9689) Flink consumer deserialization example

Satheesh created FLINK-9689: --- Summary: Flink consumer deserialization example Key: FLINK-9689 URL: https://issues.apache.org/jira/browse/FLINK-9689 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9688) ATAN2 Sql Function support

Sergey Nuyanzin created FLINK-9688: -- Summary: ATAN2 Sql Function support Key: FLINK-9688 URL: https://issues.apache.org/jira/browse/FLINK-9688 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-9687) Delay the state fetch only when the triggerResult is fire

aitozi created FLINK-9687: - Summary: Delay the state fetch only when the triggerResult is fire Key: FLINK-9687 URL: https://issues.apache.org/jira/browse/FLINK-9687 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole

Franz Thoma created FLINK-9686: -- Summary: Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole Key: FLINK-9686 URL: https://issues.apache.org/jira/browse/FLINK-9686 Project: Flink