Replies: 2 comments 1 reply
-
已解决~~~但不知道为什么要这样设置 |
Beta Was this translation helpful? Give feedback.
1 reply
-
这是来自兰州大学-信息学院-马月宾的自动回复邮件。您好,我已经收到您的邮件,我会在最短的时间内回复您,谢谢~
|
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
单节点部署时是没问题的,现在改成集群部署却失败了!!麻烦帮忙解答一下吧,多谢
Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: TableSourceScan(table=[[default_catalog, default_database, post]], fields=[PostId, ProjectId, Name, Describe, Category, WorkNature, SalaryType, RecruitNumber, Status, Share, RegionId, Address, Lat, Lng, Department, Education, WorkTime, MinSalary, MaxSalary, Salary, Money, Tags, Highlights, Welfare, UpdatedTime, CreatedTime]) -> Calc(select=[PostId, ProjectId, Name])
at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.(ExecutionJobVertex.java:217) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at
org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.SchedulerBase.(SchedulerBase.java:191) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.DefaultScheduler.(DefaultScheduler.java:140) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
at org.apache.flink.runtime.jobmaster.JobMaster.(JobMaster.java:323) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
Beta Was this translation helpful? Give feedback.
All reactions