[jira] [Created] (FLINK-30438) The generated schema is not correct when using value.format debezium-avro-confluent

Jun Qin created FLINK-30438: --- Summary: The generated schema is not correct when using value.format debezium-avro-confluent Key: FLINK-30438 URL: https://issues.apache.org/jira/browse/FLINK-30438 Project:

[jira] [Created] (FLINK-30220) Hide user credentials in Flink SQL JDBC connector

Jun Qin created FLINK-30220: --- Summary: Hide user credentials in Flink SQL JDBC connector Key: FLINK-30220 URL: https://issues.apache.org/jira/browse/FLINK-30220 Project: Flink Issue Type:

[jira] [Created] (FLINK-28834) Add TemporalJoin example and ITCase

Jun Qin created FLINK-28834: --- Summary: Add TemporalJoin example and ITCase Key: FLINK-28834 URL: https://issues.apache.org/jira/browse/FLINK-28834 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28650) Flink SQL Parsing bug for METADATA

Jun Qin created FLINK-28650: --- Summary: Flink SQL Parsing bug for METADATA Key: FLINK-28650 URL: https://issues.apache.org/jira/browse/FLINK-28650 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-27473) Capture time that a job spends on initializing tasks

Jun Qin created FLINK-27473: --- Summary: Capture time that a job spends on initializing tasks Key: FLINK-27473 URL: https://issues.apache.org/jira/browse/FLINK-27473 Project: Flink Issue Type:

[jira] [Created] (FLINK-27173) CoGroupedStreams$TaggedUnion cannot be used as a POJO type

Jun Qin created FLINK-27173: --- Summary: CoGroupedStreams$TaggedUnion cannot be used as a POJO type Key: FLINK-27173 URL: https://issues.apache.org/jira/browse/FLINK-27173 Project: Flink Issue Type:

[jira] [Created] (FLINK-26018) Late events in the new KafkaSource

Jun Qin created FLINK-26018: --- Summary: Late events in the new KafkaSource Key: FLINK-26018 URL: https://issues.apache.org/jira/browse/FLINK-26018 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25160) Make doc clear: tolerable-failed-checkpoints counts consecutive failures

Jun Qin created FLINK-25160: --- Summary: Make doc clear: tolerable-failed-checkpoints counts consecutive failures Key: FLINK-25160 URL: https://issues.apache.org/jira/browse/FLINK-25160 Project: Flink

[jira] [Created] (FLINK-24686) Make doc clear on AsyncFunction::timeout() overriding

Jun Qin created FLINK-24686: --- Summary: Make doc clear on AsyncFunction::timeout() overriding Key: FLINK-24686 URL: https://issues.apache.org/jira/browse/FLINK-24686 Project: Flink Issue Type:

[jira] [Created] (FLINK-24543) Zookeeper connection issue causes inconsistent state in Flink

Jun Qin created FLINK-24543: --- Summary: Zookeeper connection issue causes inconsistent state in Flink Key: FLINK-24543 URL: https://issues.apache.org/jira/browse/FLINK-24543 Project: Flink Issue

[jira] [Created] (FLINK-24310) A bug in the BufferingSink example in the doc

Jun Qin created FLINK-24310: --- Summary: A bug in the BufferingSink example in the doc Key: FLINK-24310 URL: https://issues.apache.org/jira/browse/FLINK-24310 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24238) Page title missing

Jun Qin created FLINK-24238: --- Summary: Page title missing Key: FLINK-24238 URL: https://issues.apache.org/jira/browse/FLINK-24238 Project: Flink Issue Type: Bug Components: Documentation

[jira] [Created] (FLINK-23429) State Processor API failed with FileNotFoundException when working with state files on Cloud Storage

Jun Qin created FLINK-23429: --- Summary: State Processor API failed with FileNotFoundException when working with state files on Cloud Storage Key: FLINK-23429 URL: https://issues.apache.org/jira/browse/FLINK-23429

[jira] [Created] (FLINK-23411) Expose Flink checkpoint details metrics

Jun Qin created FLINK-23411: --- Summary: Expose Flink checkpoint details metrics Key: FLINK-23411 URL: https://issues.apache.org/jira/browse/FLINK-23411 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23410) Use a pool of KafkaProducers to commit Kafka Transactions

Jun Qin created FLINK-23410: --- Summary: Use a pool of KafkaProducers to commit Kafka Transactions Key: FLINK-23410 URL: https://issues.apache.org/jira/browse/FLINK-23410 Project: Flink Issue Type:

[jira] [Created] (FLINK-23201) The check on alignmentDurationNanos seems to be too strict

Jun Qin created FLINK-23201: --- Summary: The check on alignmentDurationNanos seems to be too strict Key: FLINK-23201 URL: https://issues.apache.org/jira/browse/FLINK-23201 Project: Flink Issue Type:

[jira] [Created] (FLINK-22647) The time unit of state access latency on the Flink UI is incorrect

Jun Qin created FLINK-22647: --- Summary: The time unit of state access latency on the Flink UI is incorrect Key: FLINK-22647 URL: https://issues.apache.org/jira/browse/FLINK-22647 Project: Flink

[jira] [Created] (FLINK-22642) UI issue with flame graph

Jun Qin created FLINK-22642: --- Summary: UI issue with flame graph Key: FLINK-22642 URL: https://issues.apache.org/jira/browse/FLINK-22642 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

Jun Qin created FLINK-21336: --- Summary: Activate bloom filter in RocksDB State Backend via Flink configuration Key: FLINK-21336 URL: https://issues.apache.org/jira/browse/FLINK-21336 Project: Flink

[jira] [Created] (FLINK-21315) Support to set operator names in state processor API

Jun Qin created FLINK-21315: --- Summary: Support to set operator names in state processor API Key: FLINK-21315 URL: https://issues.apache.org/jira/browse/FLINK-21315 Project: Flink Issue Type:

[jira] [Created] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

Jun Qin created FLINK-19008: --- Summary: Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb) Key: FLINK-19008 URL: https://issues.apache.org/jira/browse/FLINK-19008

[jira] [Created] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

Jun Qin created FLINK-18998: --- Summary: No watermark is shown on Flink UI when ProcessingTime is used Key: FLINK-18998 URL: https://issues.apache.org/jira/browse/FLINK-18998 Project: Flink Issue

[jira] [Created] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

Jun Qin created FLINK-18702: --- Summary: Flink elasticsearch connector leaks threads and classloaders thereof Key: FLINK-18702 URL: https://issues.apache.org/jira/browse/FLINK-18702 Project: Flink

[jira] [Created] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

Jun Qin created FLINK-17327: --- Summary: Kafka unavailability could cause Flink TM shutdown Key: FLINK-17327 URL: https://issues.apache.org/jira/browse/FLINK-17327 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

Jun Qin created FLINK-17288: --- Summary: Speedup loading from savepoints into RocksDB by bulk load Key: FLINK-17288 URL: https://issues.apache.org/jira/browse/FLINK-17288 Project: Flink Issue Type:

[jira] [Created] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

Jun Qin created FLINK-16419: --- Summary: Avoid to recommit transactions which are known committed successfully to Kafka upon recovery Key: FLINK-16419 URL: https://issues.apache.org/jira/browse/FLINK-16419

[jira] [Created] (FLINK-15865) When to add .uid() call: inconsistent definition of operators in Flink docs

Jun Qin created FLINK-15865: --- Summary: When to add .uid() call: inconsistent definition of operators in Flink docs Key: FLINK-15865 URL: https://issues.apache.org/jira/browse/FLINK-15865 Project: Flink

[jira] [Created] (FLINK-15298) Wrong dependences in the DataStream API tutorial (the wiki-edits example)

Jun Qin created FLINK-15298: --- Summary: Wrong dependences in the DataStream API tutorial (the wiki-edits example) Key: FLINK-15298 URL: https://issues.apache.org/jira/browse/FLINK-15298 Project: Flink

[jira] [Created] (FLINK-14942) State Processing API: add an option to make deep copy

Jun Qin created FLINK-14942: --- Summary: State Processing API: add an option to make deep copy Key: FLINK-14942 URL: https://issues.apache.org/jira/browse/FLINK-14942 Project: Flink Issue Type:

[jira] [Created] (FLINK-14890) TestHarness for KeyedBroadcastProcessFunction

Jun Qin created FLINK-14890: --- Summary: TestHarness for KeyedBroadcastProcessFunction Key: FLINK-14890 URL: https://issues.apache.org/jira/browse/FLINK-14890 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14054) Enable checkpointing via job configuration

Jun Qin created FLINK-14054: --- Summary: Enable checkpointing via job configuration Key: FLINK-14054 URL: https://issues.apache.org/jira/browse/FLINK-14054 Project: Flink Issue Type: Improvement