[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-20 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268466#comment-17268466 ] Xingxing Di commented on FLINK-20913: - Thanks [~lirui], I've sumitted PRs. > Improv

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-19 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267966#comment-17267966 ] Xingxing Di commented on FLINK-20913: - [~lirui] , I would like to, and i'm working o

[jira] [Issue Comment Deleted] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-15 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Comment: was deleted (was: [~lirui] could you assign it to me, i'll submit a PR.) > Improve new H

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-13 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264242#comment-17264242 ] Xingxing Di commented on FLINK-20913: - [~lirui] could you assign it to me, i'll subm

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-12 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263838#comment-17263838 ] Xingxing Di commented on FLINK-20913: - Hi [~lirui], i looked into the code, i found

[jira] [Updated] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Summary: Improve new HiveConf(jobConf, HiveConf.class) (was: Improve new HiveConf) > Improve new

[jira] [Updated] (FLINK-20913) Improve new HiveConf

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Description: When we query hive tables We got an Exception in  org.apache.flink.connectors.hive.u

[jira] [Updated] (FLINK-20913) Improve new HiveConf

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Summary: Improve new HiveConf (was: Got TTransportException while querying Hive tables) > Improv

[jira] [Updated] (FLINK-20913) Got TTransportException while querying Hive tables

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Description: When we query hive tables We got an Exception in  org.apache.flink.connectors.hive.u

[jira] [Updated] (FLINK-20913) Got TTransportException while querying Hive tables

2021-01-10 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-20913: Description: When we query hive tables We will got an Exception in  org.apache.flink.connectors.h

[jira] [Created] (FLINK-20913) Got TTransportException while querying Hive tables

2021-01-10 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-20913: --- Summary: Got TTransportException while querying Hive tables Key: FLINK-20913 URL: https://issues.apache.org/jira/browse/FLINK-20913 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19947) Support sink parallelism configuration to Print connector

2020-11-03 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225798#comment-17225798 ] Xingxing Di commented on FLINK-19947: - Is anyone working on this, I would like to do

[jira] [Commented] (FLINK-10674) Fix handling of retractions after clean up

2020-07-26 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165401#comment-17165401 ] Xingxing Di commented on FLINK-10674: - Hi Timo, I saw this issue has been fixed in

[jira] [Updated] (FLINK-10674) Fix handling of retractions after clean up

2020-07-26 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-10674: Attachment: screenshot-1.png > Fix handling of retractions after clean up > --

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-07-22 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162494#comment-17162494 ] Xingxing Di edited comment on FLINK-16478 at 7/22/20, 12:51 PM: --

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-07-22 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162494#comment-17162494 ] Xingxing Di edited comment on FLINK-16478 at 7/22/20, 12:51 PM: --

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-07-21 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162494#comment-17162494 ] Xingxing Di commented on FLINK-16478: - Hi [~chesnay], we run flink jobs in "per job"

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-13 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106217#comment-17106217 ] Xingxing Di edited comment on FLINK-16478 at 5/13/20, 2:56 PM: ---

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-13 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106217#comment-17106217 ] Xingxing Di edited comment on FLINK-16478 at 5/13/20, 11:56 AM: --

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-05-13 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106217#comment-17106217 ] Xingxing Di commented on FLINK-16478: - Hi [~trohrmann], thanks for the comments. I u

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-12 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/12/20, 11:53 AM: --

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-12 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/12/20, 11:42 AM: --

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-06 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/7/20, 3:33 AM:

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-06 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/7/20, 3:29 AM:

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-05 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/5/20, 3:38 PM:

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-05 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/5/20, 10:45 AM: ---

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-05-05 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di edited comment on FLINK-16478 at 5/5/20, 10:12 AM: ---

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-05-05 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099746#comment-17099746 ] Xingxing Di commented on FLINK-16478: - Hi [~trohrmann], thanks for the comments. 1.

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-05-01 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097714#comment-17097714 ] Xingxing Di commented on FLINK-16478: - {quote}In general I think such a feature woul

[jira] [Created] (FLINK-17485) Add a thread dump REST API

2020-04-30 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-17485: --- Summary: Add a thread dump REST API Key: FLINK-17485 URL: https://issues.apache.org/jira/browse/FLINK-17485 Project: Flink Issue Type: Improvement Co

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-04-29 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095890#comment-17095890 ] Xingxing Di commented on FLINK-16478: -   {quote}[~xiaodao] [~dixingx...@yeah.net] Gr

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-04-27 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092471#comment-17092471 ] Xingxing Di edited comment on FLINK-16478 at 4/27/20, 1:11 PM: ---

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-04-27 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093496#comment-17093496 ] Xingxing Di commented on FLINK-16478: - [~fly_in_gis] Yes, you can use full qualified

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-04-25 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092478#comment-17092478 ] Xingxing Di edited comment on FLINK-16478 at 4/26/20, 6:35 AM: ---

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-04-25 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092478#comment-17092478 ] Xingxing Di commented on FLINK-16478: - [~felixzheng] yes, than depends on how the lo

[jira] [Comment Edited] (FLINK-16478) add restApi to modify loglevel

2020-04-25 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092471#comment-17092471 ] Xingxing Di edited comment on FLINK-16478 at 4/26/20, 4:13 AM: ---

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

2020-04-25 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092471#comment-17092471 ] Xingxing Di commented on FLINK-16478: - Hi [~xiaodao] , [~felixzheng], i am glad to s

[jira] [Closed] (FLINK-17382) Flink should support dynamic log level setting

2020-04-25 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di closed FLINK-17382. --- Resolution: Duplicate > Flink should support dynamic log level setting > ---

[jira] [Commented] (FLINK-17382) Flink should support dynamic log level setting

2020-04-25 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092456#comment-17092456 ] Xingxing Di commented on FLINK-17382: - [~felixzheng] thank you, it is duplicated. >

[jira] [Created] (FLINK-17382) Flink should support dynamic log level setting

2020-04-25 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-17382: --- Summary: Flink should support dynamic log level setting Key: FLINK-17382 URL: https://issues.apache.org/jira/browse/FLINK-17382 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-04-18 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di closed FLINK-16819. --- Resolution: Fixed the problem resolved by upgrading to 1.9.2 > Got KryoException while using UDAF i

[jira] [Updated] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-04-18 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-16819: Fix Version/s: 1.9.2 > Got KryoException while using UDAF in flink1.9 > --

[jira] [Commented] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-04-18 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086465#comment-17086465 ] Xingxing Di commented on FLINK-16819: - Hi [~jark] , the problem has been resolved by

[jira] [Commented] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results

2020-04-18 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086464#comment-17086464 ] Xingxing Di commented on FLINK-17228: - [~jark], Thanks a lot  > Streaming sql with

[jira] [Updated] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results

2020-04-17 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-17228: Description: We are facing an special scenario, *we want to know if this feature is supported*:

[jira] [Created] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results

2020-04-17 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-17228: --- Summary: Streaming sql with nested GROUP BY got wrong results Key: FLINK-17228 URL: https://issues.apache.org/jira/browse/FLINK-17228 Project: Flink Issue Type

[jira] [Updated] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-03-26 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-16819: Description: Recently,  we are trying to upgrade online *sql jobs* from flink1.7 to flink1.9 , mo

[jira] [Updated] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-03-26 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-16819: Description: Recently,  we are trying to upgrade online *sql jobs* from flink1.7 to flink1.9 , mo

[jira] [Created] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-03-26 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-16819: --- Summary: Got KryoException while using UDAF in flink1.9 Key: FLINK-16819 URL: https://issues.apache.org/jira/browse/FLINK-16819 Project: Flink Issue Type: Bug