[GitHub] [pulsar] gaoran10 commented on a change in pull request #9628: [Pulsar SQL] Add max split entry queue size bytes limitation

gaoran10 commented on a change in pull request #9628: URL: https://github.com/apache/pulsar/pull/9628#discussion_r586937758 ## File path: pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java ## @@ -347,8 +355,16 @@ public void run() {

[GitHub] [pulsar] gaoran10 commented on a change in pull request #9628: [Pulsar SQL] Add max split entry queue size bytes limitation

gaoran10 commented on a change in pull request #9628: URL: https://github.com/apache/pulsar/pull/9628#discussion_r586934418 ## File path: pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java ## @@ -222,7 +228,7 @@ public void setPulsarSq

[GitHub] [pulsar] gaoran10 commented on a change in pull request #9628: [Pulsar SQL] Add max split entry queue size bytes limitation

gaoran10 commented on a change in pull request #9628: URL: https://github.com/apache/pulsar/pull/9628#discussion_r584327488 ## File path: pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/CacheSizeAllocator.java ## @@ -0,0 +1,65 @@ +/** + * Licensed to the Ap

[GitHub] [pulsar] gaoran10 commented on a change in pull request #9628: [Pulsar SQL] Add max split entry queue size bytes limitation

gaoran10 commented on a change in pull request #9628: URL: https://github.com/apache/pulsar/pull/9628#discussion_r584327440 ## File path: pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java ## @@ -136,6 +137,10 @@ public PulsarRecordCurs

[GitHub] [pulsar] gaoran10 commented on a change in pull request #9628: [Pulsar SQL] Add max split entry queue size bytes limitation

gaoran10 commented on a change in pull request #9628: URL: https://github.com/apache/pulsar/pull/9628#discussion_r580331775 ## File path: pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java ## @@ -136,6 +137,10 @@ public PulsarRecordCurs