[jira] [Commented] (HUDI-292) Consume more entries from kafka than specified sourceLimit.

2019-10-08 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/HUDI-292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947005#comment-16947005 ] Vinoth Chandar commented on HUDI-292: - sg. thanks for being awesome [~xleesf] :) > Consume more

[jira] [Commented] (HUDI-292) Consume more entries from kafka than specified sourceLimit.

2019-10-07 Thread leesf (Jira)
[ https://issues.apache.org/jira/browse/HUDI-292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946383#comment-16946383 ] leesf commented on HUDI-292: `long toOffset = Math.min(toOffsetMax, range.untilOffset() +

[jira] [Commented] (HUDI-292) Consume more entries from kafka than specified sourceLimit.

2019-10-07 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/HUDI-292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945994#comment-16945994 ] Vinoth Chandar commented on HUDI-292: - is it because `long toOffset = Math.min(toOffsetMax,