[jira] [Created] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

zhijiang created FLINK-8547: --- Summary: Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control Key: FLINK-8547 URL: https://issues.apache.org/jira/browse/FLINK-8547

[jira] [Created] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6

Till Rohrmann created FLINK-8546: Summary: Respect savepoint settings and recover from latest checkpoint in Flip-6 Key: FLINK-8546 URL: https://issues.apache.org/jira/browse/FLINK-8546 Project: Flink

[jira] [Created] (FLINK-8545) Implement upsert stream table source

Hequn Cheng created FLINK-8545: -- Summary: Implement upsert stream table source Key: FLINK-8545 URL: https://issues.apache.org/jira/browse/FLINK-8545 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null

Bill Lee created FLINK-8544: --- Summary: JSONKeyValueDeserializationSchema throws NPE when message key is null Key: FLINK-8544 URL: https://issues.apache.org/jira/browse/FLINK-8544 Project: Flink Is

[jira] [Created] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

chris snow created FLINK-8543: - Summary: Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen Key: FLINK-8543 URL: https://issues.apache.org/jira/browse/FLINK-8543 Project: Flink

[jira] [Created] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer

Tzu-Li (Gordon) Tai created FLINK-8542: -- Summary: Do not indefinitely store closed shard's state in the FlinkKinesisConsumer Key: FLINK-8542 URL: https://issues.apache.org/jira/browse/FLINK-8542