You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yardstrong (Jira)" <ji...@apache.org> on 2020/10/10 10:33:00 UTC
[jira] [Updated] (FLINK-19565)
java.util.Collections$UnmodifiableList to field
org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type
java.util.ArrayList in instance of
org.apache.flink.runtime.jobgraph.JobVertex
[ https://issues.apache.org/jira/browse/FLINK-19565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yardstrong updated FLINK-19565:
-------------------------------
Environment:
I add {color:#4c9aff}flink-csv-1.10.2.jar{color} & {color:#4c9aff}flink-sql-connector-kafka_2.11-1.11.0.jar {color:#172b4d}to the lib dir. I run the sql below with sql-client:{color}{color}
_CREATE TABLE kafkaSource (_
{color:#505f79} _a VARCHAR,_{color}
{color:#505f79} _b VARCHAR_{color}
{color:#505f79}_) WITH (_{color}
{color:#505f79} _'connector' = 'kafka',_{color}
{color:#505f79} _'topic' = 'source001',_{color}
{color:#505f79} _'properties.bootstrap.servers' = 'localhost:9092',_{color}
{color:#505f79} _'properties.group.id' = 'consumer001',_{color}
{color:#505f79} _'format' = 'csv',_{color}
{color:#505f79} _'scan.startup.mode' = 'latest-offset'_{color}
{color:#505f79}_);_{color}
{color:#505f79}_CREATE TABLE kafkaSink (_{color}
{color:#505f79} _a VARCHAR,_{color}
{color:#505f79} _b VARCHAR_{color}
{color:#505f79}_) WITH (_{color}
{color:#505f79} _'connector' = 'kafka',_{color}
{color:#505f79} _'topic' = 'sink001',_{color}
{color:#505f79} _'properties.bootstrap.servers' = 'localhost:9092',_{color}
{color:#505f79} _'format' = 'csv'_{color}
{color:#505f79}_);_{color}
{color:#505f79}_INSERT INTO kafkaSink_{color}
{color:#505f79}_SELECT *_{color}
{color:#505f79}_FROM kafkaSource;_{color}
{color:#172b4d}Then the exception {color}appeared.
was:
I add {color:#4c9aff}flink-csv-1.10.2.jar{color} & {color:#4c9aff}flink-sql-connector-kafka_2.11-1.11.0.jar {color:#172b4d}to the lib dir. I run the sql below with sql-client:{color}{color}
{color:#505f79}_CREATE TABLE kafkaSource (_{color}
{color:#505f79} _a VARCHAR,_{color}
{color:#505f79} _b VARCHAR_{color}
{color:#505f79}_) WITH (_{color}
{color:#505f79} _'connector' = 'kafka',_{color}
{color:#505f79} _'topic' = 'source001',_{color}
{color:#505f79} _'properties.bootstrap.servers' = 'localhost:9092',_{color}
{color:#505f79} _'properties.group.id' = 'consumer001',_{color}
{color:#505f79} _'format' = 'csv',_{color}
{color:#505f79} _'scan.startup.mode' = 'latest-offset'_{color}
{color:#505f79}_);_{color}
{color:#505f79}_CREATE TABLE kafkaSink (_{color}
{color:#505f79} _a VARCHAR,_{color}
{color:#505f79} _b VARCHAR_{color}
{color:#505f79}_) WITH (_{color}
{color:#505f79} _'connector' = 'kafka',_{color}
{color:#505f79} _'topic' = 'sink001',_{color}
{color:#505f79} _'properties.bootstrap.servers' = 'localhost:9092',_{color}
{color:#505f79} _'format' = 'csv'_{color}
{color:#505f79}_);_{color}
{color:#505f79}_INSERT INTO kafkaSink_{color}
{color:#505f79}_SELECT *_{color}
{color:#505f79}_FROM kafkaSource;_{color}
{color:#172b4d}Then the exception {color}appeared.
> java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runtime.jobgraph.JobVertex
> ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-19565
> URL: https://issues.apache.org/jira/browse/FLINK-19565
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
> Affects Versions: 1.10.2
> Environment: I add {color:#4c9aff}flink-csv-1.10.2.jar{color} & {color:#4c9aff}flink-sql-connector-kafka_2.11-1.11.0.jar {color:#172b4d}to the lib dir. I run the sql below with sql-client:{color}{color}
>
>
>
> _CREATE TABLE kafkaSource (_
> {color:#505f79} _a VARCHAR,_{color}
> {color:#505f79} _b VARCHAR_{color}
> {color:#505f79}_) WITH (_{color}
> {color:#505f79} _'connector' = 'kafka',_{color}
> {color:#505f79} _'topic' = 'source001',_{color}
> {color:#505f79} _'properties.bootstrap.servers' = 'localhost:9092',_{color}
> {color:#505f79} _'properties.group.id' = 'consumer001',_{color}
> {color:#505f79} _'format' = 'csv',_{color}
> {color:#505f79} _'scan.startup.mode' = 'latest-offset'_{color}
> {color:#505f79}_);_{color}
> {color:#505f79}_CREATE TABLE kafkaSink (_{color}
> {color:#505f79} _a VARCHAR,_{color}
> {color:#505f79} _b VARCHAR_{color}
> {color:#505f79}_) WITH (_{color}
> {color:#505f79} _'connector' = 'kafka',_{color}
> {color:#505f79} _'topic' = 'sink001',_{color}
> {color:#505f79} _'properties.bootstrap.servers' = 'localhost:9092',_{color}
> {color:#505f79} _'format' = 'csv'_{color}
> {color:#505f79}_);_{color}
> {color:#505f79}_INSERT INTO kafkaSink_{color}
> {color:#505f79}_SELECT *_{color}
> {color:#505f79}_FROM kafkaSource;_{color}
>
> {color:#172b4d}Then the exception {color}appeared.
> Reporter: yardstrong
> Priority: Trivial
>
> {color:#FF0000}Expcetion information below:{color}
>
> Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
> Caused by: java.lang.RuntimeException: Error running SQL job.
> at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeUpdateInternal$14(LocalExecutor.java:598)
> at org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:255)
> at org.apache.flink.table.client.gateway.local.LocalExecutor.executeUpdateInternal(LocalExecutor.java:592)
> at org.apache.flink.table.client.gateway.local.LocalExecutor.executeUpdate(LocalExecutor.java:515)
> at org.apache.flink.table.client.cli.CliClient.callInsert(CliClient.java:596)
> at org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:315)
> at java.util.Optional.ifPresent(Optional.java:159)
> at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:212)
> at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:142)
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:114)
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
> Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
> at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeUpdateInternal$14(LocalExecutor.java:595)
> ... 10 more
> Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
> at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$7(RestClusterClient.java:366)
> at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
> at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
> at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> at org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:292)
> at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
> at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
> at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Failed to deserialize JobGraph.
> at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$loadJobGraph$2(JobSubmitHandler.java:127)
> at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.ClassCastException: cannot assign instance of java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runtim
> e.jobgraph.JobVertex
> at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2302)
> at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1432)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2371)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2289)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2147)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:482)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:440)
> at java.util.HashMap.readObject(HashMap.java:1412)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1185)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2256)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2147)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646)
> at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2365)
> at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2289)
> at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2147)
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:482)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java:440)
> at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.lambda$loadJobGraph$2(JobSubmitHandler.java:125)
> ... 8 more
> ]
> at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:390)
> at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:374)
> at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966)
> at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
> ... 4 more
--
This message was sent by Atlassian Jira
(v8.3.4#803005)