[ https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dian Fu closed FLINK-31503. --------------------------- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fixed Fixed in: - master via de258f3ce01e720d23bec67c20892133f89293d3 - release-1.17 via 3163b8f9caa53e9487ce062eba2c3d399dfe08a2 - release-1.16 via d438b3bdc48a0456088594700d438725d0fb1480 > "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider > org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype" is > thrown when executing Python UDFs in SQL Client > ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-31503 > URL: https://issues.apache.org/jira/browse/FLINK-31503 > Project: Flink > Issue Type: Bug > Components: API / Python > Reporter: Dian Fu > Assignee: Dian Fu > Priority: Major > Labels: pull-request-available > Fix For: 1.16.2, 1.18.0, 1.17.1 > > > The following exception will be thrown when executing SQL statements > containing Python UDFs in SQL Client: > {code} > Caused by: java.util.ServiceConfigurationError: > org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider > org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a subtype > at java.util.ServiceLoader.fail(ServiceLoader.java:239) > at java.util.ServiceLoader.access$300(ServiceLoader.java:185) > at > java.util.ServiceLoader$LazyIterator.nextService(ServiceLoader.java:376) > at java.util.ServiceLoader$LazyIterator.next(ServiceLoader.java:404) > at java.util.ServiceLoader$1.next(ServiceLoader.java:480) > at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableCollection$Builder.addAll(ImmutableCollection.java:415) > at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableSet$Builder.addAll(ImmutableSet.java:507) > at > org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableSortedSet$Builder.addAll(ImmutableSortedSet.java:528) > at > org.apache.beam.sdk.util.common.ReflectHelpers.loadServicesOrdered(ReflectHelpers.java:199) > at > org.apache.beam.sdk.options.PipelineOptionsFactory$Cache.initializeRegistry(PipelineOptionsFactory.java:2089) > at > org.apache.beam.sdk.options.PipelineOptionsFactory$Cache.<init>(PipelineOptionsFactory.java:2083) > at > org.apache.beam.sdk.options.PipelineOptionsFactory$Cache.<init>(PipelineOptionsFactory.java:2047) > at > org.apache.beam.sdk.options.PipelineOptionsFactory.resetCache(PipelineOptionsFactory.java:581) > at > org.apache.beam.sdk.options.PipelineOptionsFactory.<clinit>(PipelineOptionsFactory.java:547) > at > org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.open(BeamPythonFunctionRunner.java:241) > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)