This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 71e85d8 [FLINK-17315][tests] Fix and reenable UnalignedCheckpointITCase. add 63f1d40 [FLINK-17307] Add collector to deserialize method of DeserializationSchema add 0b699b4 [FLINK-17307] Forward call to DeserializationSchema#collect with a collector in KafkaDeserializationSchemaWrapper add de706dd [FLINK-17307] Add collector to deserialize in RMQ add 407ccc8 [FLINK-17307] Check for deserialize method with a Collector in Kinesis consumer add 6119c31 [FLINK-17307] Add collector to deserialize in PubSub No new revisions were added by this update. Summary of changes: .../gcp/pubsub/DeserializationSchemaWrapper.java | 8 +- .../connectors/gcp/pubsub/PubSubSource.java | 42 +++- .../pubsub/common/PubSubDeserializationSchema.java | 18 ++ .../pubsub/DeserializationSchemaWrapperTest.java | 13 +- .../connectors/gcp/pubsub/PubSubConsumingTest.java | 250 +++++++++++++++++++++ .../connectors/gcp/pubsub/PubSubSourceTest.java | 71 ------ .../KafkaDeserializationSchemaWrapper.java | 5 +- .../KinesisDeserializationSchemaWrapper.java | 12 + .../kinesis/FlinkKinesisConsumerTest.java | 5 - .../connectors/kinesis/KinesisConsumerTest.java | 72 ++++++ .../streaming/connectors/rabbitmq/RMQSource.java | 44 +++- .../serialization/DeserializationSchema.java | 19 ++ 12 files changed, 459 insertions(+), 100 deletions(-) create mode 100644 flink-connectors/flink-connector-gcp-pubsub/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubConsumingTest.java create mode 100644 flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/KinesisConsumerTest.java