From 793dd910fc17b0e149f4b554b54cad55ca5bc479 Mon Sep 17 00:00:00 2001 From: liuchangqing Date: Thu, 6 Jan 2022 13:19:24 +0800 Subject: [PATCH] Fix time field use error (#12249) * Fix time field use error * rebuid Co-authored-by: liu.changqing --- .../java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java index 99be9f969d6cd..d839e05def76f 100644 --- a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java +++ b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java @@ -580,7 +580,7 @@ public boolean advanceNextPosition() { currentRowValuesMap.put(columnHandle, longValueProvider(this.partition)); } else if (PulsarInternalColumn.EVENT_TIME.getName().equals(columnHandle.getName())) { currentRowValuesMap.put(columnHandle, PulsarFieldValueProviders.timeValueProvider( - this.currentMessage.getEventTime(), this.currentMessage.getPublishTime() == 0)); + this.currentMessage.getEventTime(), this.currentMessage.getEventTime() == 0)); } else if (PulsarInternalColumn.PUBLISH_TIME.getName().equals(columnHandle.getName())) { currentRowValuesMap.put(columnHandle, PulsarFieldValueProviders.timeValueProvider( this.currentMessage.getPublishTime(), this.currentMessage.getPublishTime() == 0));