[jira] [Commented] (FLINK-33050) Prompts user to close when atomicity implementation is not supported

2023-09-19 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766757#comment-17766757 ] tartarus commented on FLINK-33050: -- See https://issues.apache.org/jira/browse/FLINK-32787 for details 

[jira] [Comment Edited] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-09-06 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762380#comment-17762380 ] tartarus edited comment on FLINK-32787 at 9/6/23 1:10 PM: -- [~hackergin]  thanks

[jira] [Commented] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-09-06 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762380#comment-17762380 ] tartarus commented on FLINK-32787: -- [~hackergin]  thanks for verifying~ I think there are two issues

[jira] [Created] (FLINK-33050) Prompts user to close when atomicity implementation is not supported

2023-09-06 Thread tartarus (Jira)
tartarus created FLINK-33050: Summary: Prompts user to close when atomicity implementation is not supported Key: FLINK-33050 URL: https://issues.apache.org/jira/browse/FLINK-33050 Project: Flink

[jira] [Comment Edited] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755822#comment-17755822 ] tartarus edited comment on FLINK-32791 at 8/18/23 7:00 AM: --- Verified the Time

[jira] [Commented] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755822#comment-17755822 ] tartarus commented on FLINK-32791: -- Verified the RTAS with paimon catalog; Write the data with the

[jira] [Updated] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32791: - Attachment: image-2023-08-18-14-56-19-198.png > Release Testing: Verify FLIP-308: Support Time Travel >

[jira] [Updated] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32791: - Attachment: image-2023-08-18-14-55-18-883.png > Release Testing: Verify FLIP-308: Support Time Travel >

[jira] [Updated] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

2023-08-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32791: - Attachment: image-2023-08-18-14-55-55-817.png > Release Testing: Verify FLIP-308: Support Time Travel >

[jira] [Created] (FLINK-32581) Add document for atomic CTAS

2023-07-11 Thread tartarus (Jira)
tartarus created FLINK-32581: Summary: Add document for atomic CTAS Key: FLINK-32581 URL: https://issues.apache.org/jira/browse/FLINK-32581 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-32349) Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-07-11 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-32349: - Parent: FLINK-32580 Issue Type: Sub-task (was: New Feature) > Support atomic for CREATE TABLE

[jira] [Created] (FLINK-32580) FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS)

2023-07-11 Thread tartarus (Jira)
tartarus created FLINK-32580: Summary: FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) Key: FLINK-32580 URL: https://issues.apache.org/jira/browse/FLINK-32580 Project: Flink Issue

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-06-29 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738555#comment-17738555 ] tartarus commented on FLINK-31655: -- Hi [~pnowojski]  thank you for your reply. I currently tend to use

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-06-29 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738549#comment-17738549 ] tartarus commented on FLINK-31655: -- Hi [~wangm92]  Thank you for sharing, your solution sounds similar

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-06-29 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738546#comment-17738546 ] tartarus commented on FLINK-31655: -- hi [~fanrui]  thank you for your reply, I will answer your concerns

[jira] [Comment Edited] (FLINK-31655) Adaptive Channel selection for partitioner

2023-06-16 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733425#comment-17733425 ] tartarus edited comment on FLINK-31655 at 6/16/23 9:37 AM: --- [~fanrui]  Thank

[jira] [Comment Edited] (FLINK-31655) Adaptive Channel selection for partitioner

2023-06-16 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733425#comment-17733425 ] tartarus edited comment on FLINK-31655 at 6/16/23 9:36 AM: --- [~fanrui]  Thank

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-06-16 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733425#comment-17733425 ] tartarus commented on FLINK-31655: -- [~fanrui]  Thank you very much for sharing your solution! 

[jira] [Commented] (FLINK-28460) Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS)

2023-06-15 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732998#comment-17732998 ] tartarus commented on FLINK-28460: -- Resolved in FLIP-305, for details see

[jira] [Created] (FLINK-32349) Support atomic for CREATE TABLE AS SELECT(CTAS) statement

2023-06-15 Thread tartarus (Jira)
tartarus created FLINK-32349: Summary: Support atomic for CREATE TABLE AS SELECT(CTAS) statement Key: FLINK-32349 URL: https://issues.apache.org/jira/browse/FLINK-32349 Project: Flink Issue

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-04-13 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712168#comment-17712168 ] tartarus commented on FLINK-31655: -- [~akalash] [~pnowojski] [~pltbkd] Thank you very much for your

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-04-12 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711663#comment-17711663 ] tartarus commented on FLINK-31655: -- Hi [~akalash]  thanks for your reminder! In our company, adaptive

[jira] [Created] (FLINK-31721) Move JobStatusHook to flink-core module

2023-04-04 Thread tartarus (Jira)
tartarus created FLINK-31721: Summary: Move JobStatusHook to flink-core module Key: FLINK-31721 URL: https://issues.apache.org/jira/browse/FLINK-31721 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-03-31 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707138#comment-17707138 ] tartarus commented on FLINK-31655: -- Hi [~gaoyunhaii] [~fanrui]  Thanks for your suggestions, I will

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-03-29 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706287#comment-17706287 ] tartarus commented on FLINK-31655: -- cc [~zhuzh]  > Adaptive Channel selection for partitioner >

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

2023-03-29 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706281#comment-17706281 ] tartarus commented on FLINK-31655: -- [~gaoyunhaii]  [~fanrui]  Please take a look at this issue, after

[jira] [Created] (FLINK-31655) Adaptive Channel selection for partitioner

2023-03-29 Thread tartarus (Jira)
tartarus created FLINK-31655: Summary: Adaptive Channel selection for partitioner Key: FLINK-31655 URL: https://issues.apache.org/jira/browse/FLINK-31655 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-30640) Unstable test in CliClientITCase

2023-01-13 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676509#comment-17676509 ] tartarus commented on FLINK-30640: -- It looks like ctas didn't execute successfully. Will retrying with

[jira] [Commented] (FLINK-29219) CREATE TABLE AS statement blocks SQL client's execution

2022-09-15 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605152#comment-17605152 ] tartarus commented on FLINK-29219: -- [~renqs]  This problem has been located because sql-client does not

[jira] [Comment Edited] (FLINK-29219) CREATE TABLE AS statement blocks SQL client's execution

2022-09-08 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601658#comment-17601658 ] tartarus edited comment on FLINK-29219 at 9/8/22 6:21 AM: -- [~renqs]  Thank you

[jira] [Commented] (FLINK-29219) CREATE TABLE AS statement blocks SQL client's execution

2022-09-08 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601658#comment-17601658 ] tartarus commented on FLINK-29219: -- [~renqs]  Thank you very much for your feedback on this issue! I

[jira] [Commented] (FLINK-28965) Should create empty partition when it's for dynamic partition

2022-08-15 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579809#comment-17579809 ] tartarus commented on FLINK-28965: -- [~luoyuxia]   thank for you raise this issue, I will fix it soon!

[jira] [Created] (FLINK-28770) CREATE TABLE AS SELECT supports explain

2022-08-01 Thread tartarus (Jira)
tartarus created FLINK-28770: Summary: CREATE TABLE AS SELECT supports explain Key: FLINK-28770 URL: https://issues.apache.org/jira/browse/FLINK-28770 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28720) Add Hive partition when flink has no data to write

2022-07-27 Thread tartarus (Jira)
tartarus created FLINK-28720: Summary: Add Hive partition when flink has no data to write Key: FLINK-28720 URL: https://issues.apache.org/jira/browse/FLINK-28720 Project: Flink Issue Type:

[jira] [Created] (FLINK-28463) Flink SQL syntax support CREATE TABLE AS SELECT(CTAS)

2022-07-08 Thread tartarus (Jira)
tartarus created FLINK-28463: Summary: Flink SQL syntax support CREATE TABLE AS SELECT(CTAS) Key: FLINK-28463 URL: https://issues.apache.org/jira/browse/FLINK-28463 Project: Flink Issue Type:

[jira] [Created] (FLINK-28462) Table API support CREATE TABLE AS SELECT(CTAS)

2022-07-08 Thread tartarus (Jira)
tartarus created FLINK-28462: Summary: Table API support CREATE TABLE AS SELECT(CTAS) Key: FLINK-28462 URL: https://issues.apache.org/jira/browse/FLINK-28462 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28460) Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS)

2022-07-08 Thread tartarus (Jira)
tartarus created FLINK-28460: Summary: Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS) Key: FLINK-28460 URL: https://issues.apache.org/jira/browse/FLINK-28460 Project: Flink Issue Type:

[jira] [Created] (FLINK-28459) Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS)

2022-07-08 Thread tartarus (Jira)
tartarus created FLINK-28459: Summary: Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS) Key: FLINK-28459 URL: https://issues.apache.org/jira/browse/FLINK-28459 Project: Flink Issue

[jira] [Created] (FLINK-28457) Flink add JobStatusHook support

2022-07-08 Thread tartarus (Jira)
tartarus created FLINK-28457: Summary: Flink add JobStatusHook support Key: FLINK-28457 URL: https://issues.apache.org/jira/browse/FLINK-28457 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

2022-07-08 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564156#comment-17564156 ] tartarus commented on FLINK-26942: -- [~waywtdcc]  Thanks for the suggestion about the [with [no] data]

[jira] [Created] (FLINK-28343) Hive dialect fails using union map type

2022-07-01 Thread tartarus (Jira)
tartarus created FLINK-28343: Summary: Hive dialect fails using union map type Key: FLINK-28343 URL: https://issues.apache.org/jira/browse/FLINK-28343 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28342) Flink batch support for Hive StorageHandlers

2022-07-01 Thread tartarus (Jira)
tartarus created FLINK-28342: Summary: Flink batch support for Hive StorageHandlers Key: FLINK-28342 URL: https://issues.apache.org/jira/browse/FLINK-28342 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28235) Min aggregate function support type: ''ARRAY''.

2022-06-23 Thread tartarus (Jira)
tartarus created FLINK-28235: Summary: Min aggregate function support type: ''ARRAY''. Key: FLINK-28235 URL: https://issues.apache.org/jira/browse/FLINK-28235 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28158) Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE)

2022-06-20 Thread tartarus (Jira)
tartarus created FLINK-28158: Summary: Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE) Key: FLINK-28158 URL: https://issues.apache.org/jira/browse/FLINK-28158 Project: Flink

[jira] [Commented] (FLINK-27603) Hive dialect supports "reload function"

2022-06-09 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552530#comment-17552530 ] tartarus commented on FLINK-27603: -- Thanks for your work! I think the reload function is the habit of

[jira] [Commented] (FLINK-27677) Kubernetes reuse rest.bind-port, but do not support a range of ports

2022-05-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539180#comment-17539180 ] tartarus commented on FLINK-27677: -- [~wangyang0918]  thank you for your reply! The scenarios of k8s

[jira] [Commented] (FLINK-27677) Kubernetes reuse rest.bind-port, but do not support a range of ports

2022-05-18 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538656#comment-17538656 ] tartarus commented on FLINK-27677: -- [~tison]  I think the behavior of this configuration on k8s and

[jira] [Created] (FLINK-27677) Kubernetes reuse rest.bind-port, but do not support a range of ports

2022-05-18 Thread tartarus (Jira)
tartarus created FLINK-27677: Summary: Kubernetes reuse rest.bind-port, but do not support a range of ports Key: FLINK-27677 URL: https://issues.apache.org/jira/browse/FLINK-27677 Project: Flink

[jira] [Updated] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

2022-05-05 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-27450: - Description: If we use jdk11 to run Hive related jobs, there will be a problem that the Hive

[jira] [Commented] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

2022-04-29 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529814#comment-17529814 ] tartarus commented on FLINK-27450: -- [~jark] please assign to me, I will create a pr to fix it. > [JDK

[jira] [Created] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

2022-04-29 Thread tartarus (Jira)
tartarus created FLINK-27450: Summary: [JDK 11] Hive SessionState can't be initialized due to classloader problem Key: FLINK-27450 URL: https://issues.apache.org/jira/browse/FLINK-27450 Project: Flink

[jira] [Commented] (FLINK-27379) CodeGenException: Unable to find common type of

2022-04-27 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528738#comment-17528738 ] tartarus commented on FLINK-27379: -- [~luoyuxia] thanks for your reply. you are so efficient! >

[jira] [Commented] (FLINK-27387) Support Insert Multi-Table

2022-04-27 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528737#comment-17528737 ] tartarus commented on FLINK-27387: -- [~luoyuxia] This is really good news, Looking forward to using it

[jira] [Commented] (FLINK-27391) Support Hive bucket table

2022-04-27 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528736#comment-17528736 ] tartarus commented on FLINK-27391: -- [~luoyuxia] thanks for your reply. I think we should support

[jira] [Commented] (FLINK-27386) throw NPE if multi MAPJOIN hint union all

2022-04-26 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528034#comment-17528034 ] tartarus commented on FLINK-27386: -- [~luoyuxia] thanks for your reply, idea will add jvm parameter

[jira] [Created] (FLINK-27391) Support Hive bucket table

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27391: Summary: Support Hive bucket table Key: FLINK-27391 URL: https://issues.apache.org/jira/browse/FLINK-27391 Project: Flink Issue Type: Sub-task Affects Versions:

[jira] [Created] (FLINK-27387) Support Insert Multi-Table

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27387: Summary: Support Insert Multi-Table Key: FLINK-27387 URL: https://issues.apache.org/jira/browse/FLINK-27387 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27386) throw NPE if multi MAPJOIN hint union all

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27386: Summary: throw NPE if multi MAPJOIN hint union all Key: FLINK-27386 URL: https://issues.apache.org/jira/browse/FLINK-27386 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27385) Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression index($0, 0)

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27385: Summary: Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression index($0, 0) Key: FLINK-27385 URL: https://issues.apache.org/jira/browse/FLINK-27385

[jira] [Created] (FLINK-27380) Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27380: Summary: Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox Key: FLINK-27380 URL: https://issues.apache.org/jira/browse/FLINK-27380

[jira] [Created] (FLINK-27379) CodeGenException: Unable to find common type of

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27379: Summary: CodeGenException: Unable to find common type of Key: FLINK-27379 URL: https://issues.apache.org/jira/browse/FLINK-27379 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27378) Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess

2022-04-25 Thread tartarus (Jira)
tartarus created FLINK-27378: Summary: Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess Key: FLINK-27378 URL: https://issues.apache.org/jira/browse/FLINK-27378 Project: Flink Issue

[jira] [Commented] (FLINK-27305) Hive Dialect support implicit conversion

2022-04-19 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524208#comment-17524208 ] tartarus commented on FLINK-27305: -- [~luoyuxia]  thanks for your remind. It seems that

[jira] [Created] (FLINK-27305) Hive Dialect support implicit conversion

2022-04-19 Thread tartarus (Jira)
tartarus created FLINK-27305: Summary: Hive Dialect support implicit conversion Key: FLINK-27305 URL: https://issues.apache.org/jira/browse/FLINK-27305 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-04-19 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524142#comment-17524142 ] tartarus commented on FLINK-27304: -- Looks like it is caused by the hive binary type,  sample array>

[jira] [Created] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-04-19 Thread tartarus (Jira)
tartarus created FLINK-27304: Summary: Flink doesn't support Hive primitive type void yet Key: FLINK-27304 URL: https://issues.apache.org/jira/browse/FLINK-27304 Project: Flink Issue Type:

[jira] [Created] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

2022-04-18 Thread tartarus (Jira)
tartarus created FLINK-27296: Summary: CalcOperator CodeGenException: Boolean expression type expected Key: FLINK-27296 URL: https://issues.apache.org/jira/browse/FLINK-27296 Project: Flink

[jira] [Created] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

2022-03-31 Thread tartarus (Jira)
tartarus created FLINK-26942: Summary: Support SELECT clause in CREATE TABLE(CTAS) Key: FLINK-26942 URL: https://issues.apache.org/jira/browse/FLINK-26942 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25605) Batch get statistics of multiple partitions instead of get one by one

2022-03-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513804#comment-17513804 ] tartarus commented on FLINK-25605: -- [~jingzhang]  Please assign this issue to me and I'll try to fix

[jira] [Updated] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

2022-03-03 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-26460: - Description: {code:java} CREATE TABLE zm_test ( `a` BIGINT, `m` MAP ); {code} if we insert into

[jira] [Commented] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

2022-03-03 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500583#comment-17500583 ] tartarus commented on FLINK-26460: -- [~jark]   please assign it to me, thanks > Fix Unsupported type

[jira] [Created] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

2022-03-03 Thread tartarus (Jira)
tartarus created FLINK-26460: Summary: Fix Unsupported type when convertTypeToSpec: MAP Key: FLINK-26460 URL: https://issues.apache.org/jira/browse/FLINK-26460 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25240) Update log4j2 version to 2.15.0

2021-12-10 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457101#comment-17457101 ] tartarus commented on FLINK-25240: -- 2.15.0 may not be the best choice, the community has released

[jira] [Commented] (FLINK-25258) Update log4j2 version to 2.15.0-rc2

2021-12-10 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457089#comment-17457089 ] tartarus commented on FLINK-25258: --

[jira] [Commented] (FLINK-25258) Update log4j2 version to 2.15.0-rc2

2021-12-10 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457082#comment-17457082 ] tartarus commented on FLINK-25258: -- [~jingzhang] Please assign this issue to me, thank you It is

[jira] [Commented] (FLINK-20416) Need a cached catalog for HiveCatalog

2021-12-08 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456122#comment-17456122 ] tartarus commented on FLINK-20416: -- [~shared_ptr] Excuse me, I found that this jira hasn't been updated

[jira] [Commented] (FLINK-25204) Spell one more as in the DataStream interval join docs

2021-12-06 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454424#comment-17454424 ] tartarus commented on FLINK-25204: -- [~jark] Please assign to me , thanks > Spell one more as in the

[jira] [Created] (FLINK-25204) Spell one more as in the DataStream interval join docs

2021-12-06 Thread tartarus (Jira)
tartarus created FLINK-25204: Summary: Spell one more as in the DataStream interval join docs Key: FLINK-25204 URL: https://issues.apache.org/jira/browse/FLINK-25204 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24761) Fix PartitionPruner code gen compile fail

2021-11-04 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-24761: - Description: {color:#4c9aff}PartitionPruner{color} compile code use

[jira] [Updated] (FLINK-24761) Fix PartitionPruner code gen compile fail

2021-11-04 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-24761: - Description: {color:#4c9aff}PartitionPruner{color} compile code use

[jira] [Commented] (FLINK-24761) Fix PartitionPruner code gen compile fail

2021-11-04 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438532#comment-17438532 ] tartarus commented on FLINK-24761: -- [~jark] Please assign this jira to me, thanks > Fix

[jira] [Created] (FLINK-24761) Fix PartitionPruner code gen compile fail

2021-11-04 Thread tartarus (Jira)
tartarus created FLINK-24761: Summary: Fix PartitionPruner code gen compile fail Key: FLINK-24761 URL: https://issues.apache.org/jira/browse/FLINK-24761 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-23715) Support for reading fields that do not exist in Parquet files

2021-08-10 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397050#comment-17397050 ] tartarus commented on FLINK-23715: -- [~ruili]  Please assign this issue to me, thanks > Support for

[jira] [Created] (FLINK-23715) Support for reading fields that do not exist in Parquet files

2021-08-10 Thread tartarus (Jira)
tartarus created FLINK-23715: Summary: Support for reading fields that do not exist in Parquet files Key: FLINK-23715 URL: https://issues.apache.org/jira/browse/FLINK-23715 Project: Flink Issue

[jira] [Updated] (FLINK-23531) Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-23531: - Summary: Allow skip all change log for row-time deduplicate mini-batch (was: Allow skip everytime

[jira] [Updated] (FLINK-23531) Allow skip all change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-23531: - Description: current we keep all change log for row-time deduplicate mini-batch, we need buffer all

[jira] [Commented] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389248#comment-17389248 ] tartarus commented on FLINK-23531: -- [~jark]  please assign to me, thanks > Allow skip everytime change

[jira] [Created] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch

2021-07-28 Thread tartarus (Jira)
tartarus created FLINK-23531: Summary: Allow skip everytime change log for row-time deduplicate mini-batch Key: FLINK-23531 URL: https://issues.apache.org/jira/browse/FLINK-23531 Project: Flink

[jira] [Created] (FLINK-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup

2021-07-19 Thread tartarus (Jira)
tartarus created FLINK-23425: Summary: The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup Key: FLINK-23425 URL:

[jira] [Commented] (FLINK-20518) WebUI should escape characters in metric names

2021-06-24 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368686#comment-17368686 ] tartarus commented on FLINK-20518: -- [~chesnay]  Do you think the parameters are decoded on the server

[jira] [Commented] (FLINK-23134) add URL decode for metric rest

2021-06-24 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368662#comment-17368662 ] tartarus commented on FLINK-23134: -- [~trohrmann]  Do you think this is ok? Please assign this issue to

[jira] [Created] (FLINK-23134) add URL decode for metric rest

2021-06-24 Thread tartarus (Jira)
tartarus created FLINK-23134: Summary: add URL decode for metric rest Key: FLINK-23134 URL: https://issues.apache.org/jira/browse/FLINK-23134 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-22716) Add metrics watermarkAlignedChannelNum

2021-05-19 Thread tartarus (Jira)
tartarus created FLINK-22716: Summary: Add metrics watermarkAlignedChannelNum Key: FLINK-22716 URL: https://issues.apache.org/jira/browse/FLINK-22716 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

2021-04-26 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332416#comment-17332416 ] tartarus commented on FLINK-22455: -- [~joemoe] I use 1.13.0 ,but I think this problem has existed for a

[jira] [Created] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

2021-04-25 Thread tartarus (Jira)
tartarus created FLINK-22455: Summary: FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse Key: FLINK-22455 URL: https://issues.apache.org/jira/browse/FLINK-22455 Project:

[jira] [Created] (FLINK-22412) SplitAggregateRule support optimization of aggregate function reuse

2021-04-22 Thread tartarus (Jira)
tartarus created FLINK-22412: Summary: SplitAggregateRule support optimization of aggregate function reuse Key: FLINK-22412 URL: https://issues.apache.org/jira/browse/FLINK-22412 Project: Flink

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-04-17 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Labels: pull-request-available (was: pull-request-available stale-assigned) > SplitAggregateRule will

[jira] [Commented] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-04-06 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315334#comment-17315334 ] tartarus commented on FLINK-21923: -- `LogicalTableAggregate` does not have a `PartialFinalType` member

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-03-23 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Description: SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to improve

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-03-23 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Description: SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to improve

  1   2   >