You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2021/07/26 14:04:18 UTC
[iotdb] branch fixMasterCompile created (now f307eb2)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch fixMasterCompile
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at f307eb2 Fix compile error in assignQueryId(#3628)
This branch includes the following new commits:
new f307eb2 Fix compile error in assignQueryId(#3628)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: Fix compile error in assignQueryId(#3628)
Posted by xi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a commit to branch fixMasterCompile
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f307eb2639f024fb61231a4aae5d5004669881ea
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Mon Jul 26 09:02:27 2021 -0500
Fix compile error in assignQueryId(#3628)
---
.../java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java | 2 +-
.../org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java
index c5656d4..c923e55 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterQueryRouterTest.java
@@ -319,7 +319,7 @@ public class ClusterQueryRouterTest extends BaseQueryTest {
PhysicalPlan plan = processor.parseSQLToPhysicalPlan(sqlStr, ZoneId.systemDefault(), 1024);
UDTFPlan udtfPlan = (UDTFPlan) plan;
QueryContext context =
- new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true, 1024, -1));
+ new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true));
try {
QueryDataSet queryDataSet = clusterQueryRouter.udtfQuery(udtfPlan, context);
for (int i = 0; i < 20; i++) {
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
index ee91d22..2012966 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
@@ -62,7 +62,7 @@ public class ClusterUDTFQueryExecutorTest extends BaseQueryTest {
PhysicalPlan plan = processor.parseSQLToPhysicalPlan(sqlStr, ZoneId.systemDefault(), 1024);
UDTFPlan udtfPlan = (UDTFPlan) plan;
QueryContext context =
- new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true, 1024, -1));
+ new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true));
try {
executor = new ClusterUDTFQueryExecutor(udtfPlan, testMetaMember);
QueryDataSet queryDataSet = executor.executeWithoutValueFilterAlignByTime(context);
@@ -82,7 +82,7 @@ public class ClusterUDTFQueryExecutorTest extends BaseQueryTest {
PhysicalPlan plan = processor.parseSQLToPhysicalPlan(sqlStr, ZoneId.systemDefault(), 1024);
UDTFPlan udtfPlan = (UDTFPlan) plan;
QueryContext context =
- new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true, 1024, -1));
+ new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true));
try {
executor = new ClusterUDTFQueryExecutor(udtfPlan, testMetaMember);
QueryDataSet queryDataSet = executor.executeWithoutValueFilterAlignByTime(context);