You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2020/07/23 15:23:30 UTC
[flink] branch master updated (da210e0 -> fdcaa46)

This is an automated email from the ASF dual-hosted git repository.

rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from da210e0  [FLINK-18421][checkpointing][tests] Fix logging of RejectedExecutionException during CheckpointCoordinator shutdown
     add fdcaa46  [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

No new revisions were added by this update.

Summary of changes:
 docs/dev/connectors/pubsub.md                      |   2 +-
 docs/dev/connectors/pubsub.zh.md                   |   2 +-
 .../flink-connector-gcp-pubsub/pom.xml             |  30 +--
 .../gcp/pubsub/DefaultPubSubSubscriberFactory.java |   1 -
 .../connectors/gcp/pubsub/PubSubSink.java          |  39 +++-
 .../connectors/gcp/pubsub/PubSubSource.java        |   7 +-
 .../gcp/pubsub/common/AcknowledgeOnCheckpoint.java |   6 +-
 .../gcp/pubsub/emulator/EmulatorCredentials.java   |  62 ++++++
 .../emulator/EmulatorCredentialsProvider.java      |  32 ++--
 .../PubSubSubscriberFactoryForEmulator.java        |   4 +-
 .../connectors/gcp/pubsub/PubSubConsumingTest.java |   5 +-
 .../connectors/gcp/pubsub/PubSubSourceTest.java    |   4 +-
 .../pubsub/common/AcknowledgeOnCheckpointTest.java |  12 +-
 .../pom.xml                                        |  13 +-
 .../gcp/pubsub/EmulatedFullTopologyTest.java       | 209 +++++++++++++++++++++
 .../gcp/pubsub/EmulatedPubSubSinkTest.java         |  11 +-
 .../gcp/pubsub/EmulatedPubSubSourceTest.java       |  80 ++++----
 .../SimpleStringSchemaWithStopMarkerDetection.java |  27 ++-
 .../gcp/pubsub/emulator/GCloudUnitTestBase.java    |   2 +-
 .../gcp/pubsub/emulator/PubsubHelper.java          |  24 ++-
 .../examples/gcp/pubsub/PubSubPublisher.java       |   4 +-
 21 files changed, 433 insertions(+), 143 deletions(-)
 create mode 100644 flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/emulator/EmulatorCredentials.java
 copy flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateDataTransfer.java => flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/emulator/EmulatorCredentialsProvider.java (54%)
 rename flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/{ => emulator}/PubSubSubscriberFactoryForEmulator.java (94%)
 create mode 100644 flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/EmulatedFullTopologyTest.java
 copy flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java => flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/SimpleStringSchemaWithStopMarkerDetection.java (50%)