xiaojin.wy created FLINK-24192:
--
Summary: Sql get plan failed. All the inputs have relevant nodes,
however the cost is still infinite
Key: FLINK-24192
URL: https://issues.apache.org/jira/browse/FLINK-24192
[
https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23602:
---
Description:
{code:java}
CREATE TABLE database5_t2 (
`c0` DECIMAL , `c1` BIGINT
) WITH (
'connec
[
https://issues.apache.org/jira/browse/FLINK-23641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy closed FLINK-23641.
--
Resolution: Won't Fix
> A bad data should not stop and fail the job
>
[
https://issues.apache.org/jira/browse/FLINK-23642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23642:
---
Description:
The sql below we get returns a 'false' value
{code:java}
SELECT (not (CAST (((CAST (IS
xiaojin.wy created FLINK-23642:
--
Summary: A result of SELECT (not (CAST (((CAST
(IS_ALPHA(-421305765) AS BOOLEAN)) OR (CAST ((SHA1(CAST ('鲇T' AS STRING ))) AS
BOOLEAN))) AS BOOLEAN))) IS NULL should return true
Key: FLINK-23642
xiaojin.wy created FLINK-23641:
--
Summary: A bad data should not stop and fail the job
Key: FLINK-23641
URL: https://issues.apache.org/jira/browse/FLINK-23641
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy closed FLINK-23609.
--
Resolution: Won't Fix
> Codegen error of "Infinite or NaN at
> java.math.BigDecimal.(BigDecimal.java
[
https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393015#comment-17393015
]
xiaojin.wy commented on FLINK-23602:
I don't have the ability to assign people, mayb
[
https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23609:
---
Description:
{code:java}
CREATE TABLE database5_t2 (
`c0` DECIMAL
) WITH (
'connector' = 'filesy
[
https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23609:
---
Summary: Codegen error of "Infinite or NaN at
java.math.BigDecimal.(BigDecimal.java:898)" (was: Co
[
https://issues.apache.org/jira/browse/FLINK-23609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23609:
---
Environment: (was: java.lang.NumberFormatException: Infinite or NaN
at java.math.BigDeci
xiaojin.wy created FLINK-23609:
--
Summary: Codeine error of "Infinite or NaN at
java.math.BigDecimal.(BigDecimal.java:898)"
Key: FLINK-23609
URL: https://issues.apache.org/jira/browse/FLINK-23609
Project
xiaojin.wy created FLINK-23602:
--
Summary: org.codehaus.commons.compiler.CompileException: Line 84,
Column 78: No applicable constructor/method found for actual parameters
"org.apache.flink.table.data.DecimalData
Key: FLINK-23602
xiaojin.wy created FLINK-23579:
--
Summary: SELECT SHA2(NULL, CAST(NULL AS INT)) AS ref0 can't compile
Key: FLINK-23579
URL: https://issues.apache.org/jira/browse/FLINK-23579
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23303:
---
Description:
{code:java}
CREATE TABLE database5_t1(
`c0` SMALLINT , `c1` INTEGER , `c2` SMALLINT
) W
[
https://issues.apache.org/jira/browse/FLINK-23303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23303:
---
Description:
{code:java}
CREATE TABLE database5_t1(
`c0` SMALLINT , `c1` INTEGER , `c2` SMALLINT
) W
[
https://issues.apache.org/jira/browse/FLINK-23288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377900#comment-17377900
]
xiaojin.wy edited comment on FLINK-23288 at 7/9/21, 7:56 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-23288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377900#comment-17377900
]
xiaojin.wy edited comment on FLINK-23288 at 7/9/21, 7:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-23288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377900#comment-17377900
]
xiaojin.wy commented on FLINK-23288:
But if a user want to join two tables' data int
[
https://issues.apache.org/jira/browse/FLINK-23303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23303:
---
Description:
{code:java}
CREATE TABLE database5_t1(
`c0` SMALLINT , `c1` INTEGER , `c2` SMALLINT
) W
[
https://issues.apache.org/jira/browse/FLINK-23303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23303:
---
Description:
{code:java}
CREATE TABLE database5_t1(
`c0` SMALLINT , `c1` INTEGER , `c2` SMALLINT
) W
[
https://issues.apache.org/jira/browse/FLINK-23303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23303:
---
Description:
{code:java}
CREATE TABLE database5_t1(
`c0` SMALLINT , `c1` INTEGER , `c2` SMALLINT
) W
[
https://issues.apache.org/jira/browse/FLINK-23303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23303:
---
Description:
{code:java}
CREATE TABLE database5_t1(
`c0` SMALLINT , `c1` INTEGER , `c2` SMALLINT
)
xiaojin.wy created FLINK-23303:
--
Summary: org.apache.calcite.rex.RexLiteral cannot be cast to
org.apache.calcite.rex.RexCall
Key: FLINK-23303
URL: https://issues.apache.org/jira/browse/FLINK-23303
Projec
xiaojin.wy created FLINK-23290:
--
Summary: cast '(LZ *3' as boolean, get a null
Key: FLINK-23290
URL: https://issues.apache.org/jira/browse/FLINK-23290
Project: Flink
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/FLINK-23288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23288:
---
Description:
CREATE TABLE database5_t0(
`c0` DOUBLE , `c1` INTEGER , `c2` STRING
) WITH (
'connecto
xiaojin.wy created FLINK-23288:
--
Summary: Inserting (1.378593404E9) (0.6047707965147558) to a
double type, it will generate CodeGenException
Key: FLINK-23288
URL: https://issues.apache.org/jira/browse/FLINK-23288
[
https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23271:
---
Description:
*Sql :*
CREATE TABLE database3_t0(
c0 DECIMAL , c1 SMALLINT
) WITH (
'connector'
[
https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23271:
---
Description:
*-- sql --*
CREATE TABLE database3_t0(
c0 DECIMAL , c1 SMALLINT
) WITH (
'connect
[
https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23271:
---
Description:
-- *sql *--
CREATE TABLE database3_t0(
c0 DECIMAL , c1 SMALLINT
) WITH (
'connect
[
https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23271:
---
Description:
*-- sql --*
CREATE TABLE database3_t0(
c0 DECIMAL , c1 SMALLINT
) WITH (
'connecto
xiaojin.wy created FLINK-23271:
--
Summary: RuntimeException: while resolving method 'booleanValue'
in class class java.math.BigDecimal
Key: FLINK-23271
URL: https://issues.apache.org/jira/browse/FLINK-23271
xiaojin.wy created FLINK-23188:
--
Summary: Unsupported function definition: IFNULL. Only user
defined functions are supported as inline functions
Key: FLINK-23188
URL: https://issues.apache.org/jira/browse/FLINK-23188
[
https://issues.apache.org/jira/browse/FLINK-23184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23184:
---
Description:
CREATE TABLE MySink (
`a` SMALLINT
) WITH (
'connector' = 'filesystem',
'format'
xiaojin.wy created FLINK-23184:
--
Summary: CompileException Assignment conversion not possible from
type "int" to type "short"
Key: FLINK-23184
URL: https://issues.apache.org/jira/browse/FLINK-23184
Proje
[
https://issues.apache.org/jira/browse/FLINK-23077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-23077:
---
Description:
Running nexmark with flink 1.13.0, 1.13.1, q5 can`t success.
*The conf is: *
pipeline.o
xiaojin.wy created FLINK-23077:
--
Summary: Running nexmark q5 with 1.13.1 of
pipeline.object-reuse=true, the taskmanager will be killed and produce failover.
Key: FLINK-23077
URL: https://issues.apache.org/jira/browse
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148604#comment-17148604
]
xiaojin.wy commented on FLINK-18364:
mark [~TsReaper]
> A streaming sql cause "org.
[
https://issues.apache.org/jira/browse/FLINK-18371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-18371:
---
Environment:
I use the sql-gateway to run this sql.
The environment is streaming.
*The sql is:*
CRE
[
https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15397:
---
Fix Version/s: 1.11.0
Affects Version/s: 1.11.0
> Streaming and batch has different value in
xiaojin.wy created FLINK-18411:
--
Summary: release-1.11 compile failed
Key: FLINK-18411
URL: https://issues.apache.org/jira/browse/FLINK-18411
Project: Flink
Issue Type: Bug
Components:
xiaojin.wy created FLINK-18401:
--
Summary: A streaming sql has "Sort on a non-time-attribute field
is not supported"
Key: FLINK-18401
URL: https://issues.apache.org/jira/browse/FLINK-18401
Project: Flink
xiaojin.wy created FLINK-18400:
--
Summary: A streaming sql has "java.lang.NegativeArraySizeException"
Key: FLINK-18400
URL: https://issues.apache.org/jira/browse/FLINK-18400
Project: Flink
Issue
xiaojin.wy created FLINK-18371:
--
Summary: NPE of
"org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)"
Key: FLINK-18371
URL: https://issues.apache.o
[
https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140133#comment-17140133
]
xiaojin.wy commented on FLINK-18365:
[~jark] This two issues are different, FLINK-1
[
https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140133#comment-17140133
]
xiaojin.wy edited comment on FLINK-18365 at 6/19/20, 2:37 AM:
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140129#comment-17140129
]
xiaojin.wy edited comment on FLINK-18364 at 6/19/20, 2:33 AM:
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-18364:
---
Description:
*The whole error is:*
Caused by: org.apache.flink.table.api.ValidationException: Type
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140129#comment-17140129
]
xiaojin.wy commented on FLINK-18364:
The error above appear again after the sql chan
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-18364:
---
Description:
*The whole error is:*
Caused by: org.apache.flink.table.api.ValidationException: Type
xiaojin.wy created FLINK-18365:
--
Summary: The same sql in a batch env and a streaming env has
different value.
Key: FLINK-18365
URL: https://issues.apache.org/jira/browse/FLINK-18365
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-18364:
---
Description:
*The whole error is:*
Caused by: org.apache.flink.table.api.ValidationException: Type
[
https://issues.apache.org/jira/browse/FLINK-18364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-18364:
---
Description:
*The whole error is:*
Caused by: org.apache.flink.table.api.ValidationException: Type T
xiaojin.wy created FLINK-18364:
--
Summary: A streaming sql cause
"org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table
field 'rowtime' does not match with the physical type TIMESTAMP(3) of the
'rowtime' field of the TableSink c
[
https://issues.apache.org/jira/browse/FLINK-15613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15613:
---
Description:
*The sql is* :
CREATE TABLE `int8_tbl` (
q1 bigint, q2 bigint
) WITH (
'connector.p
[
https://issues.apache.org/jira/browse/FLINK-15613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029650#comment-17029650
]
xiaojin.wy commented on FLINK-15613:
[~ykt836], could you assign someone to fix it?
[
https://issues.apache.org/jira/browse/FLINK-15658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15658:
---
Description:
*summary:*
The same sql can run in a batch environment normally, but in a streaming
e
[
https://issues.apache.org/jira/browse/FLINK-15658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15658:
---
Environment:
*Input data:*
tenk1 is:
4773|9990|1|1|3|13|73|773|773|4773|4773|146|147|PB|GUOAAA|O
[
https://issues.apache.org/jira/browse/FLINK-15658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15658:
---
Description:
*summary:
*
The same sql can run in a batch environment normally, but in a streaming
xiaojin.wy created FLINK-15658:
--
Summary: The same sql run in a streaming environment producing a
Exception, but a batch env can run normally.
Key: FLINK-15658
URL: https://issues.apache.org/jira/browse/FLINK-15658
xiaojin.wy created FLINK-15613:
--
Summary: execute sql appear "java.lang.IndexOutOfBoundsException"
Key: FLINK-15613
URL: https://issues.apache.org/jira/browse/FLINK-15613
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15565:
---
Description:
*The sql is:*
CREATE TABLE `over10k` (
t tinyint,
si smallint,
i int,
b bigint,
f
xiaojin.wy created FLINK-15565:
--
Summary: sql planner Incompatible
Key: FLINK-15565
URL: https://issues.apache.org/jira/browse/FLINK-15565
Project: Flink
Issue Type: Bug
Components: Ta
[
https://issues.apache.org/jira/browse/FLINK-15437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005267#comment-17005267
]
xiaojin.wy commented on FLINK-15437:
[~xintongsong] I delete '-n 20', the same excep
[
https://issues.apache.org/jira/browse/FLINK-15437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005234#comment-17005234
]
xiaojin.wy commented on FLINK-15437:
[~wuzang]
> Start session with property of "-D
[
https://issues.apache.org/jira/browse/FLINK-15437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15437:
---
Description:
*The environment:*
Yarn session cmd is as below, and the flink-conf.yaml has not the pr
xiaojin.wy created FLINK-15437:
--
Summary: Start session with property of
"-Dtaskmanager.memory.process.size" not work
Key: FLINK-15437
URL: https://issues.apache.org/jira/browse/FLINK-15437
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-15437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15437:
---
Description:
*The environment:*
Yarn session cmd is as below, and the flink-conf.yaml has not the pr
[
https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15397:
---
Description:
*The sql is:*
CREATE TABLE `testdata` (
a INT,
b INT
) WITH (
[
https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15397:
---
Description:
*The sql is:*
CREATE TABLE `testdata` (
a INT,
b INT
) WITH (
[
https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15397:
---
Description:
*The sql is:*
CREATE TABLE `testdata` (
a INT,
b INT
) WITH (
[
https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15397:
---
Description:
*The sql is:*
CREATE TABLE `testdata` (
a INT,
b INT
) WITH (
xiaojin.wy created FLINK-15397:
--
Summary: Streaming and batch has different value in the case of
count function
Key: FLINK-15397
URL: https://issues.apache.org/jira/browse/FLINK-15397
Project: Flink
xiaojin.wy created FLINK-15346:
--
Summary: OldCsvValidator has no property of "emptyColumnAsNull".
Key: FLINK-15346
URL: https://issues.apache.org/jira/browse/FLINK-15346
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999718#comment-16999718
]
xiaojin.wy edited comment on FLINK-15321 at 12/19/19 3:50 AM:
[
https://issues.apache.org/jira/browse/FLINK-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999718#comment-16999718
]
xiaojin.wy commented on FLINK-15321:
ok, I will close it if it's expected.
> The re
[
https://issues.apache.org/jira/browse/FLINK-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15321:
---
Description:
The sql is :
SELECT concat('a', cast(null as varchar), 'c');
The result of the sql is
xiaojin.wy created FLINK-15321:
--
Summary: The result of sql(SELECT concat('a', cast(null as
varchar), 'c');) is NULL;
Key: FLINK-15321
URL: https://issues.apache.org/jira/browse/FLINK-15321
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15310:
---
Description:
*The sql is:*
CREATE TABLE `orders` (
rowtime TIMESTAMP,
id INT,
[
https://issues.apache.org/jira/browse/FLINK-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15310:
---
Description:
*The sql is:*
CREATE TABLE `orders` (
rowtime TIMESTAMP,
id INT,
[
https://issues.apache.org/jira/browse/FLINK-15310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998938#comment-16998938
]
xiaojin.wy commented on FLINK-15310:
[~danny0405]
> A timestamp result get by a sel
xiaojin.wy created FLINK-15310:
--
Summary: A timestamp result get by a select sql and a csvsink sql
is different
Key: FLINK-15310
URL: https://issues.apache.org/jira/browse/FLINK-15310
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15309:
---
Description:
*The sql is:*
CREATE TABLE `src` (
key bigint,
v varchar
) WITH (
xiaojin.wy created FLINK-15309:
--
Summary: Execute sql appear "NumberFormatException: Zero length
BigInteger"
Key: FLINK-15309
URL: https://issues.apache.org/jira/browse/FLINK-15309
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997991#comment-16997991
]
xiaojin.wy commented on FLINK-15289:
[~lzljs3620320] will repair this issue.
> Run
xiaojin.wy created FLINK-15289:
--
Summary: Run sql appear error of "Zero-length character strings
have no serializable string representation".
Key: FLINK-15289
URL: https://issues.apache.org/jira/browse/FLINK-15289
[
https://issues.apache.org/jira/browse/FLINK-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15284:
---
Comment: was deleted
(was: [~ykt836])
> Sql error (Failed to push project into table source!)
> ---
[
https://issues.apache.org/jira/browse/FLINK-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997763#comment-16997763
]
xiaojin.wy commented on FLINK-15284:
This is the same one with https://issues.apache
[
https://issues.apache.org/jira/browse/FLINK-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997759#comment-16997759
]
xiaojin.wy commented on FLINK-15284:
[~ykt836]
> Sql error (Failed to push project
xiaojin.wy created FLINK-15284:
--
Summary: Sql error (Failed to push project into table source!)
Key: FLINK-15284
URL: https://issues.apache.org/jira/browse/FLINK-15284
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15284:
---
Description:
*The sql is:*
CREATE TABLE `t` (
x INT
) WITH (
'format.field-delimiter'=',',
'con
[
https://issues.apache.org/jira/browse/FLINK-15246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy closed FLINK-15246.
--
Resolution: Fixed
> Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL] not equal to TableSink
> s
[
https://issues.apache.org/jira/browse/FLINK-15246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997229#comment-16997229
]
xiaojin.wy commented on FLINK-15246:
This issue has not appear any more when I user
xiaojin.wy created FLINK-15246:
--
Summary: Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL]
not equal to TableSink schema:[EXPR$0: TIMESTAMP(3)]
Key: FLINK-15246
URL: https://issues.apache.org/jira/browse/FL
[
https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy closed FLINK-15238.
--
Resolution: Invalid
> A sql can't generate a valid execution plan
> --
[
https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15238:
---
Description:
*The table and the query is like this:*
CREATE TABLE `scott_emp` (
> empno INT,
> enam
[
https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15238:
---
Description:
The table and the query is like this:
CREATE TABLE `scott_emp` (CREATE TABLE `scott_em
xiaojin.wy created FLINK-15238:
--
Summary: A sql can't generate a valid execution plan
Key: FLINK-15238
URL: https://issues.apache.org/jira/browse/FLINK-15238
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaojin.wy updated FLINK-15217:
---
Description:
*The sql is like this:*
CREATE TABLE `DATE_TBL` (
> f1 date
> ) WITH (
> 'format.fi
xiaojin.wy created FLINK-15217:
--
Summary: 'java.time.LocalDate' should support for the CSV input
format.
Key: FLINK-15217
URL: https://issues.apache.org/jira/browse/FLINK-15217
Project: Flink
I
1 - 100 of 107 matches
Mail list logo
