Skip to content

使用KubernetesApplication模式部署flink job 执行stop之后无法通过保存的savepoint恢复job任务 #464

@baisui1981

Description

@baisui1981

执行 通过保存的savepoint恢复job任务 报如下异常日志:

Caused by: java.lang.RuntimeException: com.qlangtech.tis.lang.TisException: ClusterRetrieveException: Could not get the rest endpoint of tis-flink-cluster-1
        at com.qlangtech.tis.datax.job.ServerLaunchToken.writeLaunchToken(ServerLaunchToken.java:446)
        at com.qlangtech.tis.coredefine.module.action.LaunchIncrSyncChannel.lambda$executeLaunch$2(LaunchIncrSyncChannel.java:94)
        at com.qlangtech.tis.datax.job.DefaultSSERunnable.execute(DefaultSSERunnable.java:102)
        at com.qlangtech.tis.coredefine.module.action.LaunchIncrSyncChannel.executeLaunch(LaunchIncrSyncChannel.java:92)
        at com.qlangtech.tis.coredefine.module.action.CoreAction.doRelaunchIncrProcess(CoreAction.java:682)
        ... 164 common frames omitted
Caused by: com.qlangtech.tis.lang.TisException: ClusterRetrieveException: Could not get the rest endpoint of tis-flink-cluster-1
        at com.qlangtech.tis.lang.TisException.create(TisException.java:188)
        at com.qlangtech.plugins.incr.flink.launch.clustertype.ClusterType.checkUseable(ClusterType.java:85)
        at com.qlangtech.plugins.incr.flink.launch.clustertype.KubernetesApplication.checkUseable(KubernetesApplication.java:129)
        at com.qlangtech.plugins.incr.flink.launch.TISFlinkCDCStreamFactory.checkUseable(TISFlinkCDCStreamFactory.java:201)
        at com.qlangtech.tis.coredefine.module.action.TISK8sDelegate.checkUseable(TISK8sDelegate.java:129)
        at com.qlangtech.tis.coredefine.module.action.CoreAction.lambda$getFlinkJobRelaunchOrchestrate$4(CoreAction.java:701)
        at com.qlangtech.tis.datax.job.JobResName$1.accept(JobResName.java:54)
        at com.qlangtech.tis.datax.job.SubJobResName.execute(SubJobResName.java:36)
        at com.qlangtech.tis.datax.job.JobResName.execSubJob(JobResName.java:71)
        at com.qlangtech.tis.coredefine.module.action.LaunchIncrSyncChannel.lambda$executeLaunch$1(LaunchIncrSyncChannel.java:96)
        at com.qlangtech.tis.datax.job.ServerLaunchToken.writeLaunchToken(ServerLaunchToken.java:431)
        ... 168 common frames omitted
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: org.apache.flink.client.deployment.ClusterRetrieveException: Could not get the rest endpoint of tis-flink-cluster-1
        at com.qlangtech.plugins.incr.flink.launch.clustertype.KubernetesApplication.createClient(KubernetesApplication.java:212)
        at com.qlangtech.plugins.incr.flink.launch.clustertype.KubernetesApplication.createRestClusterClient(KubernetesApplication.java:150)
        at com.qlangtech.plugins.incr.flink.launch.clustertype.ClusterType.checkUseable(ClusterType.java:74)
        ... 177 common frames omitted
Caused by: java.lang.RuntimeException: org.apache.flink.client.deployment.ClusterRetrieveException: Could not get the rest endpoint of tis-flink-cluster-1
        at org.apache.flink.kubernetes.KubernetesClusterDescriptor.lambda$createClusterClientProvider$1(KubernetesClusterDescriptor.java:121)
        at org.apache.flink.kubernetes.KubernetesClusterDescriptor.retrieve(KubernetesClusterDescriptor.java:164)
        at com.qlangtech.plugins.incr.flink.launch.clustertype.KubernetesApplication.createClient(KubernetesApplication.java:208)
        ... 179 common frames omitted
Caused by: org.apache.flink.client.deployment.ClusterRetrieveException: Could not get the rest endpoint of tis-flink-cluster-1
        ... 182 common frames omitted
     

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions