[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Summary: Improve the performance of nesting udf invoking (was: Improve the
performance of
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364691#comment-17364691
]
lynn1.zhang edited comment on FLINK-22994 at 6/17/21, 4:42 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364691#comment-17364691
]
lynn1.zhang commented on FLINK-22994:
-
public static void main(String[] args) {final int
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as BinaryData, like BinaryStringData.
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364666#comment-17364666
]
lynn1.zhang commented on FLINK-22994:
-
[^StringConverterTest.java] I also test the
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Attachment: StringConverterTest.java
> Improve the performance of invoking nesting udf
>
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364658#comment-17364658
]
lynn1.zhang commented on FLINK-22994:
-
Hi [~lzljs3620320], ipip return the type of map, so the
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Attachment: Test.java
> Improve the performance of invoking nesting udf
>
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364195#comment-17364195
]
lynn1.zhang commented on FLINK-22994:
-
[~lzljs3620320] I upload the [^test.sql] with the
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Attachment: old_projection_code
new_projection_code
> Improve the performance of
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Attachment: test.sql
> Improve the performance of invoking nesting udf
>
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as BinaryData, like BinaryStringData.
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as BinaryData, like BinaryStringData.
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as BinaryData, like BinaryStringData.
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as BinaryData, like BinaryStringData.
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as BinaryData, like BinaryStringData.
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as binary, like BinaryStringData. When
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Attachment: image-2021-06-15-15-42-08-065.png
> Improve the performance of invoking nesting udf
>
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
Flink maintain the udf result as binary, like BinaryStringData. When
lynn1.zhang created FLINK-22994:
---
Summary: Improve the performance of invoking nesting udf
Key: FLINK-22994
URL: https://issues.apache.org/jira/browse/FLINK-22994
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341677#comment-17341677
]
lynn1.zhang commented on FLINK-21345:
-
Hi [~Leonard Xu], I have updated this PR.
>
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303838#comment-17303838
]
lynn1.zhang commented on FLINK-21833:
-
Please take a look at this. We depend on this in our
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
TemporalRowTimeJoinOperator feature will lead to unlimited data expansion,
although
lynn1.zhang created FLINK-21833:
---
Summary: TemporalRowTimeJoinOperator State Leak Although configure
idle.state.retention.time
Key: FLINK-21833
URL: https://issues.apache.org/jira/browse/FLINK-21833
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282291#comment-17282291
]
lynn1.zhang edited comment on FLINK-21345 at 2/17/21, 10:36 AM:
[~jark]
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282291#comment-17282291
]
lynn1.zhang edited comment on FLINK-21345 at 2/10/21, 8:51 AM:
---
[~jark]
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282291#comment-17282291
]
lynn1.zhang edited comment on FLINK-21345 at 2/10/21, 8:51 AM:
---
[~jark]
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282291#comment-17282291
]
lynn1.zhang commented on FLINK-21345:
-
[~jark] [~Leonard Xu]
!image-2021-02-10-16-00-45-553.png!
I
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21345:
Attachment: image-2021-02-10-16-00-45-553.png
> NullPointerException
>
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21345:
Description:
First Step: Create 2 Source Tables as below:
{code:java}
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21345:
Description:
First Step: Create 2 Source Tables as below:
{code:java}
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21345:
Description:
First Step: Create 2 Source Tables as below:
{code:java}
CREATE TABLE
lynn1.zhang created FLINK-21345:
---
Summary: NullPointerException
LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157
Key: FLINK-21345
URL: https://issues.apache.org/jira/browse/FLINK-21345
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881665#comment-16881665
]
lynn1.zhang edited comment on FLINK-13072 at 7/10/19 6:33 AM:
--
[~srichter]
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang closed FLINK-13072.
---
Resolution: Not A Bug
> RocksDBStateBachend is not thread safe and data loss silently
>
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881665#comment-16881665
]
lynn1.zhang commented on FLINK-13072:
-
[~srichter] Please help to close, thx.
> RocksDBStateBachend
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-13072:
Attachment: image-2019-07-03-17-04-17-253.png
> RocksDBStateBachend is not thread safe and data
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877657#comment-16877657
]
lynn1.zhang commented on FLINK-13072:
-
I think we can modify the document
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877608#comment-16877608
]
lynn1.zhang edited comment on FLINK-13072 at 7/3/19 9:02 AM:
-
[~yunta] from
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877608#comment-16877608
]
lynn1.zhang commented on FLINK-13072:
-
from beginning, I also think the {{input.iterator()}} is not
lynn1.zhang created FLINK-13072:
---
Summary: RocksDBStateBachend is not thread safe and data loss
silently
Key: FLINK-13072
URL: https://issues.apache.org/jira/browse/FLINK-13072
Project: Flink
53 matches
Mail list logo
