[jira] [Closed] (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

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua closed FLINK-24952. -- Resolution: Fixed > Rowtime attributes must not be in the input rows of a regular join. As a > workar

[jira] [Closed] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A

[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua closed FLINK-25103. -- Resolution: Fixed > KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A >

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua closed FLINK-24885. -- Resolution: Fixed > ProcessElement Interface parameter Collector : java.lang.NullPointerException > -

[jira] [Updated] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A

[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-25103: --- Summary: KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A (was: KeyedBro

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

[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-25103: --- Issue Type: Improvement (was: Bug) > KeyedBroadcastProcessFunction run set 6, parallelism ValueStat

[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: https://issues.apache.o

[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] [Comment Edited] (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

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445787#comment-17445787 ] wangbaohua edited comment on FLINK-24952 at 11/18/21, 9:53 AM: ---

[jira] [Comment Edited] (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

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445787#comment-17445787 ] wangbaohua edited comment on FLINK-24952 at 11/18/21, 9:52 AM: ---

[jira] [Comment Edited] (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

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445787#comment-17445787 ] wangbaohua edited comment on FLINK-24952 at 11/18/21, 9:51 AM: ---

[jira] [Updated] (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

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24952: --- Environment: (was: public void test() throws Exception { final StreamExecutionEn

[jira] [Commented] (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

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445787#comment-17445787 ] wangbaohua commented on FLINK-24952: public void test() throws Exception {

[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 URL

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443600#comment-17443600 ] wangbaohua commented on FLINK-24885: Yes, the BeanField field is null, but why does

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Component/s: Table SQL / API > ProcessElement Interface parameter Collector : java.lang.NullPointer

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Attachment: error.jpg > ProcessElement Interface parameter Collector : java.lang.NullPointerExcepti

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Description: 2021-11-15 11:11:55,032 INFO com.asap.demo.function.dealMapFunction

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Attachment: (was: 微信图片编辑_2025101728.jpg) > ProcessElement Interface parameter Collector : j

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Attachment: (was: 微信图片编辑_2025101535.jpg) > ProcessElement Interface parameter Collector : j

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443518#comment-17443518 ] wangbaohua commented on FLINK-24885: code: https://gitee.com/wang_bh/flink/blob/mast

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Description: 2021-11-15 09:52:01,984 WARN org.apache.flink.runtime.taskmanager.Task

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Description: !微信图片编辑_2025101728.jpg! (was: !微信图片编辑_2025101535.jpg! ) > ProcessElement I

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Description: (was: !微信图片编辑_2025101535.jpg! ) > ProcessElement Interface parameter Collector

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Attachment: 微信图片编辑_2025101728.jpg > ProcessElement Interface parameter Collector : java.lang.Nu

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Description: !微信图片编辑_2025101535.jpg! > ProcessElement Interface parameter Collector : java.la

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Description: !微信图片编辑_2025101535.jpg! (was: 2021-11-12 17:11:44,024 WARN org.apache.flink.run

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Attachment: 微信图片编辑_2025101535.jpg > ProcessElement Interface parameter Collector : java.lang.Nu

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

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24885: --- Priority: Blocker (was: Major) > ProcessElement Interface parameter Collector : java.lang.NullPoin

[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: F

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

[ https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-24870: --- Description:         at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask

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

[ https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442180#comment-17442180 ] wangbaohua edited comment on FLINK-24870 at 11/11/21, 9:18 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442180#comment-17442180 ] wangbaohua commented on FLINK-24870: DataStream kafkaData1 = kafkaData.map(new MapFu

[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: B