Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/614
---
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/611
---
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/614
SAMZA 1820: Support for all the calcite timestamp functions
The DataContextImpl that we are passing to Calcite supports just the
current_timestamp. This change adds support for all the other time
Few more notes (based on reading a similar thread from few days ago):
- this exception is while initializing offset for the data topic partition
(not samza's checkpoint topic/partition)
- we have manually verified that due to some issue, kafka data-logs have
rolled over and the earliest available o
Hi All,
We are facing identical problem as described in thread
https://www.mail-archive.com/dev@samza.apache.org/msg06740.html
Here - Samza is requesting for an Kafka partition offset that is too old
(i.e Kafka log has moved ahead). We are setting the property
*consumer.auto.offset.reset
to small
