[jira] [Created] (FLINK-32725) Add option to control writing of timestamp to Kafka topic in KafkaRecordSerializationSchema.builder

xiechenling created FLINK-32725: --- Summary: Add option to control writing of timestamp to Kafka topic in KafkaRecordSerializationSchema.builder Key: FLINK-32725 URL: https://issues.apache.org/jira/browse/FLINK-32725

[jira] [Created] (FLINK-32266) Kafka Source Continues Consuming Previous Topic After Loading Savepoint

xiechenling created FLINK-32266: --- Summary: Kafka Source Continues Consuming Previous Topic After Loading Savepoint Key: FLINK-32266 URL: https://issues.apache.org/jira/browse/FLINK-32266 Project: Flink

[jira] [Created] (FLINK-29380) Two streams union, watermark error, not the minimum value

xiechenling created FLINK-29380: --- Summary: Two streams union, watermark error, not the minimum value Key: FLINK-29380 URL: https://issues.apache.org/jira/browse/FLINK-29380 Project: Flink

[jira] [Created] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'.

xiechenling created FLINK-25440: --- Summary: Apache Pulsar Connector Document description error about 'Starting Position'. Key: FLINK-25440 URL: https://issues.apache.org/jira/browse/FLINK-25440 Project:

[jira] [Created] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

xiechenling created FLINK-23420: --- Summary: sql stream mode lag function java.lang.NullPointerException Key: FLINK-23420 URL: https://issues.apache.org/jira/browse/FLINK-23420 Project: Flink