This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch nested-operations in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 78d449d41b886997a9ee758fe1ff9a867d36297d Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Sep 17 16:01:56 2021 +0800 remove unused classes --- .../db/query/udf/core/access/MultiColumnRow.java | 97 --------------- .../query/udf/core/access/MultiColumnWindow.java | 84 ------------- .../udf/core/access/MultiColumnWindowIterator.java | 62 ---------- .../core/transformer/RawQueryPointTransformer.java | 73 ----------- .../primitive/ElasticSerializableIntList.java | 99 --------------- .../query/udf/datastructure/primitive/IntList.java | 33 ----- .../primitive/SerializableIntList.java | 133 --------------------- .../datastructure/primitive/WrappedIntArray.java | 51 -------- .../iotdb/db/integration/IoTDBNestedQueryIT.java | 6 +- .../integration/IoTDBUDTFAlignByTimeQueryIT.java | 6 +- 10 files changed, 6 insertions(+), 638 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnRow.java b/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnRow.java deleted file mode 100644 index 8baeca7..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnRow.java +++ /dev/null @@ -1,97 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.core.access; - -import org.apache.iotdb.db.query.udf.api.access.Row; -import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; -import org.apache.iotdb.tsfile.utils.Binary; - -public class MultiColumnRow implements Row { - - private final int[] columnIndexes; - private final TSDataType[] dataTypes; - - private Object[] rowRecord; - - public MultiColumnRow(int[] columnIndexes, TSDataType[] dataTypes) { - this.columnIndexes = columnIndexes; - this.dataTypes = dataTypes; - } - - @Override - public long getTime() { - return (long) rowRecord[rowRecord.length - 1]; - } - - @Override - public int getInt(int columnIndex) { - return (int) rowRecord[columnIndexes[columnIndex]]; - } - - @Override - public long getLong(int columnIndex) { - return (long) rowRecord[columnIndexes[columnIndex]]; - } - - @Override - public float getFloat(int columnIndex) { - return (float) rowRecord[columnIndexes[columnIndex]]; - } - - @Override - public double getDouble(int columnIndex) { - return (double) rowRecord[columnIndexes[columnIndex]]; - } - - @Override - public boolean getBoolean(int columnIndex) { - return (boolean) rowRecord[columnIndexes[columnIndex]]; - } - - @Override - public Binary getBinary(int columnIndex) { - return (Binary) rowRecord[columnIndexes[columnIndex]]; - } - - @Override - public String getString(int columnIndex) { - return ((Binary) rowRecord[columnIndexes[columnIndex]]).getStringValue(); - } - - @Override - public TSDataType getDataType(int columnIndex) { - return dataTypes[columnIndexes[columnIndex]]; - } - - @Override - public boolean isNull(int columnIndex) { - return rowRecord[columnIndexes[columnIndex]] == null; - } - - public Row setRowRecord(Object[] rowRecord) { - this.rowRecord = rowRecord; - return this; - } - - @Override - public int size() { - return this.columnIndexes.length; - } -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnWindow.java b/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnWindow.java deleted file mode 100644 index 0a01ad4..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnWindow.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.core.access; - -import org.apache.iotdb.db.query.udf.api.access.Row; -import org.apache.iotdb.db.query.udf.api.access.RowIterator; -import org.apache.iotdb.db.query.udf.api.access.RowWindow; -import org.apache.iotdb.db.query.udf.datastructure.primitive.IntList; -import org.apache.iotdb.db.query.udf.datastructure.row.ElasticSerializableRowRecordList; -import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; - -import java.io.IOException; - -public class MultiColumnWindow implements RowWindow { - - private final ElasticSerializableRowRecordList rowRecordList; - - private final int[] columnIndexes; - private final TSDataType[] dataTypes; - private final IntList windowRowIndexes; - - private final MultiColumnRow row; - private MultiColumnWindowIterator rowIterator; - - public MultiColumnWindow( - ElasticSerializableRowRecordList rowRecordList, - int[] columnIndexes, - TSDataType[] dataTypes, - IntList windowRowIndexes) { - this.rowRecordList = rowRecordList; - this.columnIndexes = columnIndexes; - this.dataTypes = dataTypes; - this.windowRowIndexes = windowRowIndexes; - row = new MultiColumnRow(columnIndexes, dataTypes); - } - - @Override - public int windowSize() { - return windowRowIndexes.size(); - } - - @Override - public Row getRow(int rowIndex) throws IOException { - if (rowIndex < 0 || windowRowIndexes.size() <= rowIndex) { - throw new ArrayIndexOutOfBoundsException( - String.format( - "Array index(%d) out of range [%d, %d).", rowIndex, 0, windowRowIndexes.size())); - } - return row.setRowRecord(rowRecordList.getRowRecord(windowRowIndexes.get(rowIndex))); - } - - @Override - public TSDataType getDataType(int columnIndex) { - return dataTypes[columnIndexes[columnIndex]]; - } - - @Override - public RowIterator getRowIterator() { - if (rowIterator == null) { - rowIterator = - new MultiColumnWindowIterator(rowRecordList, columnIndexes, dataTypes, windowRowIndexes); - } - - rowIterator.reset(); - return rowIterator; - } -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnWindowIterator.java b/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnWindowIterator.java deleted file mode 100644 index 59de7fc..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/core/access/MultiColumnWindowIterator.java +++ /dev/null @@ -1,62 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.core.access; - -import org.apache.iotdb.db.query.udf.api.access.Row; -import org.apache.iotdb.db.query.udf.api.access.RowIterator; -import org.apache.iotdb.db.query.udf.datastructure.primitive.IntList; -import org.apache.iotdb.db.query.udf.datastructure.row.ElasticSerializableRowRecordList; -import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; - -import java.io.IOException; - -public class MultiColumnWindowIterator implements RowIterator { - - private final ElasticSerializableRowRecordList rowRecordList; - private final IntList windowRowIndexes; - private final MultiColumnRow row; - private int rowIndex; - - public MultiColumnWindowIterator( - ElasticSerializableRowRecordList rowRecordList, - int[] columnIndexes, - TSDataType[] dataTypes, - IntList windowRowIndexes) { - this.rowRecordList = rowRecordList; - this.windowRowIndexes = windowRowIndexes; - row = new MultiColumnRow(columnIndexes, dataTypes); - rowIndex = -1; - } - - @Override - public boolean hasNextRow() { - return rowIndex < windowRowIndexes.size() - 1; - } - - @Override - public Row next() throws IOException { - return row.setRowRecord(rowRecordList.getRowRecord(windowRowIndexes.get(++rowIndex))); - } - - @Override - public void reset() { - rowIndex = -1; - } -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/RawQueryPointTransformer.java b/server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/RawQueryPointTransformer.java deleted file mode 100644 index eacf4de..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/RawQueryPointTransformer.java +++ /dev/null @@ -1,73 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.core.transformer; - -import org.apache.iotdb.db.exception.query.QueryProcessException; -import org.apache.iotdb.db.query.udf.core.reader.LayerPointReader; -import org.apache.iotdb.tsfile.exception.write.UnSupportedDataTypeException; -import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; - -import java.io.IOException; - -public class RawQueryPointTransformer extends Transformer { - - private final LayerPointReader layerPointReader; - - public RawQueryPointTransformer(LayerPointReader layerPointReader) { - this.layerPointReader = layerPointReader; - } - - @Override - protected boolean cacheValue() throws QueryProcessException, IOException { - if (!layerPointReader.next()) { - return false; - } - cachedTime = layerPointReader.currentTime(); - switch (layerPointReader.getDataType()) { - case INT32: - cachedInt = layerPointReader.currentInt(); - break; - case INT64: - cachedLong = layerPointReader.currentLong(); - break; - case FLOAT: - cachedFloat = layerPointReader.currentFloat(); - break; - case DOUBLE: - cachedDouble = layerPointReader.currentDouble(); - break; - case BOOLEAN: - cachedBoolean = layerPointReader.currentBoolean(); - break; - case TEXT: - cachedBinary = layerPointReader.currentBinary(); - break; - default: - throw new UnSupportedDataTypeException(layerPointReader.toString()); - } - layerPointReader.readyForNext(); - return true; - } - - @Override - public TSDataType getDataType() { - return layerPointReader.getDataType(); - } -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/ElasticSerializableIntList.java b/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/ElasticSerializableIntList.java deleted file mode 100644 index 89dc2ae..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/ElasticSerializableIntList.java +++ /dev/null @@ -1,99 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.datastructure.primitive; - -import org.apache.iotdb.db.exception.query.QueryProcessException; -import org.apache.iotdb.db.query.udf.datastructure.Cache; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; - -public class ElasticSerializableIntList implements IntList { - - protected long queryId; - protected int internalIntListCapacity; - protected ElasticSerializableIntList.LRUCache cache; - protected List<SerializableIntList> intLists; - protected int size; - - public ElasticSerializableIntList(long queryId, float memoryLimitInMB, int cacheSize) - throws QueryProcessException { - this.queryId = queryId; - int allocatableCapacity = SerializableIntList.calculateCapacity(memoryLimitInMB); - internalIntListCapacity = allocatableCapacity / cacheSize; - if (internalIntListCapacity == 0) { - cacheSize = 1; - internalIntListCapacity = allocatableCapacity; - } - cache = new ElasticSerializableIntList.LRUCache(cacheSize); - intLists = new ArrayList<>(); - size = 0; - } - - @Override - public int size() { - return size; - } - - @Override - public int get(int index) throws IOException { - return cache.get(index / internalIntListCapacity).get(index % internalIntListCapacity); - } - - @Override - public void put(int value) throws IOException { - checkExpansion(); - cache.get(size / internalIntListCapacity).put(value); - ++size; - } - - @Override - public void clear() { - cache.clear(); - intLists.clear(); - size = 0; - } - - private void checkExpansion() { - if (size % internalIntListCapacity == 0) { - intLists.add(SerializableIntList.newSerializableIntList(queryId)); - } - } - - private class LRUCache extends Cache { - - LRUCache(int capacity) { - super(capacity); - } - - SerializableIntList get(int targetIndex) throws IOException { - if (!removeFirstOccurrence(targetIndex)) { - if (cacheCapacity <= cacheSize) { - int lastIndex = removeLast(); - intLists.get(lastIndex).serialize(); - } - intLists.get(targetIndex).deserialize(); - } - addFirst(targetIndex); - return intLists.get(targetIndex); - } - } -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/IntList.java b/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/IntList.java deleted file mode 100644 index 476174c..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/IntList.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.datastructure.primitive; - -import java.io.IOException; - -public interface IntList { - - int size(); - - int get(int index) throws IOException; - - void put(int value) throws IOException; - - void clear(); -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/SerializableIntList.java b/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/SerializableIntList.java deleted file mode 100644 index 80f23bd..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/SerializableIntList.java +++ /dev/null @@ -1,133 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.datastructure.primitive; - -import org.apache.iotdb.db.exception.query.QueryProcessException; -import org.apache.iotdb.db.query.udf.datastructure.SerializableList; -import org.apache.iotdb.tsfile.common.conf.TSFileConfig; -import org.apache.iotdb.tsfile.utils.PublicBAOS; -import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils; - -import java.io.IOException; -import java.nio.ByteBuffer; -import java.util.ArrayList; -import java.util.List; - -import static org.apache.iotdb.db.conf.IoTDBConstant.MB; - -public class SerializableIntList implements SerializableList { - - public static SerializableIntList newSerializableIntList(long queryId) { - SerializationRecorder recorder = new SerializationRecorder(queryId); - return new SerializableIntList(recorder); - } - - public static int calculateCapacity(float memoryLimitInMB) throws QueryProcessException { - float memoryLimitInB = memoryLimitInMB * MB / 2; - int size = - ARRAY_CAPACITY_THRESHOLD - * (int) (memoryLimitInB / (ReadWriteIOUtils.INT_LEN * ARRAY_CAPACITY_THRESHOLD)); - if (size <= 0) { - throw new QueryProcessException("Memory is not enough for current query."); - } - return size; - } - - private static final int ARRAY_CAPACITY_THRESHOLD = TSFileConfig.ARRAY_CAPACITY_THRESHOLD; - - private final SerializationRecorder serializationRecorder; - - private int capacity = 16; - - private List<int[]> list; - private int writeCurListIndex; - private int writeCurArrayIndex; - private int count; - - public SerializableIntList(SerializationRecorder serializationRecorder) { - this.serializationRecorder = serializationRecorder; - init(); - } - - public void put(int value) { - if (writeCurArrayIndex == capacity) { - if (ARRAY_CAPACITY_THRESHOLD <= capacity) { - list.add(new int[capacity]); - ++writeCurListIndex; - writeCurArrayIndex = 0; - } else { - int newCapacity = capacity << 1; - int[] newValueData = new int[newCapacity]; - System.arraycopy(list.get(0), 0, newValueData, 0, capacity); - list.set(0, newValueData); - capacity = newCapacity; - } - } - - list.get(writeCurListIndex)[writeCurArrayIndex] = value; - ++writeCurArrayIndex; - ++count; - } - - public int get(int index) { - return list.get(index / capacity)[index % capacity]; - } - - public int size() { - return count; - } - - @Override - public void release() { - list = null; - } - - @Override - public void init() { - list = new ArrayList<>(); - list.add(new int[capacity]); - writeCurListIndex = 0; - writeCurArrayIndex = 0; - count = 0; - } - - @Override - public void serialize(PublicBAOS outputStream) throws IOException { - serializationRecorder.setSerializedElementSize(count); - int serializedByteLength = 0; - for (int i = 0; i < count; ++i) { - serializedByteLength += ReadWriteIOUtils.write(get(i), outputStream); - } - serializationRecorder.setSerializedByteLength(serializedByteLength); - } - - @Override - public void deserialize(ByteBuffer byteBuffer) { - int serializedElementSize = serializationRecorder.getSerializedElementSize(); - for (int i = 0; i < serializedElementSize; ++i) { - put(ReadWriteIOUtils.readInt(byteBuffer)); - } - } - - @Override - public SerializationRecorder getSerializationRecorder() { - return serializationRecorder; - } -} diff --git a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/WrappedIntArray.java b/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/WrappedIntArray.java deleted file mode 100644 index 659104f..0000000 --- a/server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/WrappedIntArray.java +++ /dev/null @@ -1,51 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.db.query.udf.datastructure.primitive; - -public class WrappedIntArray implements IntList { - - private final int[] list; - private int size; - - public WrappedIntArray(int capacity) { - list = new int[capacity]; - size = 0; - } - - @Override - public int size() { - return size; - } - - @Override - public int get(int index) { - return list[index]; - } - - @Override - public void put(int value) { - list[size++] = value; - } - - @Override - public void clear() { - size = 0; - } -} diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNestedQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNestedQueryIT.java index 377b698..035043d 100644 --- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNestedQueryIT.java +++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNestedQueryIT.java @@ -48,9 +48,9 @@ public class IoTDBNestedQueryIT { @BeforeClass public static void setUp() throws Exception { - IoTDBDescriptor.getInstance().getConfig().setUdfCollectorMemoryBudgetInMB(3); - IoTDBDescriptor.getInstance().getConfig().setUdfTransformerMemoryBudgetInMB(3); - IoTDBDescriptor.getInstance().getConfig().setUdfReaderMemoryBudgetInMB(3); + IoTDBDescriptor.getInstance().getConfig().setUdfCollectorMemoryBudgetInMB(1); + IoTDBDescriptor.getInstance().getConfig().setUdfTransformerMemoryBudgetInMB(1); + IoTDBDescriptor.getInstance().getConfig().setUdfReaderMemoryBudgetInMB(1); EnvironmentUtils.envSetUp(); Class.forName(Config.JDBC_DRIVER_NAME); createTimeSeries(); diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java index 7fa0ce3..2910174 100644 --- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java +++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java @@ -62,9 +62,9 @@ public class IoTDBUDTFAlignByTimeQueryIT { @BeforeClass public static void setUp() throws Exception { - IoTDBDescriptor.getInstance().getConfig().setUdfCollectorMemoryBudgetInMB(3); - IoTDBDescriptor.getInstance().getConfig().setUdfTransformerMemoryBudgetInMB(3); - IoTDBDescriptor.getInstance().getConfig().setUdfReaderMemoryBudgetInMB(3); + IoTDBDescriptor.getInstance().getConfig().setUdfCollectorMemoryBudgetInMB(1); + IoTDBDescriptor.getInstance().getConfig().setUdfTransformerMemoryBudgetInMB(1); + IoTDBDescriptor.getInstance().getConfig().setUdfReaderMemoryBudgetInMB(1); EnvironmentUtils.envSetUp(); Class.forName(Config.JDBC_DRIVER_NAME); createTimeSeries();
