kafka jdbc connect timestamp issue

93 views
Skip to first unread message

Shannon Ma

unread,
Oct 11, 2016, 10:30:54 PM10/11/16
to Confluent Platform
Hi, 

I noticed from the log


22:19| DEBUG | TimestampIncrementingTableQuerier.java 171 | Executing prepared statement with timestamp value = null (1970-01-01 00:00:00.000)  end time 2016-10-12 02:19:53.804


 WHERE "SAMPLE_TIME" > ? AND "SAMPLE_TIME" < ? ORDER BY "SAMPLE_TIME" ASC


does that mean the time range in the inputs are (1970 to 2016), what did i miss? what should be the start time?

Thanks
Shannon

Ryan Pridgeon

unread,
Oct 12, 2016, 4:59:45 AM10/12/16
to confluent...@googlegroups.com
This to me just sounds like it's the first time you have executed the query and as such there is no initial offset to start from. I say this because 1970-01-01 00:00:00.000 represents the Epoch for the java Calendar class. The end time just represents the current time on the target database as represented as a UTC Calendar date. 

Ryan
  


--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent-platform@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/74115469-a3ea-4451-a329-cde7dee36878%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Shannon Ma

unread,
Oct 12, 2016, 11:04:46 AM10/12/16
to Confluent Platform
Correct, is there a setting so that it will only pull the latest, so the first time it will do anything but set the current time as the offset, then the next time it will pick up anything > last off set?

Thanks
Shanon


On Wednesday, October 12, 2016 at 3:59:45 AM UTC-5, Ryan Pridgeon wrote:
This to me just sounds like it's the first time you have executed the query and as such there is no initial offset to start from. I say this because 1970-01-01 00:00:00.000 represents the Epoch for the java Calendar class. The end time just represents the current time on the target database as represented as a UTC Calendar date. 

Ryan
  

On Tue, Oct 11, 2016 at 10:30 PM, Shannon Ma <shan...@gmail.com> wrote:
Hi, 

I noticed from the log


22:19| DEBUG | TimestampIncrementingTableQuerier.java 171 | Executing prepared statement with timestamp value = null (1970-01-01 00:00:00.000)  end time 2016-10-12 02:19:53.804


 WHERE "SAMPLE_TIME" > ? AND "SAMPLE_TIME" < ? ORDER BY "SAMPLE_TIME" ASC


does that mean the time range in the inputs are (1970 to 2016), what did i miss? what should be the start time?

Thanks
Shannon

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Reply all
Reply to author
Forward
0 new messages