[
https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128313#comment-17128313
]
Robert Metzger edited comment on FLINK-17976 at 6/8/20, 6:31 PM:
-----------------------------------------------------------------
Testing protocol:
- start k8s in Google Cloud
- observed this error (only once, not reproducible)
{code}
io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: GET
at: https://35.205.14.250/api/v1/namespaces/default/services/rob-test0-rest.
Message: Unauthorized! Token may have expired! Please log-in again.
Unauthorized.
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.requestFailure(OperationSupport.java:568)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.assertResponseCode(OperationSupport.java:505)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:471)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:430)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:395)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:376)
at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleGet(BaseOperation.java:845)
at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:214)
at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:168)
at
org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getRestService(Fabric8FlinkKubeClient.java:202)
at
org.apache.flink.kubernetes.cli.KubernetesSessionCli.run(KubernetesSessionCli.java:105)
at
org.apache.flink.kubernetes.cli.KubernetesSessionCli.lambda$main$0(KubernetesSessionCli.java:188)
at
org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at
org.apache.flink.kubernetes.cli.KubernetesSessionCli.main(KubernetesSessionCli.java:188)
{code}
(See also FLINK-15798!)
- job submission works
- sql client connection works with some hacks (executor: kubernetes-session +
kubernetes.cluster-id configured)
- I see "{{Warning FailedMount 3m24s kubelet,
gke-flink-native-k8s-tes-default-pool-32b2a697-fsj6 MountVolume.SetUp failed
for volume "flink-config-volume" : configmap "flink-config-rob-test0" not
found}}" as an error from describe pods, but no impact yet.
- running wordcount reading data from GCS
was (Author: rmetzger):
Testing protocol:
- start k8s in Google Cloud
- observed this error (only once, not reproducible)
{code}
io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: GET
at: https://35.205.14.250/api/v1/namespaces/default/services/rob-test0-rest.
Message: Unauthorized! Token may have expired! Please log-in again.
Unauthorized.
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.requestFailure(OperationSupport.java:568)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.assertResponseCode(OperationSupport.java:505)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:471)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleResponse(OperationSupport.java:430)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:395)
at
io.fabric8.kubernetes.client.dsl.base.OperationSupport.handleGet(OperationSupport.java:376)
at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.handleGet(BaseOperation.java:845)
at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.getMandatory(BaseOperation.java:214)
at
io.fabric8.kubernetes.client.dsl.base.BaseOperation.get(BaseOperation.java:168)
at
org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient.getRestService(Fabric8FlinkKubeClient.java:202)
at
org.apache.flink.kubernetes.cli.KubernetesSessionCli.run(KubernetesSessionCli.java:105)
at
org.apache.flink.kubernetes.cli.KubernetesSessionCli.lambda$main$0(KubernetesSessionCli.java:188)
at
org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at
org.apache.flink.kubernetes.cli.KubernetesSessionCli.main(KubernetesSessionCli.java:188)
{code}
(See also FLINK-15798!)
- job submission works
- sql client connection works with some hacks (executor: kubernetes-session +
kubernetes.cluster-id configured)
- I see {{Warning FailedMount 3m24s kubelet,
gke-flink-native-k8s-tes-default-pool-32b2a697-fsj6 MountVolume.SetUp failed
for volume "flink-config-volume" : configmap "flink-config-rob-test0" not
found}} as an error from describe pods.
> Test native K8s integration
> ---------------------------
>
> Key: FLINK-17976
> URL: https://issues.apache.org/jira/browse/FLINK-17976
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Affects Versions: 1.11.0
> Reporter: Till Rohrmann
> Assignee: Robert Metzger
> Priority: Critical
> Labels: release-testing
> Fix For: 1.11.0
>
>
> Test Flink's native K8s integration:
> * session mode
> * application mode
> * custom Flink image
> * custom configuration and log properties
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
