[ https://issues.apache.org/jira/browse/FLINK-26863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee updated FLINK-26863: --------------------------------- Parent: FLINK-26653 Issue Type: Sub-task (was: Bug) > Filter predicate does not work > ------------------------------ > > Key: FLINK-26863 > URL: https://issues.apache.org/jira/browse/FLINK-26863 > Project: Flink > Issue Type: Sub-task > Components: Table Store > Affects Versions: 0.1.0 > Reporter: Jane Chan > Assignee: Jane Chan > Priority: Blocker > Labels: pull-request-available > Fix For: table-store-0.1.0 > > > {code:java} > Caused by: java.lang.RuntimeException: Failed to fetch next result > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109) > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:219) > at > org.apache.flink.table.store.file.utils.BlockingIterator.doCollect(BlockingIterator.java:94) > at > org.apache.flink.table.store.file.utils.BlockingIterator.lambda$collect$1(BlockingIterator.java:76) > at > java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264) > at java.base/java.util.concurrent.FutureTask.run(FutureTask.java) > at > java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > at > java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > at java.base/java.lang.Thread.run(Thread.java:834) > Caused by: java.io.IOException: Failed to fetch job execution result > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184) > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121) > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > ... 9 more > Caused by: java.util.concurrent.ExecutionException: > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > at > java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) > at > java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2022) > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182) > ... 11 more > Caused by: org.apache.flink.runtime.client.JobExecutionException: Job > execution failed. > at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141) > at > java.base/java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:680) > at > java.base/java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:658) > at > java.base/java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2094) > at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:138) > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181) > ... 11 more > Caused by: org.apache.flink.runtime.client.JobInitializationException: Could > not start the JobMaster. > at > org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) > at > java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) > at > java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) > at > java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) > at > java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run$$$capture(CompletableFuture.java:1705) > at > java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java) > ... 3 more > Caused by: java.util.concurrent.CompletionException: > java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot > instantiate the coordinator for operator Source: > managed_table_0fbb07bd-5474-4dbb-b2bf-382e075d2a23[3] -> Calc[4] -> > ConstraintEnforcer[5] > at > java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314) > at > java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319) > at > java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run$$$capture(CompletableFuture.java:1702) > ... 4 more > Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: > Cannot instantiate the coordinator for operator Source: > managed_table_0fbb07bd-5474-4dbb-b2bf-382e075d2a23[3] -> Calc[4] -> > ConstraintEnforcer[5] > at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:319) > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) > at > java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run$$$capture(CompletableFuture.java:1700) > ... 4 more > Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the > coordinator for operator Source: > managed_table_0fbb07bd-5474-4dbb-b2bf-382e075d2a23[3] -> Calc[4] -> > ConstraintEnforcer[5] > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:229) > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:849) > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:839) > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:798) > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:780) > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:194) > at > org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:149) > at > org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:363) > at > org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:208) > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:191) > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:139) > at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:135) > at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:115) > at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:345) > at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:322) > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106) > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94) > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > ... 5 more > Caused by: java.lang.NullPointerException > at > org.apache.flink.table.runtime.typeutils.InternalSerializers.createInternal(InternalSerializers.java:67) > at > org.apache.flink.table.runtime.typeutils.InternalSerializers.create(InternalSerializers.java:55) > at > org.apache.flink.table.store.file.predicate.Literal.readObject(Literal.java:74) > at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.base/java.lang.reflect.Method.invoke(Method.java:566) > at > java.base/java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1175) > at > java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2273) > at > java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2144) > at > java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646) > at > java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2412) > at > java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2306) > at > java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2144) > at > java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646) > at > java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2412) > at > java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2306) > at > java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2144) > at > java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646) > at > java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2412) > at > java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2306) > at > java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2144) > at > java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1646) > at > java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:464) > at > java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:422) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:617) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:602) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:589) > at > org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67) > at > org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:433) > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:223) > ... 22 more {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)