[
https://issues.apache.org/jira/browse/FLINK-33281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-33281.
---------------------------------
Resolution: Cannot Reproduce
The issue didn't reappear for a while. I'm closing it as not-reproducible.
> e2e 2 stage: PyFlink end-to-end test
> ------------------------------------
>
> Key: FLINK-33281
> URL: https://issues.apache.org/jira/browse/FLINK-33281
> Project: Flink
> Issue Type: Sub-task
> Reporter: Matthias Pohl
> Priority: Major
> Labels: github-actions, test-stability
>
> [https://github.com/XComp/flink/actions/runs/6529754573/job/17728244982#step:15:7938]
> {code:java}
> Oct 16 08:02:13 pyflink.util.exceptions.TableException:
> org.apache.flink.table.api.TableException: Failed to execute sql
> 7868Oct 16 08:02:13 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1048)
> 7869Oct 16 08:02:13 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:864)
> 7870Oct 16 08:02:13 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1097)
> 7871Oct 16 08:02:13 at
> org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:59)
> 7872Oct 16 08:02:13 at
> org.apache.flink.table.api.Table.executeInsert(Table.java:1074)
> 7873Oct 16 08:02:13 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 7874Oct 16 08:02:13 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 7875Oct 16 08:02:13 at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 7876Oct 16 08:02:13 at
> java.base/java.lang.reflect.Method.invoke(Method.java:566)
> 7877Oct 16 08:02:13 at
> org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
> 7878Oct 16 08:02:13 at
> org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
> 7879Oct 16 08:02:13 at
> org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
> 7880Oct 16 08:02:13 at
> org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
> 7881Oct 16 08:02:13 at
> org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
> 7882Oct 16 08:02:13 at
> org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
> 7883Oct 16 08:02:13 at java.base/java.lang.Thread.run(Thread.java:829)
> 7884Oct 16 08:02:13 Caused by: org.apache.flink.util.FlinkException: Failed
> to execute job 'insert-into_default_catalog.default_database.Results'.
> 7885Oct 16 08:02:13 at
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253)
> 7886Oct 16 08:02:13 at
> org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:189)
> 7887Oct 16 08:02:13 at
> org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110)
> 7888Oct 16 08:02:13 at
> org.apache.flink.table.executor.python.ChainingOptimizingExecutor.executeAsync(ChainingOptimizingExecutor.java:88)
> 7889Oct 16 08:02:13 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1020)
> 7890Oct 16 08:02:13 ... 15 more
> 7891Oct 16 08:02:13 Caused by:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 7892Oct 16 08:02:13 at
> org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$12(RestClusterClient.java:479)
> 7893Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:986)
> 7894Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:970)
> 7895Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
> 7896Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
> 7897Oct 16 08:02:13 at
> org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:272)
> 7898Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
> 7899Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
> 7900Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
> 7901Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:610)
> 7902Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1085)
> 7903Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
> 7904Oct 16 08:02:13 at
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> 7905Oct 16 08:02:13 at
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> 7906Oct 16 08:02:13 ... 1 more
> 7907Oct 16 08:02:13 Caused by:
> org.apache.flink.runtime.rest.util.RestClientException: [File upload failed.]
> 7908Oct 16 08:02:13 at
> org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:646)
> 7909Oct 16 08:02:13 at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:626)
> 7910Oct 16 08:02:13 at
> java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
> 7911Oct 16 08:02:13 ... 4 more{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
