Unbearably slow Table API time-windowed stream join with RocksDBStateBackend

2019-08-13 Thread LIU Xiao
eftRow) if (null == leftRowListSize) { leftRowListSize = new Integer(0) } leftCache.put(JTuple2.of(timeForLeftRow, leftRowListSize), JTuple2.of(leftRow, emitted)) leftCacheSize.put(timeForLeftRow, leftRowListSize + 1) ... -- LIU Xiao

[jira] [Created] (FLINK-11987) Kafka producer occasionally throws NullpointerException

2019-03-20 Thread LIU Xiao (JIRA)
LIU Xiao created FLINK-11987: Summary: Kafka producer occasionally throws NullpointerException Key: FLINK-11987 URL: https://issues.apache.org/jira/browse/FLINK-11987 Project: Flink Issue Type

[jira] [Created] (FLINK-22610) The test-jar of flink-connector-kafka should include all test classes

2021-05-08 Thread LIU Xiao (Jira)
LIU Xiao created FLINK-22610: Summary: The test-jar of flink-connector-kafka should include all test classes Key: FLINK-22610 URL: https://issues.apache.org/jira/browse/FLINK-22610 Project: Flink

[jira] [Created] (FLINK-23057) flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh

2021-06-21 Thread LIU Xiao (Jira)
LIU Xiao created FLINK-23057: Summary: flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh Key: FLINK-23057 URL: https://issues.apache.org/jira/browse/FLINK-