fix pom version

googleapis · Jul 16, 2021 · 147800c · 147800c
1 parent a9eb732
commit 147800c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -114,7 +114,7 @@
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-connector-test-utils</artifactId>
-            <version>1.13-SNAPSHOT</version>
+            <version>1.13.0</version>
             <scope>test</scope>
         </dependency>
     </dependencies>

diff --git a/src/main/java/com/google/cloud/pubsublite/flink/reader/PubsubLiteRecordEmitter.java b/src/main/java/com/google/cloud/pubsublite/flink/reader/PubsubLiteRecordEmitter.java
@@ -27,7 +27,7 @@ public void emitRecord(
       SourceOutput<T> sourceOutput,
       SubscriptionPartitionSplitState subscriptionPartitionSplitState) {
     if (record.value().isPresent()) {
-      sourceOutput.collect(record.value().get(), record.timestamp());
+      sourceOutput.collect(record.value().get(), record.timestamp().toEpochMilli());
     }
     subscriptionPartitionSplitState.setCurrent(record.offset());
   }