[jira] [Updated] (FLINK-26412) Hive dialect supports "CREATE FUNCTION USING xxx.jar"

2022-07-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26412: - Summary: Hive dialect supports "CREATE FUNCTION USING xxx.jar" (was: Hive dialect supports "CREATE

[jira] [Updated] (FLINK-26412) Hive dialect supports "CREATE FUNCTION USING xxx.jar"

2022-07-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26412: - Description: In Hive, it's supported to use such sql like {code:java} CREATE FUNCTION USING xxx.jar

[jira] [Commented] (FLINK-28525) HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError

2022-07-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566112#comment-17566112 ] luoyuxia commented on FLINK-28525: -- Thanks for reporting it. I'll fix it as soon as possible. The

[jira] [Updated] (FLINK-28471) Translate hive_read_write.md into Chinese

2022-07-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28471: - Component/s: Connectors / Hive > Translate hive_read_write.md into Chinese >

[jira] [Commented] (FLINK-28471) Translate hive_read_write.md into Chinese

2022-07-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564752#comment-17564752 ] luoyuxia commented on FLINK-28471: -- [~eyys] Thanks for your contribution. I'll find some time to help

[jira] [Comment Edited] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564051#comment-17564051 ] luoyuxia edited comment on FLINK-28451 at 7/8/22 2:28 AM: -- [~lsy] Thanks for

[jira] [Commented] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564051#comment-17564051 ] luoyuxia commented on FLINK-28451: -- [~lsy] Thanks for reporting it. I'll fix it. Previouly, I also have

[jira] [Updated] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28430: - Description: Now, HiveFunctionWrapper will use current thread's ClassLoader to load the Hive UDFs

[jira] [Updated] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28430: - Description: Now, HiveFunctionWrapper will use current thread's ClassLoader to load the Hive UDFs

[jira] [Updated] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28430: - Description: Now, HiveFunctionWrapper will use current thread's ClassLoader to load the Hive UDFs

[jira] [Updated] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28430: - Description: Now, Hive > HiveFunctionWrapper should use UserClassLoader to load class >

[jira] [Created] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
luoyuxia created FLINK-28430: Summary: HiveFunctionWrapper should use UserClassLoader to load class Key: FLINK-28430 URL: https://issues.apache.org/jira/browse/FLINK-28430 Project: Flink Issue

[jira] [Created] (FLINK-28422) Fall back to lastest supported HiveShim when user use a higher hive version

2022-07-06 Thread luoyuxia (Jira)
luoyuxia created FLINK-28422: Summary: Fall back to lastest supported HiveShim when user use a higher hive version Key: FLINK-28422 URL: https://issues.apache.org/jira/browse/FLINK-28422 Project: Flink

[jira] [Updated] (FLINK-23995) Hive dialect: `insert overwrite table partition if not exists` will throw exception when tablename is like 'database.table'

2022-07-04 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-23995: - Parent: FLINK-26360 Issue Type: Sub-task (was: Bug) > Hive dialect: `insert overwrite table

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

2022-07-01 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561331#comment-17561331 ] luoyuxia commented on FLINK-28343: -- [~tartarus] Thanks for reporting. Should be fixed after

[jira] [Updated] (FLINK-27597) Support get column statistic for Hive partition table

2022-06-30 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27597: - Summary: Support get column statistic for Hive partition table (was: Support get column statistic for

[jira] [Created] (FLINK-28317) Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables

2022-06-30 Thread luoyuxia (Jira)
luoyuxia created FLINK-28317: Summary: Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables Key: FLINK-28317 URL: https://issues.apache.org/jira/browse/FLINK-28317

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560815#comment-17560815 ] luoyuxia edited comment on FLINK-28276 at 6/30/22 4:25 AM: --- It's about iceberg

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560815#comment-17560815 ] luoyuxia edited comment on FLINK-28276 at 6/30/22 4:25 AM: --- It's about iceberg

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560815#comment-17560815 ] luoyuxia edited comment on FLINK-28276 at 6/30/22 4:24 AM: --- It's about iceberg

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560815#comment-17560815 ] luoyuxia edited comment on FLINK-28276 at 6/30/22 4:24 AM: --- It's about iceberg

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560815#comment-17560815 ] luoyuxia commented on FLINK-28276: -- It's about iceberg sdk. I'm not familar with it. And I'm not sure

[jira] [Resolved] (FLINK-26718) Limitations of flink+hive dimension table

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26718. -- Resolution: Not A Problem [~kunghsu] I think we can close this issue. Feel free to open it again if

[jira] [Commented] (FLINK-28208) The method createBatchSink in class HiveTableSink should setParallelism for map operator

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560811#comment-17560811 ] luoyuxia commented on FLINK-28208: -- [~Jiangang] Thanks for reporting it. I think the mapper parallelism

[jira] [Resolved] (FLINK-24871) Flink SQL hive reports IndexOutOfBoundsException when using trim in where clause

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-24871. -- Resolution: Resolved > Flink SQL hive reports IndexOutOfBoundsException when using trim in where >

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

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-25727. -- Resolution: Fixed > Flink SQL convert constant string to char type which cause hive udtf >

[jira] [Updated] (FLINK-27597) Support get column statistic for Hive paritioned table

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27597: - Summary: Support get column statistic for Hive paritioned table (was: Get statistic for Hive

[jira] [Created] (FLINK-28306) Support get table statistic for Hive partition table

2022-06-29 Thread luoyuxia (Jira)
luoyuxia created FLINK-28306: Summary: Support get table statistic for Hive partition table Key: FLINK-28306 URL: https://issues.apache.org/jira/browse/FLINK-28306 Project: Flink Issue Type:

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560802#comment-17560802 ] luoyuxia commented on FLINK-28276: -- The picture isn't completed so that I can't see the full

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560802#comment-17560802 ] luoyuxia edited comment on FLINK-28276 at 6/30/22 3:12 AM: --- The picture isn't

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560783#comment-17560783 ] luoyuxia commented on FLINK-28276: -- FileInputFormat is just an abstract class. I mean the what is the

[jira] [Updated] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28276: - Attachment: BA9CEEA0-BF38-4568-A7AD-66C68B19CF14.png >

[jira] [Comment Edited] (FLINK-26603) [Umbrella] Decouple Hive with Flink planner

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560780#comment-17560780 ] luoyuxia edited comment on FLINK-26603 at 6/30/22 1:45 AM: --- After PR

[jira] [Comment Edited] (FLINK-26603) [Umbrella] Decouple Hive with Flink planner

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560780#comment-17560780 ] luoyuxia edited comment on FLINK-26603 at 6/30/22 1:45 AM: --- After

[jira] [Commented] (FLINK-26603) [Umbrella] Decouple Hive with Flink planner

2022-06-29 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17560780#comment-17560780 ] luoyuxia commented on FLINK-26603: -- After PR[19920|[https://github.com/apache/flink/pull/19920]] , the

[jira] [Created] (FLINK-28296) Support Hive's UDAF which implement GenericUDAFResolver

2022-06-29 Thread luoyuxia (Jira)
Title: Message Title luoyuxia created an

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread luoyuxia (Jira)
Title: Message Title luoyuxia commented

[jira] [Commented] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-06-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558479#comment-17558479 ] luoyuxia commented on FLINK-28247: -- The issue is introduced in this

[jira] [Updated] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-06-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28247: - Description: The exception will be reprodued by the following sql when using Hive Dialect: {code:java}

[jira] [Updated] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-06-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28247: - Parent: FLINK-26360 Issue Type: Sub-task (was: Bug) > Exception will be thrown when over

[jira] [Created] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-06-24 Thread luoyuxia (Jira)
luoyuxia created FLINK-28247: Summary: Exception will be thrown when over window contains grouping in Hive Dialect Key: FLINK-28247 URL: https://issues.apache.org/jira/browse/FLINK-28247 Project: Flink

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

2022-06-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-28235. -- Resolution: Duplicate > Min aggregate function support type: ''ARRAY''. >

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

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

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28234: - Description: When using the follwiing sql  , it will throw the "java.lang.NumberFormatException:

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28234: - Description: When using the follwiing sql  , it will throw the "java.lang.NumberFormatException:

[jira] [Commented] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558298#comment-17558298 ] luoyuxia commented on FLINK-28234: -- I will fix it. > Infinite or NaN exception for power(-1, 0.5) >

[jira] [Updated] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28234: - Description: When  > Infinite or NaN exception for power(-1, 0.5) >

[jira] [Created] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

2022-06-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-28234: Summary: Infinite or NaN exception for power(-1, 0.5) Key: FLINK-28234 URL: https://issues.apache.org/jira/browse/FLINK-28234 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557839#comment-17557839 ] luoyuxia edited comment on FLINK-28212 at 6/23/22 1:15 PM: --- It seems a bug of

[jira] [Comment Edited] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557839#comment-17557839 ] luoyuxia edited comment on FLINK-28212 at 6/23/22 12:33 PM: It seems a bug

[jira] [Updated] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28212: - Parent: FLINK-26360 Issue Type: Sub-task (was: Bug) > IndexOutOfBoundsException is thrown when

[jira] [Commented] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557839#comment-17557839 ] luoyuxia commented on FLINK-28212: -- To fix it. The idea is straghtforward, make sure the produced

[jira] [Comment Edited] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557839#comment-17557839 ] luoyuxia edited comment on FLINK-28212 at 6/23/22 6:09 AM: --- To fix it, the

[jira] [Updated] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-23 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28212: - Description: Can be reproduced by following sql when using Hive dialect: {code:java} CREATE TABLE

[jira] [Updated] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28212: - Description: Can be reproduced by following sql {code:java} CREATE TABLE alltypesorc(

[jira] [Created] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-06-22 Thread luoyuxia (Jira)
luoyuxia created FLINK-28212: Summary: IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect Key: FLINK-28212 URL:

[jira] [Updated] (FLINK-27015) Hive dialect supports cast timestamp to decimal

2022-06-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27015: - Description: In hive, it's support to cast timestamp to decimal implictly with following sql:

[jira] [Updated] (FLINK-27015) Hive dialect supports cast timestamp to decimal

2022-06-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27015: - Summary: Hive dialect supports cast timestamp to decimal (was: Hive dialect supports cast timestamp to

[jira] [Commented] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

2022-06-19 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556154#comment-17556154 ] luoyuxia commented on FLINK-28120: -- [~godfrey] Could you please have a look. And I would like to take

[jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

2022-06-19 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28120: - Description: When I run the following sql with Hive dialect,   {code:java} create table src(key

[jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

2022-06-19 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28120: - Attachment: 截屏2022-06-18 上午11.48.46.png > Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has

[jira] [Created] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

2022-06-19 Thread luoyuxia (Jira)
luoyuxia created FLINK-28120: Summary: Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]] Key: FLINK-28120 URL:

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

2022-06-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555830#comment-17555830 ] luoyuxia commented on FLINK-27898: -- Sorry for late reply. About my thoughts, I think the second way is

[jira] [Commented] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

2022-06-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1791#comment-1791 ] luoyuxia commented on FLINK-28104: -- [~libenchao] Appreciate for your inputs.  Seems it should be

[jira] [Comment Edited] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

2022-06-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1791#comment-1791 ] luoyuxia edited comment on FLINK-28104 at 6/17/22 1:02 PM: --- [~libenchao]

[jira] [Updated] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

2022-06-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28104: - Fix Version/s: 1.16.0 > Drop the unused order parameter in FirstValueFunction/LastValueFunction >

[jira] [Created] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

2022-06-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-28104: Summary: Drop the unused order parameter in FirstValueFunction/LastValueFunction Key: FLINK-28104 URL: https://issues.apache.org/jira/browse/FLINK-28104 Project: Flink

[jira] [Created] (FLINK-28096) Hive dialect support set variable

2022-06-16 Thread luoyuxia (Jira)
luoyuxia created FLINK-28096: Summary: Hive dialect support set variable Key: FLINK-28096 URL: https://issues.apache.org/jira/browse/FLINK-28096 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-28096) Hive dialect support set variable

2022-06-16 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28096: - Component/s: Connectors / Hive > Hive dialect support set variable > -

[jira] [Updated] (FLINK-28096) Hive dialect support set variable

2022-06-16 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28096: - Fix Version/s: 1.16.0 > Hive dialect support set variable > - > >

[jira] [Created] (FLINK-28089) Hive dialect support "tablesample (xx rows)"

2022-06-16 Thread luoyuxia (Jira)
luoyuxia created FLINK-28089: Summary: Hive dialect support "tablesample (xx rows)" Key: FLINK-28089 URL: https://issues.apache.org/jira/browse/FLINK-28089 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26415) support partitioned view in hive dialect

2022-06-16 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26415: - Summary: support partitioned view in hive dialect (was: Improve view usage in hive dialect) > support

[jira] [Updated] (FLINK-27619) Support NTILE

2022-06-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27619: - Summary: Support NTILE (was: Support NTIE) > Support NTILE > - > > Key:

[jira] [Updated] (FLINK-28036) HiveInspectors should use correct writable type to creaet ConstantObjectInspector

2022-06-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28036: - Description: In HiveInspectors, we will create Hive's ConstantObjectInspector by passing writable type

[jira] [Updated] (FLINK-28036) HiveInspectors should use correct writable type to creaet ConstantObjectInspector

2022-06-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28036: - Summary: HiveInspectors should use correct writable type to creaet ConstantObjectInspector (was: Use

[jira] [Created] (FLINK-28036) Use correct writable type to creaet ConstantObjectInspector

2022-06-13 Thread luoyuxia (Jira)
luoyuxia created FLINK-28036: Summary: Use correct writable type to creaet ConstantObjectInspector Key: FLINK-28036 URL: https://issues.apache.org/jira/browse/FLINK-28036 Project: Flink Issue

[jira] [Updated] (FLINK-28036) Use correct writable type to creaet ConstantObjectInspector

2022-06-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28036: - Fix Version/s: 1.16.0 > Use correct writable type to creaet ConstantObjectInspector >

[jira] [Updated] (FLINK-28036) Use correct writable type to creaet ConstantObjectInspector

2022-06-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28036: - Component/s: Connectors / Hive > Use correct writable type to creaet ConstantObjectInspector >

[jira] [Updated] (FLINK-28036) HiveInspectors should use correct writable type to creaet ConstantObjectInspector

2022-06-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28036: - Description: In  > HiveInspectors should use correct writable type to creaet > ConstantObjectInspector

[jira] [Updated] (FLINK-28011) Optimize getAllPartitions in HiveSource

2022-06-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28011: - Component/s: Connectors / Hive > Optimize getAllPartitions in HiveSource >

[jira] [Updated] (FLINK-28011) Optimize getAllPartitions in HiveSource

2022-06-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28011: - Fix Version/s: 1.16.0 > Optimize getAllPartitions in HiveSource >

[jira] [Created] (FLINK-28011) Optimize getAllPartitions in HiveSource

2022-06-11 Thread luoyuxia (Jira)
luoyuxia created FLINK-28011: Summary: Optimize getAllPartitions in HiveSource Key: FLINK-28011 URL: https://issues.apache.org/jira/browse/FLINK-28011 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27996) Hive dialect support interval

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27996: - Component/s: Connectors / Hive > Hive dialect support interval > - > >

[jira] [Updated] (FLINK-27999) Fix test failure for Hive when using profile Hive3.1.1

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27999: - Summary: Fix test failure for Hive when using profile Hive3.1.1 (was: Fix test failure ) > Fix test

[jira] [Updated] (FLINK-27999) Fix test failure

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27999: - Summary: Fix test failure(was: Fix test failure for Hive3) > Fix test failure >

[jira] [Commented] (FLINK-27999) Fix test failure for Hive3

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552677#comment-17552677 ] luoyuxia commented on FLINK-27999: -- [~martijnvisser] Thanks for your reminder. I will update it later.

[jira] [Updated] (FLINK-27999) Fix test failure for Hive3

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27999: - Component/s: Connectors / Hive > Fix test failure for Hive3 > -- > >

[jira] [Updated] (FLINK-27999) Fix test failure for Hive3

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27999: - Description: When use 'mvn test -PHive3.1.1'  Hive connector, it will throw the following exception

[jira] [Updated] (FLINK-27999) Fix test failure for Hive3

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27999: - Fix Version/s: 1.16.0 > Fix test failure for Hive3 > -- > >

[jira] [Updated] (FLINK-27999) Fix test failure for Hive3

2022-06-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27999: - Affects Version/s: 1.15.0 > Fix test failure for Hive3 > -- > >

[jira] [Created] (FLINK-27999) Fix test failure for Hive3

2022-06-10 Thread luoyuxia (Jira)
luoyuxia created FLINK-27999: Summary: Fix test failure for Hive3 Key: FLINK-27999 URL: https://issues.apache.org/jira/browse/FLINK-27999 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27996) Hive dialect support interval

2022-06-10 Thread luoyuxia (Jira)
luoyuxia created FLINK-27996: Summary: Hive dialect support interval Key: FLINK-27996 URL: https://issues.apache.org/jira/browse/FLINK-27996 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26363. -- Resolution: Fixed > Fail to use such expression like if(1= 1, 2, 3) >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26365. -- Resolution: Duplicate > improve hive udaf > - > > Key: FLINK-26365 >

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552516#comment-17552516 ] luoyuxia commented on FLINK-27898: -- [~zoucao] Thanks for detail explaination. Just go head to open a

[jira] [Commented] (FLINK-25641) Unexpected aggregate plan after load hive module

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552514#comment-17552514 ] luoyuxia commented on FLINK-25641: -- [~jingzhang] When load hive module with a higer priority to flink's

[jira] [Resolved] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-25095. -- Resolution: Duplicate > Case when would be translated into different expression in Hive dialect and

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

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27296. -- Resolution: Duplicate > CalcOperator CodeGenException: Boolean expression type expected >

[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=17552508#comment-17552508 ] luoyuxia commented on FLINK-27304: -- [~godfreyhe] Could you please assign it to me? > Flink doesn't

[jira] [Commented] (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:comment-tabpanel=17552507#comment-17552507 ] luoyuxia commented on FLINK-27305: -- [~godfreyhe] Yes, I aggree. I would like to fix just in hive

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