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
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877608#comment-16877608
]
lynn1.zhang commented on FLINK-13072:
-
from beginning, I also think the {{input.iter
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877608#comment-16877608
]
lynn1.zhang edited comment on FLINK-13072 at 7/3/19 9:02 AM:
-
[
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 lo
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877657#comment-16877657
]
lynn1.zhang commented on FLINK-13072:
-
I think we can modify the document
[https://
[
https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881665#comment-16881665
]
lynn1.zhang commented on FLINK-13072:
-
[~srichter] Please help to close, thx.
> Roc
[
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&focusedCommentId=16881665#comment-16881665
]
lynn1.zhang edited comment on FLINK-13072 at 7/10/19 6:33 AM:
lynn1.zhang created FLINK-21345:
---
Summary: NullPointerException
LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157
Key: FLINK-21345
URL: https://issues.apache.org/jira/browse/FLINK-21345
Proj
[
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 test_streaming(
[
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 test_streaming(
[
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 test_streaming(
[
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
> LogicalCorrelateToJoinFrom
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282291#comment-17282291
]
lynn1.zhang commented on FLINK-21345:
-
[~jark] [~Leonard Xu]
!image-2021-02-10-16-0
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282291#comment-17282291
]
lynn1.zhang edited comment on FLINK-21345 at 2/10/21, 8:51 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282291#comment-17282291
]
lynn1.zhang edited comment on FLINK-21345 at 2/10/21, 8:51 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282291#comment-17282291
]
lynn1.zhang edited comment on FLINK-21345 at 2/17/21, 10:36 AM:
--
[
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
join
[
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
join
[
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
join
[
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
join
[
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
join
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
Pro
[
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
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303838#comment-17303838
]
lynn1.zhang commented on FLINK-21833:
-
Please take a look at this. We depend on this
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: Imp
[
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
[
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. W
[
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. W
[
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. W
[
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. W
[
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. W
[
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:
Attachment: old_projection_code
new_projection_code
> Improve the performance of i
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364195#comment-17364195
]
lynn1.zhang commented on FLINK-22994:
-
[~lzljs3620320] I upload the [^test.sql] wit
[
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&focusedCommentId=17364658#comment-17364658
]
lynn1.zhang commented on FLINK-22994:
-
Hi [~lzljs3620320], ipip return the type of m
[
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&focusedCommentId=17364666#comment-17364666
]
lynn1.zhang commented on FLINK-22994:
-
[^StringConverterTest.java] I also test the S
[
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. W
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364691#comment-17364691
]
lynn1.zhang commented on FLINK-22994:
-
public static void main(String[] args) {f
[
https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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:all-tabpanel
]
lynn1.zhang updated FLINK-22994:
Description:
h1. BackGround
In some nesting udf invoking cases, Flink convert the udf result to e
[
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 e
[
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 e
[
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 invokin
[
https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341677#comment-17341677
]
lynn1.zhang commented on FLINK-21345:
-
Hi [~Leonard Xu], I have updated this PR.
>
[
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 e
[
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 e
[
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 e
[
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 e
53 matches
Mail list logo