[
https://issues.apache.org/jira/browse/FLINK-18448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161181#comment-17161181
]
Robert Metzger commented on FLINK-18448:
----------------------------------------
Thanks a lot for opening this ticket. I've assigned you to it.
I'm trying to understand the implications for existing Flink PubSub connector
users.
The connector won't work anymore, if they are defining a lower BOM version in
their project (which they would only do if they are using other Google Cloud
dependencies in their project), right?
> 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
> Assignee: Niels Basjes
> Priority: Major
> Labels: pull-request-available
>
> 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)
