[jira] [Created] (FLINK-34983) Hive param sink.partition-commit.policy.kind default value is not work in stream mode

yunfan created FLINK-34983: -- Summary: Hive param sink.partition-commit.policy.kind default value is not work in stream mode Key: FLINK-34983 URL: https://issues.apache.org/jira/browse/FLINK-34983 Project: Fl

[jira] [Created] (FLINK-31065) Support more split assigner strategy for batch job

yunfan created FLINK-31065: -- Summary: Support more split assigner strategy for batch job Key: FLINK-31065 URL: https://issues.apache.org/jira/browse/FLINK-31065 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-31065) Support more split assigner strategy for batch job

[ https://issues.apache.org/jira/browse/FLINK-31065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689497#comment-17689497 ] yunfan commented on FLINK-31065: [~luoyuxia] Yes, hive is the main usage of this strateg

[jira] [Commented] (FLINK-23687) Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801104#comment-17801104 ] yunfan commented on FLINK-23687: Hello, [~jingzhang] . Are you still working on this is

[jira] [Updated] (FLINK-33233) Null point exception when non-native udf used in join condition

[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yunfan updated FLINK-33233: --- Issue Type: Bug (was: Improvement) > Null point exception when non-native udf used in join condition >

[jira] [Commented] (FLINK-33233) Null point exception when non-native udf used in join condition

[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808563#comment-17808563 ] yunfan commented on FLINK-33233: [~luoyuxia] [~mapohl] Hello. I have submitted the PR wh

[jira] [Created] (FLINK-33478) Fail to call unix_timestamp when it is in filter condition

yunfan created FLINK-33478: -- Summary: Fail to call unix_timestamp when it is in filter condition Key: FLINK-33478 URL: https://issues.apache.org/jira/browse/FLINK-33478 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33478) Fail to call unix_timestamp when it is in filter condition

[ https://issues.apache.org/jira/browse/FLINK-33478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yunfan updated FLINK-33478: --- Description: It can reproduced by following sql. select * from foo where cast(unix_timestamp() as bigint) >

[jira] [Created] (FLINK-33596) Support fold expression before transfer to RexNode

yunfan created FLINK-33596: -- Summary: Support fold expression before transfer to RexNode Key: FLINK-33596 URL: https://issues.apache.org/jira/browse/FLINK-33596 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33233) Null point exception when non-native udf used in join condition

yunfan created FLINK-33233: -- Summary: Null point exception when non-native udf used in join condition Key: FLINK-33233 URL: https://issues.apache.org/jira/browse/FLINK-33233 Project: Flink Issue Ty

[jira] [Updated] (FLINK-33233) Null point exception when non-native udf used in join condition

[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yunfan updated FLINK-33233: --- Environment: (was: It can reproduced by follow code by adding this test to  {code:java} org.apache.flink

[jira] [Updated] (FLINK-33233) Null point exception when non-native udf used in join condition

[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yunfan updated FLINK-33233: --- Description: Any non-native udf used in hive-parser join condition.  It will caused NullPointException. It

[jira] [Created] (FLINK-33381) Support split big parquet file to multi InputSplits

yunfan created FLINK-33381: -- Summary: Support split big parquet file to multi InputSplits Key: FLINK-33381 URL: https://issues.apache.org/jira/browse/FLINK-33381 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-31865) Flink hive parser support order by non select column

yunfan created FLINK-31865: -- Summary: Flink hive parser support order by non select column Key: FLINK-31865 URL: https://issues.apache.org/jira/browse/FLINK-31865 Project: Flink Issue Type: Improvem