[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJOs、maps、 JsonObject datatype event  do not work.    Any datatype for even

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Description:   1、problem：*Table change to stream for CEP* , only event  is *ROW*  datatype *can works*

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only the row datatype Stream works on CEP, and other POJOs、maps、 JsonObject datatype streams do not work, but any datatype stream for

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Description:   1、problem：*Table change to stream for CEP* , only event  is *ROW*  datatype can works o

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJOs、maps、 JsonObject datatype event  do not work.    Any datatype for even

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Summary: Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJ

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only the row datatype Stream works on CEP, and other POJOs、maps、 JsonObject datatype streams do not work, but any datatype stream for

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Summary: Table change to stream for CEP , only the row datatype Stream works on CEP, and other POJOs、m

[jira] [Commented] (FLINK-24224) Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412366#comment-17412366 ] YUJIANBO commented on FLINK-24224: -- [~dwysakowicz]:              hello, I am very eage

[jira] [Created] (FLINK-24224) Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work b

2021-09-08 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-24224: Summary: Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work by only stream api . Key:

[jira] [Commented] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2021-08-05 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394450#comment-17394450 ] YUJIANBO commented on FLINK-23643: -- [~jark]   {{ROW_NUMBER() only get *one* first data，

[jira] [Commented] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2021-08-05 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394433#comment-17394433 ] YUJIANBO commented on FLINK-23643: -- [~jark]All right. My business want to the joint fi

[jira] [Commented] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2021-08-05 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393756#comment-17393756 ] YUJIANBO commented on FLINK-23643: -- [~jark] hello Jark , please give me some advice. >

[jira] [Created] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

2021-08-05 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-23643: Summary: I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions Key: FLINK-23643 URL: https://issues.apache.org/jira/browse/FLINK-23643

[jira] [Commented] (FLINK-22806) The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger

2021-05-31 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354372#comment-17354372 ] YUJIANBO commented on FLINK-22806: -- [~jark]Thank you very much! My data coming from

[jira] [Updated] (FLINK-22806) The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one h

[jira] [Updated] (FLINK-22806) The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one h

[jira] [Updated] (FLINK-22806) The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Summary: The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger (was: The checkp

[jira] [Updated] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one h

[jira] [Updated] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one hou

[jira] [Comment Edited] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354196#comment-17354196 ] YUJIANBO edited comment on FLINK-22806 at 5/31/21, 3:30 AM:

[jira] [Commented] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354196#comment-17354196 ] YUJIANBO commented on FLINK-22806: -- Hi [~lirui] Can you give me some advice？ > The ch

[jira] [Updated] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、state.idle.duration: 3600, 2、state.checkpoints.num-r

[jira] [Created] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

2021-05-30 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-22806: Summary: The checkpoint state of FLINKSQL is getting bigger and bigger Key: FLINK-22806 URL: https://issues.apache.org/jira/browse/FLINK-22806 Project: Flink Issue

[jira] [Commented] (FLINK-21142) Flink guava Dependence problem

2021-01-25 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271912#comment-17271912 ] YUJIANBO commented on FLINK-21142: -- [~lirui]That's also my question. I didn't notice yo

[jira] [Updated] (FLINK-21142) Flink guava Dependence problem

2021-01-25 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-21142: - Description: We set up a new Hadoop cluster, and we use the flink1.12.0 compiled by the previous releas

[jira] [Updated] (FLINK-21142) Flink guava Dependence problem

2021-01-25 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-21142: - Labels: guava (was: ) > Flink guava Dependence problem > -- > >

[jira] [Updated] (FLINK-21142) Flink guava Dependence problem

2021-01-25 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-21142: - Labels: (was: guava) > Flink guava Dependence problem > -- > >

[jira] [Commented] (FLINK-21142) Flink guava Dependence problem

2021-01-25 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271881#comment-17271881 ] YUJIANBO commented on FLINK-21142: -- [~jark] [~lirui] Hello！Can you give me some advice?

[jira] [Created] (FLINK-21142) Flink guava Dependence problem

2021-01-25 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-21142: Summary: Flink guava Dependence problem Key: FLINK-21142 URL: https://issues.apache.org/jira/browse/FLINK-21142 Project: Flink Issue Type: Bug Components:

[jira] [Comment Edited] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-01-13 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264572#comment-17264572 ] YUJIANBO edited comment on FLINK-20951 at 1/14/21, 3:37 AM:

[jira] [Comment Edited] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-01-13 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264572#comment-17264572 ] YUJIANBO edited comment on FLINK-20951 at 1/14/21, 3:29 AM:

[jira] [Comment Edited] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-01-13 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264572#comment-17264572 ] YUJIANBO edited comment on FLINK-20951 at 1/14/21, 3:28 AM:

[jira] [Comment Edited] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-01-13 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264572#comment-17264572 ] YUJIANBO edited comment on FLINK-20951 at 1/14/21, 3:28 AM:

[jira] [Commented] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-01-13 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264572#comment-17264572 ] YUJIANBO commented on FLINK-20951: -- [~lirui][~jark] Thanks to the help of Jack and Rui

[jira] [Updated] (FLINK-20951) Flink SQL cli an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-20951: - Summary: Flink SQL cli an exception will occur (was: Flink SQL cli queries the partition table with hiv

[jira] [Updated] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-20951: - Description: The production hive table is partitioned by two fields：datekey and event I have do this te

[jira] [Updated] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-20951: - Description: The production hive table is partitioned by two fields：datekey and event I have do this te

[jira] [Updated] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-20951: - Description: The production hive table is partitioned by two fields：datekey and event I have do this te

[jira] [Updated] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-20951: - Description: The production hive table is partitioned by two fields：datekey and event I have do this te

[jira] [Created] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur

2021-01-12 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-20951: Summary: Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur Key: FLINK-20951 URL: http

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-28 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222729#comment-17222729 ] YUJIANBO commented on FLINK-19768: -- Thanks a lot! I'll try again ！ > The shell "./yar

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-28 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222687#comment-17222687 ] YUJIANBO commented on FLINK-19768: -- Thanks a lot for your answer！ I changed the log4j.p

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-27 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221233#comment-17221233 ] YUJIANBO commented on FLINK-19768: -- Thank you for your reply! I try it, but it doesn't

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-26 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221121#comment-17221121 ] YUJIANBO commented on FLINK-19768: -- Thank you for your reply！ I want to ask a question

[jira] [Issue Comment Deleted] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-26 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-19768: - Comment: was deleted (was: Thank you for your reply！ I want to ask a question. Our company plans to us

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-26 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221120#comment-17221120 ] YUJIANBO commented on FLINK-19768: -- Thank you for your reply！ I want to ask a questio

[jira] [Updated] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-22 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-19768: - Component/s: Deployment / YARN > The shell "./yarn-session.sh " not use log4j-session.properties , it u

[jira] [Created] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-22 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-19768: Summary: The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties Key: FLINK-19768 URL: https://issues.apache.org/jira/browse/FLINK-19768 Pr

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错：org.apache.flink.table.data.binary.BinaryRawValueDat

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错：org.apache.flink.table.data.binary.BinaryRawValueDat

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错：org.apache.flink.table.data.binary.BinaryRawValueDat

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错：* org.apache.flink.table.data.binary.BinaryRawValueD

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错： org.apache.flink.table.data.binary.BinaryRawValueDa

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Attachment: (was: flinksql 的count(1) 的结果值不能强转成String类型) > sql 中agg算子的 count(1) 的结果强转成String类型再经过一次ag

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Attachment: sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功.txt > sql 中agg算子的 count(1) 的结果强转成String类

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错： org.apache.flink.table.data.binary.BinaryRawValueDa

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Summary: sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功 (was: sql 中agg算子的 count(1) 的结果不能强转成String类

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Summary: sql 中agg算子的 count(1) 的结果不能强转成String类型 (was: sql 中agg算子的 count(1) 的结果不能强转成String类型（描述信息看不清可以看附件

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述信息看不清可以看附件txt文件）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错： org.apache.flink.table.data.binary.BinaryRawValueDa

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述信息看不清可以看附件txt文件）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Summary: sql 中agg算子的 count(1) 的结果不能强转成String类型（描述信息看不清可以看附件txt文件） (was: sql 中agg算子的 count(1) 的结果不能强转成St

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错： org.apache.flink.table.data.binary.BinaryRawValueDa

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错： org.apache.flink.table.data.binary.BinaryRawValueDa

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Description: 1、环境：flinksql、 版本是1.11.1，perjob模式 2、报错： org.apache.flink.table.data.binary.BinaryRawValueDa

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Attachment: flinksql 的count(1) 的结果值不能强转成String类型 > sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Attachment: (was: flinksql 的count(1) 的结果值不能强转成String类型) > sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Attachment: flinksql 的count(1) 的结果值不能强转成String类型 > sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

[jira] [Updated] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里）

2020-08-09 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-18862: - Summary: sql 中agg算子的 count(1) 的结果不能强转成String类型（描述填不了信息，写在附件里） (was: sql 中agg算子的 count(1) 的结果不能强转成String

[jira] [Created] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型

2020-08-09 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-18862: Summary: sql 中agg算子的 count(1) 的结果不能强转成String类型 Key: FLINK-18862 URL: https://issues.apache.org/jira/browse/FLINK-18862 Project: Flink Issue Type: Bug Compo