[
https://issues.apache.org/jira/browse/FLINK-29676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29676:
---
Description:
create two tables
{code:java}
drop table if exists TABLE_1;
CREATE TABLE TABLE_1 (
`index
[
https://issues.apache.org/jira/browse/FLINK-29676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29676:
---
Description:
create two tables
{code:java}
drop table if exists TABLE_1;
CREATE TABLE TABLE_1 (
`index
[
https://issues.apache.org/jira/browse/FLINK-29676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29676:
---
Description:
create two tables
{code:java}
drop table if exists b_11_LAINDEXINFO;
CREATE TABLE b_11_LAINDE
[
https://issues.apache.org/jira/browse/FLINK-29676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29676:
---
Description:
create two tables
{code:java}
drop table if exists b_11_LAINDEXINFO;
CREATE TABLE b_11_LAINDE
[
https://issues.apache.org/jira/browse/FLINK-29676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29676:
---
Description:
create two tables
{code:java}
drop table if exists b_11_LAINDEXINFO;
CREATE TABLE b_11_LAINDE
[
https://issues.apache.org/jira/browse/FLINK-29675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg closed FLINK-29675.
--
Resolution: Duplicate
> unexpected correlate variable $cor262 in the plan
> --
Luochg created FLINK-29676:
--
Summary: unexpected correlate variable $cor262 in the plan
Key: FLINK-29676
URL: https://issues.apache.org/jira/browse/FLINK-29676
Project: Flink
Issue Type: Bug
Luochg created FLINK-29675:
--
Summary: unexpected correlate variable $cor262 in the plan
Key: FLINK-29675
URL: https://issues.apache.org/jira/browse/FLINK-29675
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: screenshot-1.png
> Flink Sql: implicit type conversion between BIGINT and VARCHAR(2147483647) is
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
{code:java}
%flink
val tabl
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
[样式|https://issues.apache.org/jira/projects/FLINK/issues/FLINK-29556?filter=allopenissues#]Zepp
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Environment: Flink 1.13.6, Apache Zeppelin, Mysql
> Flink Sql: implicit type conversion between BIGINT and V
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first:
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary view first:
%flink
val table = btenv.sqlQu
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: image-2022-10-10-00-47-58-672.png
image-2022-10-10-00-47-38-627.png
Descrip
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin 中脚本如下
首先创建一些临时表:
%flink
val table = btenv.sqlQuery("""
select a.agentcode,b.upage
[ https://issues.apache.org/jira/browse/FLINK-29556 ]
Luochg deleted comment on FLINK-29556:
was (Author: JIRAUSER296715):
*table b_186_P2:*
!image-2022-10-10-00-42-29-986.png!
*table b_186_P2_1:*
!image-2022-10-10-00-41-18-313.png!
*Error In
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin 中脚本如下
首先创建一些临时表:
%flink
val table = btenv.sqlQuery("""
select a.agentcode,b.upage
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614744#comment-17614744
]
Luochg edited comment on FLINK-29556 at 10/9/22 4:42 PM:
-
*table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: image-2022-10-10-00-40-03-422.png
> Flink Sql: implicit type conversion between BIGINT and VARCH
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614744#comment-17614744
]
Luochg commented on FLINK-29556:
!image-2022-10-10-00-40-03-422.png!
> Flink Sql: impli
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: Flink Sql: implicit type conversion between BIGINT and
VARCHAR(2147483647) is not supported on join
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: implicit type conversion between BIGINT and VARCHAR(2147483647) is
not supported on join's conditio
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: flink sql 执行过程报implicit type conversion between BIGINT and
VARCHAR(2147483647) is not supported on
Luochg created FLINK-29556:
--
Summary: flink sql 执行过程报java.lang.NullPointerException异常
Key: FLINK-29556
URL: https://issues.apache.org/jira/browse/FLINK-29556
Project: Flink
Issue Type: Bug
36 matches
Mail list logo