You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/05/12 20:16:58 UTC
[flink] branch master updated (71e85d8 -> 6119c31)
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