[jira] [Created] (FLINK-24997) count(null) not supported in flink sql query

2021-11-22 Thread zouyunhe (Jira)
zouyunhe created FLINK-24997: Summary: count(null) not supported in flink sql query Key: FLINK-24997 URL: https://issues.apache.org/jira/browse/FLINK-24997 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming source job with partitioned table source

2021-02-28 Thread zouyunhe (Jira)
zouyunhe created FLINK-21523: Summary: ArrayIndexOutOfBoundsException occurs while run a hive streaming source job with partitioned table source Key: FLINK-21523 URL:

[jira] [Created] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in Hop window

2020-12-01 Thread zouyunhe (Jira)
zouyunhe created FLINK-20440: Summary: `LAST_VALUE` aggregate function can not be used in Hop window Key: FLINK-20440 URL: https://issues.apache.org/jira/browse/FLINK-20440 Project: Flink Issue

[jira] [Created] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

2020-11-19 Thread zouyunhe (Jira)
zouyunhe created FLINK-20253: Summary: `JsonRowDeserializationSchema` can not deserialize non utf-8 json string Key: FLINK-20253 URL: https://issues.apache.org/jira/browse/FLINK-20253 Project: Flink

[jira] [Created] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type

2020-11-19 Thread zouyunhe (Jira)
zouyunhe created FLINK-20248: Summary: `ParquetSchemaConverter` can not convert Array type to parquet Type Key: FLINK-20248 URL: https://issues.apache.org/jira/browse/FLINK-20248 Project: Flink

[jira] [Created] (FLINK-20242) Can not set job name in StatementSet.execute() method

2020-11-19 Thread zouyunhe (Jira)
zouyunhe created FLINK-20242: Summary: Can not set job name in StatementSet.execute() method Key: FLINK-20242 URL: https://issues.apache.org/jira/browse/FLINK-20242 Project: Flink Issue Type:

[jira] [Created] (FLINK-19588) HBase zookeeper connection not released in hbase batch table source while flink job failover

2020-10-12 Thread zouyunhe (Jira)
zouyunhe created FLINK-19588: Summary: HBase zookeeper connection not released in hbase batch table source while flink job failover Key: FLINK-19588 URL: https://issues.apache.org/jira/browse/FLINK-19588

[jira] [Created] (FLINK-17803) Flink batch sql job read hive table with map type, raise exception: " scala.MatchError: MAP"

2020-05-18 Thread zouyunhe (Jira)
zouyunhe created FLINK-17803: Summary: Flink batch sql job read hive table with map type, raise exception: " scala.MatchError: MAP" Key: FLINK-17803 URL: https://issues.apache.org/jira/browse/FLINK-17803