[jira] [Commented] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459902#comment-17459902 ] xiangqiao commented on FLINK-24892: --- [~wanglijie95]  Thank you. This work is very meaningful to us.

[jira] [Updated] (FLINK-25142) The user-defined hive udtf initialize exception in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-25142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-25142: -- Issue Type: Improvement (was: Bug) > The user-defined hive udtf initialize exception in hive dialect

[jira] [Updated] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-24862: -- Description: When hive udaf/udtf is used, a validate exception is thrown ，i added a unit test in

[jira] [Updated] (FLINK-25142) The user-defined hive udtf initialize exception in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-25142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-25142: -- Description: I met the problem and added a unit test in HiveDialectITCase to reproduce this

[jira] [Updated] (FLINK-25142) The user-defined hive udtf initialize exception in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-25142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-25142: -- Attachment: image-2021-12-02-16-14-31-441.png > The user-defined hive udtf initialize exception in

[jira] [Created] (FLINK-25142) The user-defined hive udtf initialize exception in hive dialect

xiangqiao created FLINK-25142: - Summary: The user-defined hive udtf initialize exception in hive dialect Key: FLINK-25142 URL: https://issues.apache.org/jira/browse/FLINK-25142 Project: Flink

[jira] [Comment Edited] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452139#comment-17452139 ] xiangqiao edited comment on FLINK-25095 at 12/2/21, 2:43 AM: - [~luoyuxia]

[jira] [Commented] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452139#comment-17452139 ] xiangqiao commented on FLINK-25095: --- I verified that if default dialect is used, the execution can be

[jira] [Comment Edited] (FLINK-24953) Optime hive parallelism inference

[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451507#comment-17451507 ] xiangqiao edited comment on FLINK-24953 at 12/1/21, 5:21 AM: - sorry, this

[jira] [Closed] (FLINK-24953) Optime hive parallelism inference

[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao closed FLINK-24953. - Resolution: Duplicate > Optime hive parallelism inference > - > >

[jira] [Commented] (FLINK-24953) Optime hive parallelism inference

[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451507#comment-17451507 ] xiangqiao commented on FLINK-24953: --- sorry, this problem has been fixed in master branch. I will close

[jira] [Comment Edited] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451085#comment-17451085 ] xiangqiao edited comment on FLINK-25095 at 11/30/21, 11:59 AM: --- Thank you

[jira] [Commented] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451085#comment-17451085 ] xiangqiao commented on FLINK-25095: --- Thank you [~luoyuxia] . As can be seen from the code, the

[jira] [Updated] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-25095: -- Description: When we {*}use blink planner{*}'s *batch mode* and set {*}hive dialect{*}. This

[jira] [Created] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

xiangqiao created FLINK-25095: - Summary: org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'. Key: FLINK-25095

[jira] [Commented] (FLINK-25012) Cannot join hive tables with different column types

[ https://issues.apache.org/jira/browse/FLINK-25012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448402#comment-17448402 ] xiangqiao commented on FLINK-25012: --- Thank you [~luoyuxia] , i have added

[jira] [Updated] (FLINK-25012) Cannot join hive tables with different column types

[ https://issues.apache.org/jira/browse/FLINK-25012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-25012: -- Description: When using the flick batch mode and join hive table, we will get the following

[jira] [Created] (FLINK-25012) Cannot join hive tables with different column types

xiangqiao created FLINK-25012: - Summary: Cannot join hive tables with different column types Key: FLINK-25012 URL: https://issues.apache.org/jira/browse/FLINK-25012 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24953) Optime hive parallelism inference

[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445837#comment-17445837 ] xiangqiao commented on FLINK-24953: --- hi [~ruili] [~lzljs3620320] , can you help me review this pr?

[jira] [Created] (FLINK-24953) Optime hive parallelism inference

xiangqiao created FLINK-24953: - Summary: Optime hive parallelism inference Key: FLINK-24953 URL: https://issues.apache.org/jira/browse/FLINK-24953 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24922) Fix spelling errors in the word "parallism"

xiangqiao created FLINK-24922: - Summary: Fix spelling errors in the word "parallism" Key: FLINK-24922 URL: https://issues.apache.org/jira/browse/FLINK-24922 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442054#comment-17442054 ] xiangqiao commented on FLINK-24862: --- Thank you [~jark] ,remove the "temporary" keyword is to create a

[jira] [Updated] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-24862: -- Description: Here are two questions： 1.First question, I added a unit test in HiveDialectITCase to

[jira] [Updated] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-24862: -- Attachment: image-2021-11-10-21-04-32-660.png > The user-defined hive udaf/udtf cannot be used

[jira] [Updated] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-24862: -- Description: Here are two questions： 1.First question, I added a unit test in HiveDialectITCase to

[jira] [Created] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

xiangqiao created FLINK-24862: - Summary: The user-defined hive udaf/udtf cannot be used normally in hive dialect Key: FLINK-24862 URL: https://issues.apache.org/jira/browse/FLINK-24862 Project: Flink

[jira] [Commented] (FLINK-24510) Fix the duplicate log output of libraries/connectors，when logback is used

[ https://issues.apache.org/jira/browse/FLINK-24510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427428#comment-17427428 ] xiangqiao commented on FLINK-24510: --- I have contributed PR, who can help assign the ticket to me?

[jira] [Commented] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

[ https://issues.apache.org/jira/browse/FLINK-24479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427427#comment-17427427 ] xiangqiao commented on FLINK-24479: --- I have contributed PR, who can help assign the ticket to me?

[jira] [Created] (FLINK-24510) Fix the duplicate log output of libraries/connectors，when logback is used

xiangqiao created FLINK-24510: - Summary: Fix the duplicate log output of libraries/connectors，when logback is used Key: FLINK-24510 URL: https://issues.apache.org/jira/browse/FLINK-24510 Project: Flink

[jira] [Updated] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

[ https://issues.apache.org/jira/browse/FLINK-24479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-24479: -- Description: RocksIteratorWrapper#seekToLast method, calling RocksIterator#seekToFirst method

[jira] [Created] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

xiangqiao created FLINK-24479: - Summary: Bug fix RocksIteratorWrapper#seekToLast method Key: FLINK-24479 URL: https://issues.apache.org/jira/browse/FLINK-24479 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404312#comment-17404312 ] xiangqiao edited comment on FLINK-23886 at 8/25/21, 9:37 AM: - Hello [~yunta] 

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404312#comment-17404312 ] xiangqiao edited comment on FLINK-23886 at 8/25/21, 9:34 AM: - Hello [~yunta] 

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404312#comment-17404312 ] xiangqiao commented on FLINK-23886: --- We download the  rocksdb data file of the failed subtask task

[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-23886: -- Attachment: image-2021-08-25-17-07-38-327.png > An exception is thrown out when recover job timers

[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-23886: -- Attachment: image-2021-08-25-17-06-29-806.png > An exception is thrown out when recover job timers

[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-23886: -- Attachment: image-2021-08-25-16-38-12-308.png > An exception is thrown out when recover job timers

[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-23886: -- Attachment: image-2021-08-25-16-38-04-023.png > An exception is thrown out when recover job timers

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403682#comment-17403682 ] xiangqiao edited comment on FLINK-23886 at 8/24/21, 9:29 AM: -  thank you

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403682#comment-17403682 ] xiangqiao edited comment on FLINK-23886 at 8/24/21, 9:02 AM: -  thank you

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403682#comment-17403682 ] xiangqiao commented on FLINK-23886: ---  thank you [~yunta] Add the common characteristics of

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403501#comment-17403501 ] xiangqiao commented on FLINK-23886: --- RocksDBCachingPriorityQueueSet#deserializeElement method will