[
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
>
[
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
>
[
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
>
[
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:
[
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445787#comment-17445787
]
wangbaohua edited comment on FLINK-24952 at 11/18/21, 9:53 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445787#comment-17445787
]
wangbaohua edited comment on FLINK-24952 at 11/18/21, 9:52 AM:
---
public
[
https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445787#comment-17445787
]
wangbaohua edited comment on FLINK-24952 at 11/18/21, 9:51 AM:
---
public
[
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
[
https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445787#comment-17445787
]
wangbaohua commented on FLINK-24952:
public void test() throws Exception {
final
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
[
https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443600#comment-17443600
]
wangbaohua commented on FLINK-24885:
Yes, the BeanField field is null, but why does the
[
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 :
[
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 :
[
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
[
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 :
[
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 :
[
https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443518#comment-17443518
]
wangbaohua commented on FLINK-24885:
code:
[
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
[
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
[
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
[
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 :
[
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 :
[
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
[
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 :
[
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 :
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:
[
https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangbaohua updated FLINK-24870:
---
Description:
at
[
https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442180#comment-17442180
]
wangbaohua edited comment on FLINK-24870 at 11/11/21, 9:18 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442180#comment-17442180
]
wangbaohua commented on FLINK-24870:
DataStream kafkaData1 = kafkaData.map(new MapFunction() {
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:
33 matches
Mail list logo