[
https://issues.apache.org/jira/browse/FLINK-36616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-36616:
---------------------------------------
Assignee: Radosław Stankiewicz
> 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)
