[GitHub] [drill] luocooong commented on a diff in pull request #2580: DRILL-8253: Support Limit Results in Kafka Scan

luocooong commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908637682 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -271,8 +292,11 @@ public void applyAssignments(List incomingEndpoint

[GitHub] [drill] cgivre commented on a diff in pull request #2580: DRILL-8253: Support the limit results in kafka scan

cgivre commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908624673 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -271,8 +292,11 @@ public void applyAssignments(List incomingEndpoints)

[GitHub] [drill] luocooong commented on a diff in pull request #2580: DRILL-8253: Support the limit results in kafka scan

luocooong commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908624939 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -262,6 +269,17 @@ public void applyAssignments(List incomingEndpoint

[GitHub] [drill] kingswanwho opened a new pull request, #2581: DRILL-8254: upgrade mysql-connectors-java to 8.0.28 due to CVE-2022-21363

kingswanwho opened a new pull request, #2581: URL: https://github.com/apache/drill/pull/2581 # [DRILL-8254](https://issues.apache.org/jira/browse/DRILL-8254): upgrade mysql-connectors-java to 8.0.28 due to CVE-2022-21363 ## Description Upgrade mysql-connectors-java to 8.0.28 due to

[GitHub] [drill] cgivre commented on a diff in pull request #2580: DRILL-8253: Support the limit results in kafka scan

cgivre commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908569894 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -262,6 +269,17 @@ public void applyAssignments(List incomingEndpoints)

[GitHub] [drill] luocooong commented on a diff in pull request #2580: DRILL-8253: Support the limit results in kafka scan

luocooong commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908439009 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -359,7 +382,7 @@ public KafkaStoragePlugin getStoragePlugin() {

[GitHub] [drill] luocooong commented on a diff in pull request #2580: DRILL-8253: Support the limit results in kafka scan

luocooong commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908438483 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -77,6 +77,7 @@ public class KafkaGroupScan extends AbstractGroupScan

[GitHub] [drill] luocooong commented on a diff in pull request #2580: DRILL-8253: 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 incomingEndpoint

[GitHub] [drill] cgivre commented on a diff in pull request #2580: DRILL-8253: Support the limit results in kafka scan

cgivre commented on code in PR #2580: URL: https://github.com/apache/drill/pull/2580#discussion_r908416571 ## contrib/storage-kafka/src/main/java/org/apache/drill/exec/store/kafka/KafkaGroupScan.java: ## @@ -262,6 +269,17 @@ public void applyAssignments(List incomingEndpoints)

[GitHub] [drill] luocooong opened a new pull request, #2580: DRILL-8253: Support the limit results in kafka scan

luocooong opened a new pull request, #2580: URL: https://github.com/apache/drill/pull/2580 # [DRILL-8253](https://issues.apache.org/jira/browse/DRILL-8253): Support the limit results in kafka scan ## Description In the current implementation of the kafka storage, although we use th

[GitHub] [drill] kingswanwho opened a new pull request, #2579: [Minor Update] Add port number in log file for maintenance convenience

kingswanwho opened a new pull request, #2579: URL: https://github.com/apache/drill/pull/2579 # [Minor Update] Add port number in log for maintenance convenience Add Drillbit http port in log file, for find the port number easily. -- This is an automated message from the Apache G