[hotfix][pubsub] Use TestLogger

is · Jun 8, 2020 · a08061b · a08061b
1 parent 3952bfa
commit a08061b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml b/flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml
@@ -82,7 +82,12 @@ under the License.
  <type>test-jar</type>
  <scope>test</scope>
  </dependency>
- </dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-test-utils-junit</artifactId>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
 
  <!-- ONLY run the tests when explicitly told to do so -->
  <properties>

diff --git a/...st/java/org/apache/flink/streaming/connectors/gcp/pubsub/emulator/GCloudUnitTestBase.java b/...st/java/org/apache/flink/streaming/connectors/gcp/pubsub/emulator/GCloudUnitTestBase.java
@@ -17,6 +17,8 @@
 
 package org.apache.flink.streaming.connectors.gcp.pubsub.emulator;
 
+import org.apache.flink.util.TestLogger;
+
 import com.google.api.gax.grpc.GrpcTransportChannel;
 import com.google.api.gax.rpc.FixedTransportChannelProvider;
 import com.google.api.gax.rpc.TransportChannelProvider;
@@ -36,7 +38,7 @@
 /**
  * The base class from which unit tests should inherit if they need to use the Google cloud emulators.
  */
-public class GCloudUnitTestBase implements Serializable {
+public class GCloudUnitTestBase extends TestLogger implements Serializable {
  @BeforeClass
  public static void launchGCloudEmulator() throws Exception {
  // Separated out into separate class so the entire test class to be serializable