[
https://issues.apache.org/jira/browse/FLINK-18448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147844#comment-17147844
]
Niels Basjes commented on FLINK-18448:
--------------------------------------
This problem is triggered by the removal of the deprecated method
io.grpc.ManagedChannelBuilder.usePlaintext(boolean) method (deprecated since
1.11.0) in grpc version 1.26.0
https://github.com/grpc/grpc-java/releases/tag/v1.11.0
https://github.com/grpc/grpc-java/releases/tag/v1.26.0
> Update Google Cloud PubSub dependencies
> ---------------------------------------
>
> Key: FLINK-18448
> URL: https://issues.apache.org/jira/browse/FLINK-18448
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Google Cloud PubSub
> Reporter: Niels Basjes
> Priority: Major
>
> While working on a project that uses the PubSub connector I found that Google
> has changed some methods in their API in such a way that it is no longer
> backwards compatible while doing local unit tests.
> I got this error when using their 0.130.0 BOM dependency in my project:
> {code}12:10:14,774 [INFO ] ExecutionGraph : 1554:
> Source: Custom Source -> Map -> Sink: Unnamed (4/8)
> (5207874dfde44474a75867cfe8353190) switched from RUNNING to FAILED.
> java.lang.NoSuchMethodError:
> io.grpc.ManagedChannelBuilder.usePlaintext(Z)Lio/grpc/ManagedChannelBuilder;
> at
> org.apache.flink.streaming.connectors.gcp.pubsub.PubSubSink.open(PubSubSink.java:104)
> at
> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
> at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
> at
> org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:990)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:453)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:448)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:460)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:533)
> at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
