[jira] [Commented] (DRILL-8253) Support the limit results in kafka scan

[ASF GitHub Bot (Jira)]

Title: Message Title

ASF GitHub Bot commented on DRILL-8253   Re: Support the limit results in kafka scan luocooong commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908438074 ########## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ########## @@ -262,6 +269,17 @@ public void applyAssignments(List<DrillbitEndpoint> incomingEndpoints) { assignments = AssignmentCreator.getMappings(incomingEndpoints, Lists.newArrayList(partitionWorkMap.values())); } + @Override + public GroupScan applyLimit(int maxRecords) { + records = maxRecords; // Just apply the limit value into sub-scan + return super.applyLimit(maxRecords); + } + Review Comment: Yes, I'm just call this parent interface that returns null (As long as the default behavior is not broken), because I just need to get the limit value from the execution plan. Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)