[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-17803:
-
Description:
We use flink 1.10.0 , blink planner, to submit a batch sql job to read from
a hive
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
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-17803:
-
Summary: Flink batch sql job read hive table which contains map type, raise
exception: "
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-17803:
-
Description:
We use flink 1.10.0 , blink planner, to submit a batch sql job to read from
a hive
[
https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe closed FLINK-17803.
Resolution: Not A Problem
> Flink batch sql job read hive table which contains map type, raise exception:
[
https://issues.apache.org/jira/browse/FLINK-19588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe closed FLINK-19588.
Resolution: Abandoned
> HBase zookeeper connection not released in hbase batch table source while
>
[
https://issues.apache.org/jira/browse/FLINK-19588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-19588:
-
Description:
Hi, I Create a sql job read from hbase table, the sql as below
{code:java}
create table
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
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20213:
-
Attachment: image-2020-11-26-10-33-15-819.png
> Partition commit is delayed when records keep coming
>
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20213:
-
Attachment: image-2020-11-26-12-00-23-542.png
> Partition commit is delayed when records keep coming
>
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20213:
-
Attachment: image-2020-11-26-12-00-55-829.png
> Partition commit is delayed when records keep coming
>
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239075#comment-17239075
]
zouyunhe commented on FLINK-20213:
--
[~lzljs3620320] the commit delay is 1 min, the tblproperties
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239051#comment-17239051
]
zouyunhe commented on FLINK-20213:
--
[~lzljs3620320] We found the watermark as below, the time is about
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239096#comment-17239096
]
zouyunhe commented on FLINK-20213:
--
[~lzljs3620320] OK
> Partition commit is delayed when records keep
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239024#comment-17239024
]
zouyunhe commented on FLINK-20213:
--
[~lzljs3620320] Hello, we get your PR and test it in
[
https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20213:
-
Attachment: (was: image-2020-11-26-10-33-15-819.png)
> Partition commit is delayed when records
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
[
https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20440:
-
Summary: `LAST_VALUE` aggregate function can not be used in hop window
(was: `LAST_VALUE` aggregate
[
https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20440:
-
Description:
Hi, I run a sql job which use `last_value` aggregate function in a hop
window, the sql
[
https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe closed FLINK-20440.
Resolution: Duplicate
> `LAST_VALUE` aggregate function can not be used in hop window
>
[
https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241474#comment-17241474
]
zouyunhe commented on FLINK-20440:
--
[~hailong wang] ok
> `LAST_VALUE` aggregate function can not be
[
https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20253:
-
Description:
We run a flink job and the input data is json format, and found the exception
will throw
[
https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235839#comment-17235839
]
zouyunhe commented on FLINK-20248:
--
[~ZhenqiuHuang] OK
> `ParquetSchemaConverter` can not convert
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
[
https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20253:
-
Description:
We run a flink job and the input data is json format, and found the exception
will throw
[
https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20253:
-
Description:
We run a flink job and the input data is json format, and found the exception
will throw
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:
[
https://issues.apache.org/jira/browse/FLINK-20242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20242:
-
Component/s: (was: API / DataStream)
Table SQL / API
Description: When run a
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
[
https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20248:
-
Description:
Run a simple code as below
{code:java}
Type arraySchema =
[
https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-20248:
-
Description:
Run a simple code as below
{code:java}
Type arraySchema =
[
https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294296#comment-17294296
]
zouyunhe commented on FLINK-21523:
--
I print some debug log , the partition field is not found in the
[
https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292571#comment-17292571
]
zouyunhe commented on FLINK-21523:
--
[~lzljs3620320] hello, please take a look at this issue。
>
[
https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-21523:
-
Description:
we have two hive table, the ddl as below
{code:java}
//test_tbl5
create table test.test_5
[
https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-21523:
-
Summary: ArrayIndexOutOfBoundsException occurs while run a hive streaming
job with partitioned table
zouyunhe created FLINK-21523:
Summary: ArrayIndexOutOfBoundsException occurs while run a hive
streaming source job with partitioned table source
Key: FLINK-21523
URL:
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447767#comment-17447767
]
zouyunhe commented on FLINK-24997:
--
OK [~icshuo]
> count(null) not supported in flink sql query
>
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447765#comment-17447765
]
zouyunhe commented on FLINK-24997:
--
[~jark] [~icshuo] the calcite can not deduce the type, but the
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-24997:
-
Description:
I use sql client to submit a sql query to flink session cluster, the sql is
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447764#comment-17447764
]
zouyunhe commented on FLINK-24997:
--
[~icshuo] it works by use `select count(cast(null as int))`.
[
https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouyunhe updated FLINK-24997:
-
Description:
I use sql client to submit a sql query to flink session cluster, the sql is
`select
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
42 matches
Mail list logo
