[
https://issues.apache.org/jira/browse/FLINK-36616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894350#comment-17894350
]
Sergey Nuyanzin commented on FLINK-36616:
-----------------------------------------
Merged as
[951ce2f171a6d19ceaad534f1977fa47def1b9f7|https://github.com/apache/flink-connector-gcp-pubsub/commit/951ce2f171a6d19ceaad534f1977fa47def1b9f7]
> Null pointer in PubSub's GcpPublisherConfig
> --------------------------------------------
>
> Key: FLINK-36616
> URL: https://issues.apache.org/jira/browse/FLINK-36616
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Google Cloud PubSub
> Reporter: Radosław Stankiewicz
> Assignee: Radosław Stankiewicz
> Priority: Minor
> Labels: pull-request-available
>
> With current implementation PubSubSinkV2 throws NPE due to
> transportChannelProvider being null.
> context: transportChannelProvider is mostly used for testing.
>
> steps to reproduce:
> 1/ GcpPublisherConfig gcpPublisherConfig =
> GcpPublisherConfig.{_}builder{_}()
> .setCredentialsProvider(new SerializableCredentialsProvider())
> .build();
> builder.setProjectId("test-project-id")
> .setTopicId("test-topic-id")
> .setGcpPublisherConfig(gcpPublisherConfig)
> .setSerializationSchema(serializationSchema)
> .setNumMaxInflightRequests(10)
> .setFailOnError(true);
> PubSubSinkV2<String> sink = builder.build();
>
> 2/ run
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
