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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27305. -- Resolution: Duplicate > Hive Dialect support implicit conversion >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27378. -- Resolution: Duplicate > Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27379. -- Resolution: Duplicate > CodeGenException: Unable to find common type of >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27380. -- Resolution: Duplicate > Failed to get Hive result type from >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia closed FLINK-27385. Resolution: Duplicate > Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552010#comment-17552010 ] luoyuxia commented on FLINK-27304: -- [~godfreyhe] yes > Flink doesn't support Hive primitive type void

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

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551950#comment-17551950 ] luoyuxia commented on FLINK-27387: -- [~godfreyhe] Yes. > Support Insert Multi-Table >

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

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551936#comment-17551936 ] luoyuxia commented on FLINK-27378: -- [~jark] Yes. > Unexpected rexnode :

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

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551935#comment-17551935 ] luoyuxia commented on FLINK-27296: -- [~jark] Yes. > CalcOperator CodeGenException: Boolean expression

[jira] [Commented] (FLINK-27950) flink streaming writes to the hive table, the set file suffix parameter is invalid

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551932#comment-17551932 ] luoyuxia commented on FLINK-27950: -- [~SOD_DOB] Thanks for your information. Maybe I miss some thing

[jira] [Commented] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551924#comment-17551924 ] luoyuxia commented on FLINK-26764: -- When I try to support it, I meet some problem. Currently, in Flink,

[jira] [Updated] (FLINK-26365) improve hive udaf

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26365: - Description: Currently we can't get call Hive UDAF that requires constant arguments like FLINK-16568

[jira] [Commented] (FLINK-27950) flink streaming writes to the hive table, the set file suffix parameter is invalid

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551618#comment-17551618 ] luoyuxia commented on FLINK-27950: -- [~SOD_DOB] Thanks for reporting it. You can set the following

[jira] [Comment Edited] (FLINK-27950) flink streaming writes to the hive table, the set file suffix parameter is invalid

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551618#comment-17551618 ] luoyuxia edited comment on FLINK-27950 at 6/8/22 1:09 PM: -- [~SOD_DOB] Thanks

[jira] (FLINK-27950) flink streaming writes to the hive table, the set file suffix parameter is invalid

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27950 ] luoyuxia deleted comment on FLINK-27950: -- was (Author: luoyuxia): [~SOD_DOB] Thanks for reporting. The property 'hive.output.file.extension' won't be conserderd by Flink. So it make no

[jira] [Commented] (FLINK-27950) flink streaming writes to the hive table, the set file suffix parameter is invalid

2022-06-08 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551611#comment-17551611 ] luoyuxia commented on FLINK-27950: -- [~SOD_DOB] Thanks for reporting. The property

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550963#comment-17550963 ] luoyuxia commented on FLINK-27898: -- [~zoucao] From my side, it does a problem. And I'm afriad of

[jira] [Commented] (FLINK-25727) Flink SQL convert constant string to char type which cause hive udtf json_tuple not work

2022-06-05 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550277#comment-17550277 ] luoyuxia commented on FLINK-25727: -- [~syntomic] This problem should be fixed in FLINK-15854. I think

[jira] [Commented] (FLINK-26355) VarCharType was not be considered in HiveTableSqlFunction

2022-06-05 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550276#comment-17550276 ] luoyuxia commented on FLINK-26355: -- [~zoucao] This issue should be fixed. I think you can close it now~ 

[jira] [Resolved] (FLINK-26364) Improve hive udtf

2022-06-05 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26364. -- Fix Version/s: 1.16.0 Resolution: Fixed > Improve hive udtf > - > >

[jira] [Commented] (FLINK-26364) Improve hive udtf

2022-06-05 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550275#comment-17550275 ] luoyuxia commented on FLINK-26364: -- Duplicated to

[jira] [Updated] (FLINK-27895) Enable the CI test for Hive's 3.x

2022-06-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27895: - Component/s: Build System / CI > Enable the CI test for Hive's 3.x >

[jira] [Commented] (FLINK-27895) Enable the CI test for Hive's 3.x

2022-06-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17547906#comment-17547906 ] luoyuxia commented on FLINK-27895: -- [~jark] Yes, it'll be my first priority. > Enable the CI test for

[jira] [Commented] (FLINK-27894) Build flink-connector-hive failed using Maven@3.8.5

2022-06-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17547812#comment-17547812 ] luoyuxia commented on FLINK-27894: -- Simliar issue to

[jira] [Created] (FLINK-27895) Enable the CI test for Hive's 3.x

2022-06-03 Thread luoyuxia (Jira)
luoyuxia created FLINK-27895: Summary: Enable the CI test for Hive's 3.x Key: FLINK-27895 URL: https://issues.apache.org/jira/browse/FLINK-27895 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-27859) Hive dialect should support create table whose name begins with digits

2022-05-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27859: - Summary: Hive dialect should support create table whose name begins with digits (was: Hive dialect

[jira] [Created] (FLINK-27859) Hive dialect should support create table that begins with digits

2022-05-31 Thread luoyuxia (Jira)
luoyuxia created FLINK-27859: Summary: Hive dialect should support create table that begins with digits Key: FLINK-27859 URL: https://issues.apache.org/jira/browse/FLINK-27859 Project: Flink

[jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format

2022-05-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27858: - Description: Can move on after finish [FLINK-16952|https://issues.apache.org/jira/browse/FLINK-16952]

[jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format

2022-05-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27858: - Description: Can move on after finish FLINK-17778   was: Can move on after finish FLINK-17778 | |  

[jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format

2022-05-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27858: - Fix Version/s: 1.16.0 > Hive source support filter push down for parquet format >

[jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format

2022-05-31 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27858: - Description: Can move on after finish FLINK-17778 | |   > Hive source support filter push down for

[jira] [Created] (FLINK-27858) Hive source support filter push down for parquet format

2022-05-31 Thread luoyuxia (Jira)
luoyuxia created FLINK-27858: Summary: Hive source support filter push down for parquet format Key: FLINK-27858 URL: https://issues.apache.org/jira/browse/FLINK-27858 Project: Flink Issue Type:

[jira] [Created] (FLINK-27857) Hive source support filter push down for orc format

2022-05-31 Thread luoyuxia (Jira)
luoyuxia created FLINK-27857: Summary: Hive source support filter push down for orc format Key: FLINK-27857 URL: https://issues.apache.org/jira/browse/FLINK-27857 Project: Flink Issue Type:

[jira] [Created] (FLINK-27850) Hive dialect supports "add file xxx"

2022-05-31 Thread luoyuxia (Jira)
luoyuxia created FLINK-27850: Summary: Hive dialect supports "add file xxx" Key: FLINK-27850 URL: https://issues.apache.org/jira/browse/FLINK-27850 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27801) Disable flushing stream when call Jackson's writeValue() method for CsvBulkWriter

2022-05-26 Thread luoyuxia (Jira)
luoyuxia created FLINK-27801: Summary: Disable flushing stream when call Jackson's writeValue() method for CsvBulkWriter Key: FLINK-27801 URL: https://issues.apache.org/jira/browse/FLINK-27801 Project:

[jira] [Commented] (FLINK-27219) CliClientITCase.testSqlStatements failed on azure with jdk11

2022-05-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541381#comment-17541381 ] luoyuxia commented on FLINK-27219: -- The backport for release-1.15 is in

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

2022-05-20 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 5/20/22 10:46 AM: [~tartarus]

[jira] [Created] (FLINK-27718) Hive dialect supports to count mutiple fields

2022-05-20 Thread luoyuxia (Jira)
luoyuxia created FLINK-27718: Summary: Hive dialect supports to count mutiple fields Key: FLINK-27718 URL: https://issues.apache.org/jira/browse/FLINK-27718 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27006) Support SingleValueAggFunction for Char data type

2022-05-20 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27006: - Component/s: Table SQL / API > Support SingleValueAggFunction for Char data type >

[jira] [Created] (FLINK-27620) Support percent_rank

2022-05-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-27620: Summary: Support percent_rank Key: FLINK-27620 URL: https://issues.apache.org/jira/browse/FLINK-27620 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-27619) Support NTIE

2022-05-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-27619: Summary: Support NTIE Key: FLINK-27619 URL: https://issues.apache.org/jira/browse/FLINK-27619 Project: Flink Issue Type: Sub-task Reporter: luoyuxia

[jira] [Created] (FLINK-27618) Suuport CumeDist

2022-05-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-27618: Summary: Suuport CumeDist Key: FLINK-27618 URL: https://issues.apache.org/jira/browse/FLINK-27618 Project: Flink Issue Type: Sub-task Reporter: luoyuxia

[jira] [Created] (FLINK-27617) Add more analysis functions for Flink batch

2022-05-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-27617: Summary: Add more analysis functions for Flink batch Key: FLINK-27617 URL: https://issues.apache.org/jira/browse/FLINK-27617 Project: Flink Issue Type: Improvement

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

2022-05-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Description: In Hive, by "reload function", the user can use the function defined in other session.

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

2022-05-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Description: In Hive, by "reload function", the user can use the function defined in other session.

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

2022-05-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Description: In Hive, by  > Hive dialect supports "reload function" >

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

2022-05-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Summary: Hive dialect supports "reload function" (was: Hive dialect support "reload function") > Hive

[jira] [Updated] (FLINK-27603) Hive dialect support "reload function"

2022-05-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Component/s: Connectors / Hive > Hive dialect support "reload function" >

[jira] [Updated] (FLINK-27603) Hive dialect support "reload function"

2022-05-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Fix Version/s: 1.16.0 > Hive dialect support "reload function" > --

[jira] [Created] (FLINK-27603) Hive dialect support "reload function"

2022-05-13 Thread luoyuxia (Jira)
luoyuxia created FLINK-27603: Summary: Hive dialect support "reload function" Key: FLINK-27603 URL: https://issues.apache.org/jira/browse/FLINK-27603 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27597) Get statistic for Hive paritioned table

2022-05-12 Thread luoyuxia (Jira)
luoyuxia created FLINK-27597: Summary: Get statistic for Hive paritioned table Key: FLINK-27597 URL: https://issues.apache.org/jira/browse/FLINK-27597 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27338) Improve spliting file for Hive soure

2022-05-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27338: - Parent: FLINK-27596 Issue Type: Sub-task (was: Improvement) > Improve spliting file for Hive

[jira] [Created] (FLINK-27596) [Umbrella] Optimize Hive source

2022-05-12 Thread luoyuxia (Jira)
luoyuxia created FLINK-27596: Summary: [Umbrella] Optimize Hive source Key: FLINK-27596 URL: https://issues.apache.org/jira/browse/FLINK-27596 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-05-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27191: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support multi kerberos-enabled Hive

[jira] [Updated] (FLINK-27525) Add a demo for using kafka sink via Flink SQL

2022-05-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27525: - Component/s: Connectors / Kafka Documentation > Add a demo for using kafka sink via

[jira] [Created] (FLINK-27525) Add a demo for using kafka sink via Flink SQL

2022-05-06 Thread luoyuxia (Jira)
luoyuxia created FLINK-27525: Summary: Add a demo for using kafka sink via Flink SQL Key: FLINK-27525 URL: https://issues.apache.org/jira/browse/FLINK-27525 Project: Flink Issue Type:

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

2022-05-04 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531995#comment-17531995 ] luoyuxia commented on FLINK-27386: -- To fix it is quite simple and I have submited a pr. But I would

[jira] (FLINK-15526) Add RollingPolicy to PartitionWriters

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15526 ] luoyuxia deleted comment on FLINK-15526: -- was (Author: luoyuxia): [~lzljs3620320] If there is no any other user is working it, I would like to take it.  > Add RollingPolicy to

[jira] (FLINK-15526) Add RollingPolicy to PartitionWriters

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15526 ] luoyuxia deleted comment on FLINK-15526: -- was (Author: luoyuxia): [~lzljs3620320] I see DefaultRollingPolicy.shouldRollOnEvent can already avoid writing a big file by file size. Does the Jira

[jira] (FLINK-18346) Support partition pruning for lookup table source

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18346 ] luoyuxia deleted comment on FLINK-18346: -- was (Author: luoyuxia): [~lzljs3620320] If there is no any other user is working it, I would like to take it.  A pr will come soon. > Support

[jira] [Commented] (FLINK-18346) Support partition pruning for lookup table source

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530282#comment-17530282 ] luoyuxia commented on FLINK-18346: -- [~lzljs3620320] If there is no any other user is working it, I

[jira] [Commented] (FLINK-15526) Add RollingPolicy to PartitionWriters

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530281#comment-17530281 ] luoyuxia commented on FLINK-15526: -- [~lzljs3620320] If there is no any other user is working it, I

[jira] [Commented] (FLINK-16904) Migrate FileSystem descriptor to new table factory

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530279#comment-17530279 ] luoyuxia commented on FLINK-16904: -- [~lzljs3620320] If there is no any other user is working it, I

[jira] [Commented] (FLINK-17398) Filesystem support flexible path reading

2022-04-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530278#comment-17530278 ] luoyuxia commented on FLINK-17398: -- [~lzljs3620320] If no any other is working it, I would like to take

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

2022-04-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529739#comment-17529739 ] luoyuxia commented on FLINK-27391: -- [~tartarus] Sorry for missing the feature of reading bucket table. 

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-27 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529156#comment-17529156 ] luoyuxia edited comment on FLINK-27191 at 4/28/22 2:27 AM: --- [~straw] Very

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-27 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529156#comment-17529156 ] luoyuxia commented on FLINK-27191: -- [~straw] Very sorry for late repsonse for I'am busy with some other

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-27 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529156#comment-17529156 ] luoyuxia edited comment on FLINK-27191 at 4/28/22 2:26 AM: --- [~straw] Very

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

2022-04-27 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528605#comment-17528605 ] luoyuxia commented on FLINK-27391: -- [~tartarus] Thanks for reporting it. There's also a similar Jira

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528476#comment-17528476 ] luoyuxia commented on FLINK-27387: -- [~tartarus] Thanks for reporting it. I would like to take it. >

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27387 ] luoyuxia deleted comment on FLINK-27387: -- was (Author: luoyuxia): [~tartarus] Thanks for reporting it. I would like to take this ticket. > Support Insert Multi-Table >

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528075#comment-17528075 ] luoyuxia commented on FLINK-27387: -- [~tartarus] Thanks for reporting it. I would like to take this

[jira] [Commented] (FLINK-27338) Improve spliting file for Hive soure

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528026#comment-17528026 ] luoyuxia commented on FLINK-27338: -- [~martijnvisser] Yes. > Improve spliting file for Hive soure >

[jira] [Commented] (FLINK-27407) Exception of "unable to find common type of Boolean and Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)"

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528019#comment-17528019 ] luoyuxia commented on FLINK-27407: -- [~libenchao] Appreciated to your information. > Exception of

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527986#comment-17527986 ] luoyuxia commented on FLINK-27386: -- [~tartarus] Thanks for reporting it. But what's the Flink version

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527148#comment-17527148 ] luoyuxia edited comment on FLINK-27304 at 4/26/22 6:33 AM: --- [~tartarus] Thanks

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527922#comment-17527922 ] luoyuxia commented on FLINK-27379: -- More detail analysis is in

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527920#comment-17527920 ] luoyuxia edited comment on FLINK-27296 at 4/26/22 6:29 AM: --- More detail

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527920#comment-17527920 ] luoyuxia edited comment on FLINK-27296 at 4/26/22 6:29 AM: --- More detail

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

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527920#comment-17527920 ] luoyuxia commented on FLINK-27296: -- More detail analysis is in

[jira] [Commented] (FLINK-27402) Unexpected boolean expression simplification for AND expression

2022-04-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527917#comment-17527917 ] luoyuxia commented on FLINK-27402: -- Updating: from my sides, it may not a problem for it's not allowed

[jira] [Commented] (FLINK-27407) Exception of "unable to find common type of Boolean and Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)"

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527884#comment-17527884 ] luoyuxia commented on FLINK-27407: -- [~godfreyhe] Could you please help have a look? Is it a problem?

[jira] [Updated] (FLINK-27407) Exception of "unable to find common type of Boolean and Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)"

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27407: - Description: For Flink SQL, the following sql can be excuted: {code:java} create table t1 (id bigint,

[jira] [Created] (FLINK-27407) Exception of "unable to find common type of Boolean and Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)"

2022-04-25 Thread luoyuxia (Jira)
luoyuxia created FLINK-27407: Summary: Exception of "unable to find common type of Boolean and Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)" Key: FLINK-27407 URL:

[jira] [Commented] (FLINK-27402) Unexpected boolean expression simplification for AND expression

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527855#comment-17527855 ] luoyuxia commented on FLINK-27402: -- We also encounter the some problem when working with Hive dialect

[jira] [Created] (FLINK-27402) Unexpected boolean expression simplification for AND expression

2022-04-25 Thread luoyuxia (Jira)
luoyuxia created FLINK-27402: Summary: Unexpected boolean expression simplification for AND expression Key: FLINK-27402 URL: https://issues.apache.org/jira/browse/FLINK-27402 Project: Flink

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527483#comment-17527483 ] luoyuxia commented on FLINK-27296: -- After some debug, the root case is "a['liveStream_isFemale'] =

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527482#comment-17527482 ] luoyuxia commented on FLINK-27379: -- [~tartarus] Thanks for reporting it. Similar issue to Flink-26771.

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527446#comment-17527446 ] luoyuxia commented on FLINK-27296: -- [~tartarus] Thanks for reporting it. Similar issue to

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527408#comment-17527408 ] luoyuxia edited comment on FLINK-27380 at 4/25/22 10:35 AM: [~tartarus]

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527408#comment-17527408 ] luoyuxia edited comment on FLINK-27380 at 4/25/22 10:33 AM: [~tartarus]

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527408#comment-17527408 ] luoyuxia commented on FLINK-27380: -- [~tartarus] Thanks for reporting it. Similar issue to

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527404#comment-17527404 ] luoyuxia edited comment on FLINK-27385 at 4/25/22 10:23 AM: [~tartarus]

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527405#comment-17527405 ] luoyuxia commented on FLINK-27378: -- [~tartarus] Thanks for reportiing it. I also noticed such case and

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

2022-04-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527404#comment-17527404 ] luoyuxia commented on FLINK-27385: -- [~tartarus] Thanks for reportiing it. I also noticed such case and

[jira] [Created] (FLINK-27376) Hive dialect supports "select current_database()"

2022-04-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-27376: Summary: Hive dialect supports "select current_database()" Key: FLINK-27376 URL: https://issues.apache.org/jira/browse/FLINK-27376 Project: Flink Issue Type:

[jira] [Created] (FLINK-27375) Hive dialect support "over() without order keys inside"

2022-04-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-27375: Summary: Hive dialect support "over() without order keys inside" Key: FLINK-27375 URL: https://issues.apache.org/jira/browse/FLINK-27375 Project: Flink Issue Type:

[jira] [Updated] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27374: - Parent: FLINK-26360 Issue Type: Sub-task (was: Improvement) > Convert Hive's void type to

[jira] [Updated] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-04-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27374: - Component/s: Connectors / Hive > Convert Hive's void type to Flink's string type >

[jira] [Created] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-04-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-27374: Summary: Convert Hive's void type to Flink's string type Key: FLINK-27374 URL: https://issues.apache.org/jira/browse/FLINK-27374 Project: Flink Issue Type:

<    5   6   7   8   9   10   11   12   13   14   >