[jira] [Created] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A, could you tell me how to store in the six tasks A

wangbaohua created FLINK-25103: -- Summary: KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A, could you tell me how to store in the six tasks A Key: FLINK-25103 URL:

[jira] [Created] (FLINK-25028) java.lang.OutOfMemoryError: Java heap space

wangbaohua created FLINK-25028: -- Summary: java.lang.OutOfMemoryError: Java heap space Key: FLINK-25028 URL: https://issues.apache.org/jira/browse/FLINK-25028 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24952) Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before

wangbaohua created FLINK-24952: -- Summary: Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before Key: FLINK-24952

[jira] [Created] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

wangbaohua created FLINK-24885: -- Summary: ProcessElement Interface parameter Collector : java.lang.NullPointerException Key: FLINK-24885 URL: https://issues.apache.org/jira/browse/FLINK-24885 Project:

[jira] [Created] (FLINK-24870) Cannot cast "java.util.Date" to "java.time.Instant"

wangbaohua created FLINK-24870: -- Summary: Cannot cast "java.util.Date" to "java.time.Instant" Key: FLINK-24870 URL: https://issues.apache.org/jira/browse/FLINK-24870 Project: Flink Issue Type: