[jira] [Commented] (FLINK-9825) Upgrade checkstyle version to 8.6

2018-07-28 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560778#comment-16560778 ] dalongliu commented on FLINK-9825: -- [~Zentol], [~mingleizhang],Thank you very much, I will try my best

[jira] [Commented] (FLINK-9825) Upgrade checkstyle version to 8.6

2018-07-27 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559769#comment-16559769 ] dalongliu commented on FLINK-9825: -- Hi, [~Zentol], Could you give me permission to contribute to apache

[jira] [Commented] (FLINK-9982) NPE in EnumValueSerializer#copy

2018-07-27 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559759#comment-16559759 ] dalongliu commented on FLINK-9982: -- Hi,[~mingleizhang], I want to fix this bug, thanks! > NPE in

[jira] [Commented] (FLINK-9985) Incorrect parameter order in document

2018-07-27 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559779#comment-16559779 ] dalongliu commented on FLINK-9985: -- Hi, [~mingleizhang], I want to fix  this bug. Thank you very much!

[jira] [Commented] (FLINK-9985) Incorrect parameter order in document

2018-07-27 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559780#comment-16559780 ] dalongliu commented on FLINK-9985: -- Hi, [~mingleizhang], I want to fix  this bug. Thank you very much!

[jira] [Commented] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

2018-08-14 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579809#comment-16579809 ] dalongliu commented on FLINK-10144: --- [~Zentol] can you assign this issue to [~wucj],he want to

[jira] [Created] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

2018-08-14 Thread dalongliu (JIRA)
dalongliu created FLINK-10144: - Summary: No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages" Key: FLINK-10144 URL:

[jira] [Created] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed

2018-10-21 Thread dalongliu (JIRA)
dalongliu created FLINK-10636: - Summary: ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed Key: FLINK-10636 URL: https://issues.apache.org/jira/browse/FLINK-10636

[jira] [Created] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

2019-05-25 Thread dalongliu (JIRA)
dalongliu created FLINK-12623: - Summary: Flink on yarn encountered AMRMClientImpl does not update AMRM token properly Key: FLINK-12623 URL: https://issues.apache.org/jira/browse/FLINK-12623 Project:

[jira] [Assigned] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

2019-05-25 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-12623: - Assignee: dalongliu > Flink on yarn encountered AMRMClientImpl does not update AMRM token

[jira] [Assigned] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

2019-05-25 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-12623: - Assignee: dalongliu > Flink on yarn encountered AMRMClientImpl does not update AMRM token

[jira] [Assigned] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly

2019-05-25 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-12623: - Assignee: (was: dalongliu) > Flink on yarn encountered AMRMClientImpl does not update AMRM

[jira] [Commented] (FLINK-11637) Translate "Checkpoints" page into Chinese

2019-04-30 Thread dalongliu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830423#comment-16830423 ] dalongliu commented on FLINK-11637: --- Hi, [~klion26] Is anyone doing the work now? > Translate

[jira] [Commented] (FLINK-16581) Minibatch deduplication lack state TTL

2020-03-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058446#comment-17058446 ] dalongliu commented on FLINK-16581: --- [~lzljs3620320] I want to fix this bug > Minibatch deduplication

[jira] [Commented] (FLINK-16844) Support retract message for StreamExecGroupWindowAggregate in blink planner

2020-04-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081669#comment-17081669 ] dalongliu commented on FLINK-16844: --- +1, I have similar needs in production which require

[jira] [Updated] (FLINK-17096) Minibatch Group Agg support state ttl

2020-04-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-17096: -- Description: At the moment, MiniBatch Group Agg include Local/Global doesn`t support State TTL, for

[jira] [Commented] (FLINK-17096) Minibatch Group Agg support state ttl

2020-04-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082014#comment-17082014 ] dalongliu commented on FLINK-17096: --- CC [~jark] > Minibatch Group Agg support state ttl >

[jira] [Commented] (FLINK-17099) Refactoring State TTL solution in Group Agg、TopN operator, etc replace Timer with StateTtlConfig

2020-04-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082015#comment-17082015 ] dalongliu commented on FLINK-17099: --- CC [~jark] > Refactoring State TTL solution in Group Agg、TopN

[jira] [Created] (FLINK-17099) Refactoring State TTL solution in Group Agg、TopN operator, etc replace Timer with StateTtlConfig

2020-04-12 Thread dalongliu (Jira)
dalongliu created FLINK-17099: - Summary: Refactoring State TTL solution in Group Agg、TopN operator, etc replace Timer with StateTtlConfig Key: FLINK-17099 URL: https://issues.apache.org/jira/browse/FLINK-17099

[jira] [Created] (FLINK-17096) Minibatch Group Agg support state ttl

2020-04-12 Thread dalongliu (Jira)
dalongliu created FLINK-17096: - Summary: Minibatch Group Agg support state ttl Key: FLINK-17096 URL: https://issues.apache.org/jira/browse/FLINK-17096 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed

2020-04-19 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087320#comment-17087320 ] dalongliu commented on FLINK-10636: --- [~becket_qin] yes, I also encounter this error now when use flink

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2020-03-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068381#comment-17068381 ] dalongliu commented on FLINK-10473: --- [~azagrebin] thks for your reply, I have debuggger stops in 

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2020-03-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068612#comment-17068612 ] dalongliu commented on FLINK-10473: --- [~azagrebin] OK, I got it, tks, I will debug the code again to

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-03-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071658#comment-17071658 ] dalongliu commented on FLINK-16876: --- +1 > Make TtlTimeProvider configurable when creating keyed state

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-04-02 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073484#comment-17073484 ] dalongliu commented on FLINK-16876: --- [~yunta] As you say, you help to implement  customized mock

[jira] [Commented] (FLINK-16876) Make TtlTimeProvider configurable when creating keyed state backend

2020-04-02 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073597#comment-17073597 ] dalongliu commented on FLINK-16876: --- [~azagrebin] So, at the moment, how do you prepare? > Make

[jira] [Commented] (FLINK-16581) Minibatch deduplication lack state TTL

2020-03-25 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17066429#comment-17066429 ] dalongliu commented on FLINK-16581: --- [~jark] I agree with you, use StateTtlConfig can simplify the

[jira] [Comment Edited] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2020-03-26 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067738#comment-17067738 ] dalongliu edited comment on FLINK-10473 at 3/26/20, 2:51 PM: - Hi,

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2020-03-26 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067738#comment-17067738 ] dalongliu commented on FLINK-10473: --- Hi, [~azagrebin], for the pull request you subimmted, when I

[jira] [Updated] (FLINK-17099) Refactoring State TTL solution in Group Agg、Deduplication、TopN operator replace Timer with StateTtlConfig

2020-04-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-17099: -- Description: At the moment, there are 2 ways to cleanup states. 1) registering a processing-time

[jira] [Updated] (FLINK-17099) Refactoring State TTL solution in Group Agg、Deduplication、TopN operators replace Timer with StateTtlConfig

2020-04-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-17099: -- Summary: Refactoring State TTL solution in Group Agg、Deduplication、TopN operators replace Timer with

[jira] [Updated] (FLINK-17099) Refactoring State TTL solution in Group Agg、Deduplication、TopN operator replace Timer with StateTtlConfig

2020-04-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-17099: -- Summary: Refactoring State TTL solution in Group Agg、Deduplication、TopN operator replace Timer with

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105039#comment-17105039 ] dalongliu commented on FLINK-17625: --- [~jark] Can I help to fix this bug? > Fix

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-11 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105050#comment-17105050 ] dalongliu commented on FLINK-17625: --- [~jark] Ok, thanks for your advice. > Fix

[jira] [Updated] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

2020-03-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-16681: -- Description: In my thought, jdbc connector is the one of most frequently used connector in flink .

[jira] [Comment Edited] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113296#comment-17113296 ] dalongliu edited comment on FLINK-17625 at 5/21/20, 3:48 PM: - Hi,

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113296#comment-17113296 ] dalongliu commented on FLINK-17625: --- Hi, [~danny0405], sorry, I haven't done because of something else

[jira] [Comment Edited] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

2020-05-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113296#comment-17113296 ] dalongliu edited comment on FLINK-17625 at 5/21/20, 3:58 PM: - Hi,

[jira] [Created] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
dalongliu created FLINK-19207: - Summary: TtlListState#IteratorWithCleanup support remove method Key: FLINK-19207 URL: https://issues.apache.org/jira/browse/FLINK-19207 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19207: -- Description: In [Minibatch Group Agg support state ttl

[jira] [Updated] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19207: -- Description: In Minibatch Group Agg support state ttl , we are using TTL State refactor group Agg

[jira] [Comment Edited] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194649#comment-17194649 ] dalongliu edited comment on FLINK-19207 at 9/12/20, 7:59 AM: - [~jark] after

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194649#comment-17194649 ] dalongliu commented on FLINK-19207: --- [~jark] after study the source code of IteratorWithCleanup class,

[jira] [Comment Edited] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194649#comment-17194649 ] dalongliu edited comment on FLINK-19207 at 9/12/20, 7:58 AM: - [~jark] after

[jira] [Updated] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19207: -- Description: In [ Minibatch Group Agg support state

[jira] [Updated] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19207: -- Description: In  [Flink-17096|https://issues.apache.org/jira/browse/FLINK-17096] , we are using TTL

[jira] [Updated] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19207: -- Description: In Flink-17096 , we are using TTL State refactor group Agg function state expiration

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196172#comment-17196172 ] dalongliu commented on FLINK-19207: --- Hi [~jark], as you say, I understand we should do as follows: #

[jira] [Comment Edited] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196172#comment-17196172 ] dalongliu edited comment on FLINK-19207 at 9/15/20, 2:05 PM: - Hi [~jark], as

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196643#comment-17196643 ] dalongliu commented on FLINK-19207: --- I see, tks! > TtlListState#IteratorWithCleanup support remove

[jira] [Commented] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214374#comment-17214374 ] dalongliu commented on FLINK-19633: --- I can try it. > Fix ArrayIndexOutOfBoundsException in

[jira] [Updated] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19633: -- Description: This is reported in Dingtalk group by user. Like FLINK-17625 We should check list is

[jira] [Updated] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19633: -- Description: {code:java} java.lang.ArrayIndexOutOfBoundsException: -1 at

[jira] [Created] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
dalongliu created FLINK-19633: - Summary: Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction Key: FLINK-19633 URL: https://issues.apache.org/jira/browse/FLINK-19633 Project: Flink

[jira] [Updated] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19633: -- Description: This is reported in Dingtalk group by user. Like FLINK-17625 We should check list is

[jira] [Updated] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19633: -- Description: This is reported in Dingtalk group by user. Like 

[jira] [Commented] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213922#comment-17213922 ] dalongliu commented on FLINK-19633: --- CC [~jark] > Fix ArrayIndexOutOfBoundsException in

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

2020-09-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204712#comment-17204712 ] dalongliu commented on FLINK-19207: --- [~azagrebin], thanks for your reply, got it. >

[jira] [Commented] (FLINK-19280) The option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to zero

2020-09-17 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198123#comment-17198123 ] dalongliu commented on FLINK-19280: --- I want to try fix it, can you assigne it to me. > The option

[jira] [Updated] (FLINK-19281) LIKE cannot recognize full table path

2020-09-17 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19281: -- Description: for example, if we have a table whose full path is

[jira] [Commented] (FLINK-19258) Fix the wrong example of "csv.line-delimiter" in CSV documentation

2020-09-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196878#comment-17196878 ] dalongliu commented on FLINK-19258: --- Hi, [~jark] I can help do it. > Fix the wrong example of

[jira] [Commented] (FLINK-19276) Allow to read metadata for Debezium format

2020-09-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199179#comment-17199179 ] dalongliu commented on FLINK-19276: --- [~twalthr] Can I help to do this work? > Allow to read metadata

[jira] [Commented] (FLINK-18872) Aggregate with mini-batch does not respect state retention

2020-08-10 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175175#comment-17175175 ] dalongliu commented on FLINK-18872: --- [~libenchao], I have open a Jira issue for this problem months

[jira] [Commented] (FLINK-17716) Remove deprecated RowData.get and similar methods

2020-06-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149064#comment-17149064 ] dalongliu commented on FLINK-17716: --- Hi, [~twalthr] does this work has been done? I'm interesting it.

[jira] [Created] (FLINK-18410) Flink SQL filesystem connector class name correct

2020-06-22 Thread dalongliu (Jira)
dalongliu created FLINK-18410: - Summary: Flink SQL filesystem connector class name correct Key: FLINK-18410 URL: https://issues.apache.org/jira/browse/FLINK-18410 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18410) Flink SQL filesystem connector class name correct

2020-06-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142021#comment-17142021 ] dalongliu commented on FLINK-18410: --- cc [~lzljs3620320], what do you think it? > Flink SQL filesystem

[jira] [Commented] (FLINK-18396) Translate "Formats Overview" page into Chinese

2020-06-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141095#comment-17141095 ] dalongliu commented on FLINK-18396: --- [~jark] can you assign it to me? > Translate "Formats Overview"

[jira] [Comment Edited] (FLINK-18440) ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2020-06-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147217#comment-17147217 ] dalongliu edited comment on FLINK-18440 at 6/28/20, 5:34 AM: - [~shenlang],I

[jira] [Commented] (FLINK-18440) ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2020-06-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147217#comment-17147217 ] dalongliu commented on FLINK-18440: --- [~shenlang],I also encountered this problem when create view use

[jira] [Created] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-10-31 Thread dalongliu (Jira)
dalongliu created FLINK-19905: - Summary: The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction Key: FLINK-19905 URL: https://issues.apache.org/jira/browse/FLINK-19905

[jira] [Updated] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-10-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19905: -- Description: As describe in FLINK-19684, we should init the begin value to 0 in JdbcLookupFunction.

[jira] [Updated] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-10-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-19905: -- Priority: Minor (was: Trivial) > The Jdbc-connector's 'lookup.max-retries' option initial value is 1

[jira] [Commented] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-10-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224027#comment-17224027 ] dalongliu commented on FLINK-19905: --- CC [~jark] > The Jdbc-connector's 'lookup.max-retries' option

[jira] [Created] (FLINK-24822) Improve CatalogTableSpecBase and its subclass method parameter

2021-11-08 Thread dalongliu (Jira)
dalongliu created FLINK-24822: - Summary: Improve CatalogTableSpecBase and its subclass method parameter Key: FLINK-24822 URL: https://issues.apache.org/jira/browse/FLINK-24822 Project: Flink

[jira] [Commented] (FLINK-23217) Support StreamExecValues json serialization/deserialization

2021-07-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17384336#comment-17384336 ] dalongliu commented on FLINK-23217: --- [~godfreyhe] I have opened the PR, please review it, tks. >

[jira] [Created] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-12 Thread dalongliu (Jira)
dalongliu created FLINK-25635: - Summary: Using sql client create hive catalog throw exception Key: FLINK-25635 URL: https://issues.apache.org/jira/browse/FLINK-25635 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475095#comment-17475095 ] dalongliu commented on FLINK-25635: --- cc [~luoyuxia]  > Using sql client create hive catalog throw

[jira] [Created] (FLINK-26813) Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-03-22 Thread dalongliu (Jira)
dalongliu created FLINK-26813: - Summary: Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE Key: FLINK-26813 URL: https://issues.apache.org/jira/browse/FLINK-26813 Project:

[jira] [Updated] (FLINK-26813) Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-03-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26813: -- Parent: FLINK-21634 Issue Type: Sub-task (was: New Feature) > Supports ADD/MODIFY

[jira] [Updated] (FLINK-26929) Introduce adaptive hash join for batch sql optimization

2022-03-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26929: -- Description: We propose an optimization method adaptive hash join for the batch join scenario, hoping

[jira] [Created] (FLINK-26929) Introduce adaptive hash join for batch sql optimization

2022-03-30 Thread dalongliu (Jira)
dalongliu created FLINK-26929: - Summary: Introduce adaptive hash join for batch sql optimization Key: FLINK-26929 URL: https://issues.apache.org/jira/browse/FLINK-26929 Project: Flink Issue

[jira] [Updated] (FLINK-26943) Add DATE_ADD supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26943: -- Description: Returns the date {{numDays}} after {{{}startDate{}}}. Syntax: {code:java}

[jira] [Created] (FLINK-26949) Add NVL supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26949: - Summary: Add NVL supported in SQL & Table API Key: FLINK-26949 URL: https://issues.apache.org/jira/browse/FLINK-26949 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26951) Add HASH supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26951: - Summary: Add HASH supported in SQL & Table API Key: FLINK-26951 URL: https://issues.apache.org/jira/browse/FLINK-26951 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26939) Add TRANSLATE supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26939: - Summary: Add TRANSLATE supported in SQL & Table API Key: FLINK-26939 URL: https://issues.apache.org/jira/browse/FLINK-26939 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26945: - Summary: Add DATE_SUB supported in SQL & Table API Key: FLINK-26945 URL: https://issues.apache.org/jira/browse/FLINK-26945 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26943) Add DATE_ADD supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26943: -- Description: Returns the date {{numDays}} after {{{}startDate{}}}. Syntax: {code:java}

[jira] [Created] (FLINK-26944) Add ADD_MONTHS supported in SQL and Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26944: - Summary: Add ADD_MONTHS supported in SQL and Table API Key: FLINK-26944 URL: https://issues.apache.org/jira/browse/FLINK-26944 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26946) Add SHIFTRIGHT supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26946: - Summary: Add SHIFTRIGHT supported in SQL & Table API Key: FLINK-26946 URL: https://issues.apache.org/jira/browse/FLINK-26946 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26947) Add ARRAY_CONTAINS supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26947: - Summary: Add ARRAY_CONTAINS supported in SQL & Table API Key: FLINK-26947 URL: https://issues.apache.org/jira/browse/FLINK-26947 Project: Flink Issue Type:

[jira] [Created] (FLINK-26943) Add DATE_ADD supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26943: - Summary: Add DATE_ADD supported in SQL & Table API Key: FLINK-26943 URL: https://issues.apache.org/jira/browse/FLINK-26943 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26940) Add SUBSTRING_INDEX supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26940: - Summary: Add SUBSTRING_INDEX supported in SQL & Table API Key: FLINK-26940 URL: https://issues.apache.org/jira/browse/FLINK-26940 Project: Flink Issue Type:

[jira] [Created] (FLINK-26948) Add SORT_ARRAY supported in SQL & Table API

2022-03-31 Thread dalongliu (Jira)
dalongliu created FLINK-26948: - Summary: Add SORT_ARRAY supported in SQL & Table API Key: FLINK-26948 URL: https://issues.apache.org/jira/browse/FLINK-26948 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement

2022-04-01 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516198#comment-17516198 ] dalongliu commented on FLINK-22317: --- I will take over this issue, cc [~jark]  > Support DROP

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

2022-03-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-21634: -- Description: We already introduced ALTER TABLE statement in FLIP-69 [1], but only support to rename

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

2022-03-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-21634: -- Description: We already introduced ALTER TABLE statement in FLIP-69 [1], but only support to rename

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

2022-03-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-21634: -- Description: We already introduced ALTER TABLE statement in FLIP-69 [1], but only support to rename

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-03-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509569#comment-17509569 ] dalongliu commented on FLINK-22315: --- The column position is only used in ADD column syntax, we should

[jira] [Commented] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement

2022-03-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509551#comment-17509551 ] dalongliu commented on FLINK-22317: --- Hi, [~Aiden Gong] are you still doing this work? > Support DROP

[jira] [Comment Edited] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-03-20 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509569#comment-17509569 ] dalongliu edited comment on FLINK-22315 at 3/21/22, 3:13 AM: - The column

  1   2   3   4   5   6   >