Martijn Visser created FLINK-24166:
--------------------------------------
Summary: Local class incompatible error returned when submitting
incorrect SQL statement
Key: FLINK-24166
URL: https://issues.apache.org/jira/browse/FLINK-24166
Project: Flink
Issue Type: Bug
Components: Table SQL / API, Table SQL / Client
Affects Versions: 1.14.0
Reporter: Martijn Visser
Reproduction steps:
1. Downloaded Flink 1.14 RC0 and started SQL client using ./sql-client.sh
2. Tried two incorrect SQL statements:
{code:sql}
SELECT MAP[1, 'a', 1.1, 'b'];
{code}
{code:sql}
SELECT CARDINALITY(ARRAY[1, 2, 3, 1.2]);
{code}
3. Returned error message in Flink 1.14 RC0 is:
{code:java}
[ERROR] Could not execute SQL statement. Reason:
java.io.InvalidClassException:
org.apache.flink.table.runtime.generated.GeneratedClass; local class
incompatible: stream classdesc serialVersionUID = 383271260664545330, local
class serialVersionUID = 6170410716745042722
{code}
In Flink 1.13.2, the error message that was returned is:
{code:java}
[ERROR] Could not execute SQL statement. Reason:
org.codehaus.commons.compiler.CompileException: Line 42, Column 35: No
applicable constructor/method found for actual parameters "int, int, int";
candidates are: "public void
org.apache.flink.table.data.writer.BinaryArrayWriter.writeDecimal(int,
org.apache.flink.table.data.DecimalData, int)", "public void
org.apache.flink.table.data.writer.AbstractBinaryWriter.writeDecimal(int,
org.apache.flink.table.data.DecimalData, int)", "public abstract void
org.apache.flink.table.data.writer.BinaryWriter.writeDecimal(int,
org.apache.flink.table.data.DecimalData, int)"
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
