Nov 10 10:22:53 [ERROR] org.apache.flink.connector.firehose.sink.KinesisFirehoseSinkTest.firehoseSinkFailsWhenUnableToConnectToRemoteService Time elapsed: 7.394 s <<< FAILURE!
Nov 10 10:22:53 java.lang.AssertionError:
Nov 10 10:22:53
Nov 10 10:22:53 Expecting throwable message:
Nov 10 10:22:53 "An OperatorEvent from an OperatorCoordinator to a task was lost. Triggering task failover to ensure consistency. Event: '[NoMoreSplitEvent]', targetTask: Source: Sequence Source -> Map -> Map -> Sink: Writer (15/32) - execution #0"
Nov 10 10:22:53 to contain:
Nov 10 10:22:53 "Received an UnknownHostException when attempting to interact with a service."
Nov 10 10:22:53 but did not.