[
https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764749#comment-17764749
]
Ryan Skraba commented on FLINK-33018:
-------------------------------------
I don't think this JIRA is necessarily a blocker -- it looks like an error in
the test that shows up as flakiness (as opposed to an error in the connector).
The above PR fixes the test, if anybody wants to take a look!
The "eventual segfault" that I noticed early happens before and after the fix,
and is *very likely* a different error due to the
{{MockStreamingRuntimeContext}} creating and not closing a {{MockEnvironment}}.
We could probably fix this, but it should never occur unless you try and run
one of these tests 100K times! What do you think?
> GCP Pubsub
> PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream
> failed
> --------------------------------------------------------------------------------------------------------
>
> Key: FLINK-33018
> URL: https://issues.apache.org/jira/browse/FLINK-33018
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Google Cloud PubSub
> Affects Versions: gcp-pubsub-3.0.2
> Reporter: Martijn Visser
> Priority: Blocker
> Labels: pull-request-available, stale-blocker
>
> https://github.com/apache/flink-connector-gcp-pubsub/actions/runs/6061318336/job/16446392844#step:13:507
> {code:java}
> [INFO]
> [INFO] Results:
> [INFO]
> Error: Failures:
> Error:
> PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream:119
>
> expected: ["1", "2", "3"]
> but was: ["1", "2"]
> [INFO]
> Error: Tests run: 30, Failures: 1, Errors: 0, Skipped: 0
> [INFO]
> [INFO]
> ------------------------------------------------------------------------
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
