e2e 2 stage: PyFlink end-to-end test

 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