You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@drill.apache.org by "Cong Luo (Jira)" <ji...@apache.org> on 2022/06/28 10:43:00 UTC

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

|  ![](cid:jira-generated-image-avatar-d00e4188-6cd8-41e7-9312-8476ff41929b) |
[Cong Luo](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=luoc)
**created** an issue  
---|---  
|  
---  
|  [Apache Drill](https://issues.apache.org/jira/browse/DRILL) /
[![Improvement](cid:jira-generated-image-avatar-
fed108b3-7657-4bf9-835f-3e7eecd065cf)](https://issues.apache.org/jira/browse/DRILL-8253)
[DRILL-8253](https://issues.apache.org/jira/browse/DRILL-8253)  
---  
[Support the limit results in kafka
scan](https://issues.apache.org/jira/browse/DRILL-8253)  
| Issue Type: |  ![Improvement](cid:jira-generated-image-avatar-
fed108b3-7657-4bf9-835f-3e7eecd065cf) Improvement  
---|---  
Assignee: |  [Cong
Luo](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=luoc)  
Components: |  Storage - Kafka  
Created: |  28/Jun/22 10:42  
Fix Versions: |  1.20.2  
Priority: |  ![Major](cid:jira-generated-image-static-
major-7ef48d89-2866-411a-88b6-c8960393fe1e) Major  
Reporter: |  [Cong
Luo](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=luoc)  
|

In the current implementation of the kafka storage, although we use the limit
detection method in the result loader, but the actual **maxRecords** is always
-1.  
  
---  
|  |  [ ![Add Comment](cid:jira-generated-image-static-comment-
icon-0bd6d4d9-5687-45f9-a11d-d1bd4b1e3d9a)
](https://issues.apache.org/jira/browse/DRILL-8253#add-comment "Add Comment")
|  [Add Comment](https://issues.apache.org/jira/browse/DRILL-8253#add-comment
"Add Comment")  
---|---  
  
|  This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9) |  |
![Atlassian logo](https://issues.apache.org/jira/images/mail/atlassian-email-
logo.png)  
---