Fix following testing, add instructions for uploading

GoogleCloudPlatform · Mar 24, 2021 · ac2dd81 · ac2dd81
1 parent 320fe25
commit ac2dd81
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/sql-streaming-copier/README.md b/sql-streaming-copier/README.md
@@ -125,4 +125,3 @@ gcloud dataflow flex-template build $TEMPLATE_PATH \
     --env FLEX_TEMPLATE_JAVA_MAIN_CLASS="com.google.cloud.pubsub.sql.TemplateMain"
 ```
 
-
diff --git a/...eaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java b/...eaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java
@@ -36,7 +36,7 @@ public StandardSource getSource() {
     return new StandardSqlSource() {
       @Override
       public String query() {
-        return "SELECT payload, message_key, attributes, IFNULL(event_timestamp, publish_timestamp) FROM PCOLLECTION";
+        return "SELECT payload, message_key, attributes, IFNULL(event_timestamp, publish_timestamp) AS event_timestamp FROM PCOLLECTION";
       }
 
       @Override
Original file line number	Diff line number	Diff line change
Expand Up		@@ -125,4 +125,3 @@ gcloud dataflow flex-template build $TEMPLATE_PATH \
		--env FLEX_TEMPLATE_JAVA_MAIN_CLASS="com.google.cloud.pubsub.sql.TemplateMain"
		```