[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644379#comment-17644379
]
Matthias Pohl commented on FLINK-30313:
---
Thanks for looking into it. It might be worth it responding in the SO thread
since it appears that there were two users running into the same problem.
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Assignee: Márton Balassi
>Priority: Critical
> Fix For: kubernetes-operator-1.3.0
>
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644356#comment-17644356
]
Márton Balassi commented on FLINK-30313:
The operator depends on 1.15.3 of flink-core:
{code:java}
% mvn dependency:tree | grep flink-core
[INFO] | +- org.apache.flink:flink-core:jar:1.15.3:provided
[INFO] +- org.apache.flink:flink-core:jar:1.15.3:compile
[INFO] +- org.apache.flink:flink-core:jar:1.15.3:compile
[INFO] | +- org.apache.flink:flink-core:test-jar:tests:1.15.3:test
[INFO] | +- org.apache.flink:flink-core:jar:1.15.3:provided
[INFO] | +- org.apache.flink:flink-core:jar:1.15.3:provided
[INFO] | +- org.apache.flink:flink-core:jar:1.15.3:provided
[INFO] +- org.apache.flink:flink-core:jar:1.15.3:compile
{code}
That still has this config option:
[https://github.com/apache/flink/blob/release-1.15/flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java#L229]
1.16 removes it via this:
[https://github.com/apache/flink/pull/19438/files#diff-3cf7dccc898a0b78b70f65ad51019e44d0221bc59aa9918d21260fd9c883d2b2L220-L238]
I did not have the bandwidth to try to reproduce it yet, [~gaborgsomogyi]
please take a look.
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Priority: Critical
> Fix For: kubernetes-operator-1.3.0
>
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644308#comment-17644308
]
Matthias Pohl commented on FLINK-30313:
---
Ok, thanks for clarification. I couldn't find any hints in the k8s operator
code, either. The `affectedVersion` in this ticket was just a guess based on
the Flink versions being involved. I asked the SO user to share more context in
this ticket about this issue.
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Priority: Critical
> Fix For: kubernetes-operator-1.3.0
>
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644306#comment-17644306
]
Gyula Fora commented on FLINK-30313:
[~mapohl] coild you reproduce this locally?
maybe you could do a mvn dependency:tree check to see if there are any unwanted
1.16 deps .
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Priority: Major
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644302#comment-17644302
]
Gyula Fora commented on FLINK-30313:
At this point operator should not contain any 1.16 dependencies on the
classpath so I don’t see how this error may occur. Especially not the 1.2.0
version which was released before Flink 1.16.0 I think.
could something in the user image cause this problem?
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Priority: Major
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643895#comment-17643895
]
Matthias Pohl commented on FLINK-30313:
---
Thanks for the pointer [~mbalassi_impala_2d74]. Can you elaborate a bit more
how FLINK-30222 fixes this Jira issue? AFAIU, FLINK-30222 is about supporting
the newly introduced {{kubernetes}} label to load k8s HA services. This Jira
issue, though, is about different Flink modules ({{flink-core}} providing
{{HighAvailabilityOptions.USE_OLD_HA_SERVICES}} and {{flink-kubernetes}} trying
to access this field through {{KubernetesHaServicesFactory}}) being based on
different Flink versions. Based on the error message, it appears that we have
{{flink-core:1.16.0}} and {{flink-kubernetes:1.15.x}} on the classpath.
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Priority: Major
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code
[
https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643882#comment-17643882
]
Márton Balassi commented on FLINK-30313:
Imho FLINK-30222 solves this, [~mapohl] please confirm.
> Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config
> code
>
>
> Key: FLINK-30313
> URL: https://issues.apache.org/jira/browse/FLINK-30313
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
>Affects Versions: kubernetes-operator-1.2.0
>Reporter: Matthias Pohl
>Priority: Major
>
> Based on [this SO
> post|https://stackoverflow.com/questions/74599009/flink1-16-high-availability-job-manager],
> it looks like there can be a setup where we use different versions of Flink:
> {code}
> 2022-11-28 08:57:56.032 [main] INFO
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Shutting
> KubernetesApplicationClusterEntrypoint down with application status FAILED.
> Diagnostics java.lang.NoSuchFieldError: USE_OLD_HA_SERVICES
> at
> org.apache.flink.kubernetes.highavailability.KubernetesHaServicesFactory.createHAServices(KubernetesHaServicesFactory.java:37)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createCustomHAServices(HighAvailabilityServicesUtils.java:296)
> at
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:139)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:439)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:382)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232)
> at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229)
> at
> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729)
> at
> org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86)
> {code}
> This field was removed in FLINK-25806 with Flink 1.16. I'd guess that it's
> caused by the Flink operator still depending on Flink 1.15.x whilest there is
> an option to use Flink 1.16 for deployments already.
> Another SO user mentioned:
> {quote}
> I have the same issue with flink-kubernetes-operator. This field
> NoSuchFieldError: USE_OLD_HA_SERVICES was removed in flink 1.16, but error
> occurs with setting: flinkVersion: v1_15
> {quote}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
