[jira] [Created] (FLINK-29032) Kafka Consume from timestamp catch exception : Caused by: java.lang.IllegalArgumentException: Invalid negative offset

HunterHunter created FLINK-29032: Summary: Kafka Consume from timestamp catch exception : Caused by: java.lang.IllegalArgumentException: Invalid negative offset Key: FLINK-29032 URL:

[jira] [Created] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

HunterHunter created FLINK-28435: Summary: Flink version 1.15.0 consumption Kafka has backpressure. Key: FLINK-28435 URL: https://issues.apache.org/jira/browse/FLINK-28435 Project: Flink

[jira] [Created] (FLINK-27993) When only use 'flex SQL' to develop programs, `watermark` can be defined when creating view tables

HunterHunter created FLINK-27993: Summary: When only use 'flex SQL' to develop programs, `watermark` can be defined when creating view tables Key: FLINK-27993 URL:

[jira] [Created] (FLINK-25743) Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar

HunterHunter created FLINK-25743: Summary: Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar Key: FLINK-25743 URL: https://issues.apache.org/jira/browse/FLINK-25743

[jira] [Created] (FLINK-25439) StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes

HunterHunter created FLINK-25439: Summary: StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes Key: FLINK-25439 URL: https://issues.apache.org/jira/browse/FLINK-25439

[jira] [Created] (FLINK-25396) lookupjoin source table for pre-partitioning

HunterHunter created FLINK-25396: Summary: lookupjoin source table for pre-partitioning Key: FLINK-25396 URL: https://issues.apache.org/jira/browse/FLINK-25396 Project: Flink Issue Type:

[jira] [Created] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

HunterHunter created FLINK-21278: Summary: NullpointExecption error is reported when using the evictor method to filter the data before the window calculation Key: FLINK-21278 URL:

[jira] [Created] (FLINK-19724) tableEnv.toRetractStream(table, PoJo.class) when

HunterHunter created FLINK-19724: Summary: tableEnv.toRetractStream(table, PoJo.class) when Key: FLINK-19724 URL: https://issues.apache.org/jira/browse/FLINK-19724 Project: Flink Issue Type:

[jira] [Created] (FLINK-15608) State Processor api Write new state will get NullPointerException

HunterHunter created FLINK-15608: Summary: State Processor api Write new state will get NullPointerException Key: FLINK-15608 URL: https://issues.apache.org/jira/browse/FLINK-15608 Project: Flink