You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2021/02/22 13:08:45 UTC
[iotdb] branch IOTDB-1169 created (now 86d2d4b)
This is an automated email from the ASF dual-hosted git repository.
jincheng pushed a change to branch IOTDB-1169
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at 86d2d4b [IOTDB-1169] Clean up for redundant throw clause
This branch includes the following new commits:
new 86d2d4b [IOTDB-1169] Clean up for redundant throw clause
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: [IOTDB-1169] Clean up for redundant throw clause
Posted by ji...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jincheng pushed a commit to branch IOTDB-1169
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 86d2d4bf1634b9210ce0d07627b96081ae144ed4
Author: sunjincheng121 <su...@gmail.com>
AuthorDate: Mon Feb 22 21:07:21 2021 +0800
[IOTDB-1169] Clean up for redundant throw clause
---
.../java/org/apache/iotdb/cli/AbstractCliIT.java | 2 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 4 +--
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 3 +-
.../cluster/server/member/DataGroupMember.java | 12 +-------
.../iotdb/cluster/common/TestLogManager.java | 4 +--
.../iotdb/cluster/log/CommitLogCallbackTest.java | 4 +--
.../cluster/log/applier/MetaLogApplierTest.java | 11 ++------
.../cluster/log/manage/RaftLogManagerTest.java | 3 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 2 +-
.../iotdb/cluster/query/LoadConfigurationTest.java | 4 +--
.../query/reader/RemoteSimpleSeriesReaderTest.java | 2 +-
.../caller/AppendGroupEntryHandlerTest.java | 3 +-
.../handlers/caller/ElectionHandlerTest.java | 2 +-
.../iotdb/flink/FlinkTsFileStreamSource.java | 3 +-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 3 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 3 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 2 +-
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 2 +-
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 4 +--
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 7 ++---
.../flink/tsfile/RowTsFileConnectorTestBase.java | 2 +-
.../flink/tsfile/RowTsFileInputFormatITCase.java | 2 +-
.../web/grafana/dao/impl/BasicDaoImplTest.java | 4 +--
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 7 ++---
.../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 10 +++----
.../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 4 +--
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 4 +--
.../iotdb/hadoop/tsfile/TSFRecordWriter.java | 2 +-
.../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 4 +--
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 2 +-
.../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 2 +-
.../org/apache/iotdb/hive/TSFHiveRecordReader.java | 2 +-
.../java/org/apache/iotdb/hive/TsFileSerDe.java | 4 +--
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBDataSource.java | 17 ++++++-----
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 10 +++----
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 8 +++---
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 4 +--
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 24 ++++++++--------
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 6 ++--
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 4 +--
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 4 +--
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 6 ++--
.../org/apache/iotdb/db/engine/StorageEngine.java | 5 ++--
.../engine/storagegroup/StorageGroupProcessor.java | 11 +-------
.../java/org/apache/iotdb/db/metadata/MTree.java | 5 ++--
.../apache/iotdb/db/metrics/server/JettyUtil.java | 6 ++--
.../iotdb/db/metrics/server/QueryServlet.java | 7 ++---
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../db/query/aggregation/impl/CountAggrResult.java | 2 +-
.../query/aggregation/impl/MaxValueAggrResult.java | 4 +--
.../query/aggregation/impl/MinValueAggrResult.java | 7 ++---
.../iotdb/db/query/dataset/SingleDataSet.java | 5 ++--
.../query/dataset/groupby/GroupByTimeDataSet.java | 2 +-
.../db/query/reader/chunk/DiskChunkLoader.java | 2 +-
.../db/query/reader/chunk/MemChunkLoader.java | 4 +--
.../db/query/reader/chunk/MemChunkReader.java | 2 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 3 +-
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../org/apache/iotdb/db/service/JMXService.java | 3 +-
.../org/apache/iotdb/db/service/MQTTService.java | 3 +-
.../apache/iotdb/db/service/MetricsService.java | 4 +--
.../org/apache/iotdb/db/service/RPCService.java | 3 +-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 3 +-
.../iotdb/db/sync/receiver/SyncServerManager.java | 3 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 9 +++---
.../db/tools/watermark/WatermarkDetector.java | 2 +-
.../java/org/apache/iotdb/db/utils/FileUtils.java | 3 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 2 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 2 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 2 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 2 +-
.../IoTDBDefaultThreadExceptionHandlerTest.java | 4 +--
.../db/concurrent/IoTDBThreadPoolFactoryTest.java | 8 +++---
.../db/engine/memtable/MemTableFlushTaskTest.java | 3 +-
.../db/engine/memtable/MemtableBenchmark.java | 3 +-
.../engine/modification/DeletionFileNodeTest.java | 3 +-
.../io/LocalTextModificationAccessorTest.java | 2 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 4 +--
.../engine/storagegroup/TsFileProcessorTest.java | 2 +-
.../virtualSg/HashVirtualPartitionerTest.java | 2 +-
.../db/integration/IoTDBAutoCreateSchemaIT.java | 2 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 2 +-
.../iotdb/db/integration/IoTDBClearCacheIT.java | 3 +-
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 3 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 20 ++++++-------
.../iotdb/db/integration/IoTDBCompressTypeIT.java | 2 +-
.../db/integration/IoTDBCreateSnapshotIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 14 ++++-----
.../db/integration/IoTDBDeleteStorageGroupIT.java | 2 +-
.../db/integration/IoTDBDeleteTimeseriesIT.java | 2 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 3 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 21 +++++++-------
.../db/integration/IoTDBFloatPrecisionIT.java | 5 ++--
.../iotdb/db/integration/IoTDBLargeDataIT.java | 12 ++++----
.../apache/iotdb/db/integration/IoTDBLastIT.java | 4 +--
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 11 ++++----
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 2 +-
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 3 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 8 +++---
.../db/integration/IoTDBMultiStatementsIT.java | 3 +-
.../iotdb/db/integration/IoTDBNumberPathIT.java | 21 +++++++-------
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 2 +-
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 2 +-
.../iotdb/db/integration/IoTDBRecoverIT.java | 4 +--
.../db/integration/IoTDBRecoverUnclosedIT.java | 4 +--
.../db/integration/IoTDBRemovePartitionIT.java | 7 ++---
.../IoTDBSameMeasurementsDifferentTypesIT.java | 3 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 2 +-
.../iotdb/db/integration/IoTDBTagAlterIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBTagIT.java | 2 +-
.../iotdb/db/integration/IoTDBVersionIT.java | 2 +-
.../aggregation/IoTDBAggregationIT.java | 10 +++----
.../aggregation/IoTDBAggregationLargeDataIT.java | 7 ++---
.../db/integration/auth/IoTDBAuthorizationIT.java | 2 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 2 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 2 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 2 +-
.../iotdb/db/qp/logical/IndexLogicalPlanTest.java | 5 ++--
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 4 +--
.../iotdb/db/query/control/TracingManagerTest.java | 5 ++--
.../reader/series/SeriesAggregateReaderTest.java | 6 ++--
.../reader/series/SeriesReaderByTimestampTest.java | 6 ++--
.../db/query/reader/series/SeriesReaderTest.java | 6 ++--
.../query/reader/series/SeriesReaderTestUtil.java | 6 ++--
.../org/apache/iotdb/db/script/EnvScriptIT.java | 6 ++--
.../db/sync/receiver/load/FileLoaderTest.java | 8 ++----
.../recover/SyncReceiverLogAnalyzerTest.java | 7 ++---
.../receiver/recover/SyncReceiverLoggerTest.java | 6 ++--
.../db/sync/sender/manage/SyncFileManagerTest.java | 6 ++--
.../db/sync/sender/transfer/SyncClientTest.java | 6 ++--
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 7 ++---
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../apache/iotdb/db/utils/FilePathUtilsTest.java | 3 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 2 +-
.../db/utils/datastructure/PrecisionTest.java | 9 +++---
.../apache/iotdb/db/writelog/PerformanceTest.java | 5 ++--
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 2 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 2 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 3 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 2 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 33 ++++++++--------------
.../apache/iotdb/spark/db/EnvironmentUtils.java | 2 +-
.../spark/tsfile/qp/common/BasicOperator.java | 4 +--
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 20 ++-----------
.../apache/iotdb/tsfile/compress/ICompressor.java | 6 ++--
.../iotdb/tsfile/compress/IUnCompressor.java | 6 ++--
.../tsfile/encoding/decoder/BitmapDecoder.java | 21 ++++----------
.../tsfile/encoding/decoder/LongRleDecoder.java | 3 +-
.../tsfile/encoding/decoder/PlainDecoder.java | 3 +-
.../encoding/encoder/SinglePrecisionEncoderV1.java | 3 +-
.../iotdb/tsfile/read/UnClosedTsFileReader.java | 4 +--
.../tsfile/read/reader/BatchDataIterator.java | 4 +--
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 2 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 6 ++--
.../write/record/datapoint/BooleanDataPoint.java | 4 +--
.../write/record/datapoint/DoubleDataPoint.java | 4 +--
.../write/record/datapoint/FloatDataPoint.java | 4 +--
.../write/record/datapoint/IntDataPoint.java | 4 +--
.../write/record/datapoint/LongDataPoint.java | 4 +--
.../write/record/datapoint/StringDataPoint.java | 4 +--
.../iotdb/tsfile/encoding/SDTEncoderTest.java | 12 ++++----
.../tsfile/encoding/decoder/BitmapDecoderTest.java | 4 +--
.../tsfile/encoding/decoder/FloatDecoderTest.java | 4 +--
.../encoding/decoder/GorillaDecoderV1Test.java | 4 +--
.../tsfile/encoding/decoder/IntRleDecoderTest.java | 4 +--
.../encoding/decoder/LongRleDecoderTest.java | 4 +--
.../delta/DeltaBinaryEncoderIntegerTest.java | 2 +-
.../decoder/delta/DeltaBinaryEncoderLongTest.java | 2 +-
.../regular/RegularDataEncoderIntegerTest.java | 2 +-
.../regular/RegularDataEncoderLongTest.java | 2 +-
.../file/metadata/TimeSeriesMetadataTest.java | 2 +-
.../tsfile/file/metadata/TsFileMetadataTest.java | 2 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 3 +-
.../tsfile/read/TimeSeriesMetadataReadTest.java | 2 +-
.../tsfile/read/filter/GroupByFilterTest.java | 2 +-
.../read/query/executor/QueryExecutorTest.java | 3 +-
.../query/timegenerator/ReaderByTimestampTest.java | 3 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 8 ++----
.../tsfile/read/reader/FakedMultiBatchReader.java | 4 +--
.../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 8 +++---
.../tsfile/utils/ReadWriteStreamUtilsTest.java | 4 +--
.../tsfile/utils/ReadWriteToBytesUtilsTest.java | 2 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 3 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 2 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 2 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 4 +--
.../iotdb/tsfile/write/TsFileWriterTest.java | 2 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 2 +-
193 files changed, 372 insertions(+), 544 deletions(-)
diff --git a/cli/src/test/java/org/apache/iotdb/cli/AbstractCliIT.java b/cli/src/test/java/org/apache/iotdb/cli/AbstractCliIT.java
index e717457..719a801 100644
--- a/cli/src/test/java/org/apache/iotdb/cli/AbstractCliIT.java
+++ b/cli/src/test/java/org/apache/iotdb/cli/AbstractCliIT.java
@@ -54,7 +54,7 @@ public class AbstractCliIT {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testInit() {
diff --git a/cli/src/test/java/org/apache/iotdb/cli/StartClientScriptIT.java b/cli/src/test/java/org/apache/iotdb/cli/StartClientScriptIT.java
index be9e375..829cd9a 100644
--- a/cli/src/test/java/org/apache/iotdb/cli/StartClientScriptIT.java
+++ b/cli/src/test/java/org/apache/iotdb/cli/StartClientScriptIT.java
@@ -28,7 +28,7 @@ import java.io.IOException;
public class StartClientScriptIT extends AbstractScript {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
@@ -39,7 +39,7 @@ public class StartClientScriptIT extends AbstractScript {
}
@Test
- public void test() throws IOException, InterruptedException {
+ public void test() throws IOException {
String os = System.getProperty("os.name").toLowerCase();
if (os.startsWith("windows")) {
testOnWindows();
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java b/cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java
index 128fa4f..47720b3 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/MetaSimpleSnapshot.java
@@ -28,7 +28,6 @@ import org.apache.iotdb.db.auth.authorizer.IAuthorizer;
import org.apache.iotdb.db.auth.entity.Role;
import org.apache.iotdb.db.auth.entity.User;
import org.apache.iotdb.db.engine.StorageEngine;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
import org.apache.iotdb.db.exception.metadata.StorageGroupAlreadySetException;
@@ -213,7 +212,7 @@ public class MetaSimpleSnapshot extends Snapshot {
try {
IoTDB.metaManager.setTTL(sgPath, entry.getValue());
StorageEngine.getInstance().setTTL(sgPath, entry.getValue());
- } catch (MetadataException | StorageEngineException | IOException e) {
+ } catch (MetadataException | IOException e) {
logger.error(
"{}: Cannot set ttl in storage group {} , errMessage: {}",
metaGroupMember.getName(),
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
index 3ac46f3..989d348 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMember.java
@@ -744,17 +744,7 @@ public class DataGroupMember extends RaftMember {
return slotSet.contains(slot);
};
for (PartialPath sg : allStorageGroupNames) {
- try {
- StorageEngine.getInstance().removePartitions(sg, filter);
- } catch (StorageEngineException e) {
- logger.warn(
- "{}: failed to remove partitions of {} and {} other slots in {}",
- name,
- slots.get(0),
- slots.size() - 1,
- sg,
- e);
- }
+ StorageEngine.getInstance().removePartitions(sg, filter);
}
for (Integer slot : slots) {
slotManager.setToNull(slot);
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java b/cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java
index 6a8dd4b..9471f64 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/common/TestLogManager.java
@@ -23,8 +23,6 @@ import org.apache.iotdb.cluster.log.Snapshot;
import org.apache.iotdb.cluster.log.manage.RaftLogManager;
import org.apache.iotdb.cluster.log.manage.serializable.SyncLogDequeSerializer;
-import java.io.IOException;
-
public class TestLogManager extends RaftLogManager {
public TestLogManager(int nodeIdentifier) {
@@ -37,5 +35,5 @@ public class TestLogManager extends RaftLogManager {
}
@Override
- public void takeSnapshot() throws IOException {}
+ public void takeSnapshot() {}
}
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java
index 06e4e45..6311b72 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/log/CommitLogCallbackTest.java
@@ -26,14 +26,12 @@ import org.apache.iotdb.db.utils.EnvironmentUtils;
import org.junit.After;
import org.junit.Test;
-import java.io.IOException;
-
import static org.junit.Assert.*;
public class CommitLogCallbackTest {
@Test
- public void test() throws InterruptedException, IOException {
+ public void test() throws InterruptedException {
RaftMember raftMember = new TestMetaGroupMember();
CommitLogCallback commitLogCallback = new CommitLogCallback(raftMember);
synchronized (raftMember.getSyncLock()) {
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java
index f5df311..8f526a3 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/log/applier/MetaLogApplierTest.java
@@ -28,8 +28,6 @@ import org.apache.iotdb.cluster.log.logtypes.RemoveNodeLog;
import org.apache.iotdb.cluster.rpc.thrift.Node;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
-import org.apache.iotdb.db.exception.metadata.StorageGroupNotSetException;
-import org.apache.iotdb.db.exception.query.QueryProcessException;
import org.apache.iotdb.db.metadata.PartialPath;
import org.apache.iotdb.db.qp.physical.sys.CreateTimeSeriesPlan;
import org.apache.iotdb.db.qp.physical.sys.SetStorageGroupPlan;
@@ -78,8 +76,7 @@ public class MetaLogApplierTest extends IoTDBTest {
}
@Test
- public void testApplyAddNode()
- throws QueryProcessException, StorageGroupNotSetException, StorageEngineException {
+ public void testApplyAddNode() {
nodes.clear();
Node node = new Node("localhost", 1111, 0, 2222, 55560);
@@ -91,8 +88,7 @@ public class MetaLogApplierTest extends IoTDBTest {
}
@Test
- public void testApplyRemoveNode()
- throws QueryProcessException, StorageGroupNotSetException, StorageEngineException {
+ public void testApplyRemoveNode() {
nodes.clear();
Node node = testMetaGroupMember.getThisNode();
@@ -104,8 +100,7 @@ public class MetaLogApplierTest extends IoTDBTest {
}
@Test
- public void testApplyMetadataCreation()
- throws QueryProcessException, MetadataException, StorageEngineException {
+ public void testApplyMetadataCreation() throws MetadataException {
PhysicalPlanLog physicalPlanLog = new PhysicalPlanLog();
SetStorageGroupPlan setStorageGroupPlan =
new SetStorageGroupPlan(new PartialPath("root.applyMeta"));
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
index 6f8b8f9..2eddaf8 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/log/manage/RaftLogManagerTest.java
@@ -916,8 +916,7 @@ public class RaftLogManagerTest {
}
@Test
- public void testAppendCommitted()
- throws LogExecutionException, GetEntriesWrongParametersException, EntryCompactedException {
+ public void testAppendCommitted() throws LogExecutionException {
CommittedEntryManager committedEntryManager =
new CommittedEntryManager(
ClusterDescriptor.getInstance().getConfig().getMaxNumOfLogsInMem());
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java
index 484b10b..951b56d 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/log/snapshot/DataSnapshotTest.java
@@ -95,7 +95,7 @@ public abstract class DataSnapshotTest {
@Override
public void removeHardLink(
- String hardLinkPath, AsyncMethodCallback<Void> resultHandler) throws TException {
+ String hardLinkPath, AsyncMethodCallback<Void> resultHandler) {
new Thread(
() -> {
try {
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java
index 3c582de..bd3d6d1 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/query/LoadConfigurationTest.java
@@ -23,7 +23,6 @@ package org.apache.iotdb.cluster.query;
import org.apache.iotdb.cluster.config.ClusterDescriptor;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.constant.TestConstant;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.query.QueryProcessException;
import org.apache.iotdb.db.qp.logical.sys.LoadConfigurationOperator;
import org.apache.iotdb.db.qp.physical.sys.LoadConfigurationPlan;
@@ -44,7 +43,6 @@ import org.powermock.modules.junit4.PowerMockRunner;
import java.io.File;
import java.io.FileWriter;
-import java.io.IOException;
import java.net.URL;
import static org.junit.Assert.assertEquals;
@@ -96,7 +94,7 @@ public class LoadConfigurationTest {
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() {
File engineFile = fsFactory.getFile(ENGINE_PROPERTIES_FILE);
if (engineFile.exists()) {
Assert.assertTrue(engineFile.delete());
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
index e3e5631..2812793 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/query/reader/RemoteSimpleSeriesReaderTest.java
@@ -119,7 +119,7 @@ public class RemoteSimpleSeriesReaderTest {
}
@After
- public void tearDown() throws Exception {
+ public void tearDown() {
ClusterDescriptor.getInstance().getConfig().setUseAsyncServer(prevUseAsyncServer);
}
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java
index e468560..7584fd7 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/AppendGroupEntryHandlerTest.java
@@ -27,7 +27,6 @@ import org.apache.iotdb.cluster.config.ClusterDescriptor;
import org.apache.iotdb.cluster.log.Log;
import org.apache.iotdb.cluster.server.Response;
import org.apache.iotdb.cluster.server.member.RaftMember;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.utils.EnvironmentUtils;
import org.junit.After;
@@ -57,7 +56,7 @@ public class AppendGroupEntryHandlerTest {
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() throws IOException {
ClusterDescriptor.getInstance().getConfig().setReplicationNum(prevReplicationNum);
member.stop();
member.closeLogManager();
diff --git a/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java b/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java
index 8dd3942..b654cc6 100644
--- a/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java
+++ b/cluster/src/test/java/org/apache/iotdb/cluster/server/handlers/caller/ElectionHandlerTest.java
@@ -82,7 +82,7 @@ public class ElectionHandlerTest {
}
@Test
- public void testLogMismatch() throws InterruptedException {
+ public void testLogMismatch() {
AtomicBoolean terminated = new AtomicBoolean(false);
AtomicBoolean electionValid = new AtomicBoolean(false);
long electorTerm = 10;
diff --git a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
index aa2d573..e8b9b6e 100644
--- a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
+++ b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
@@ -32,7 +32,6 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.types.Row;
import java.io.File;
-import java.io.IOException;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
@@ -41,7 +40,7 @@ import java.util.stream.Collectors;
/** The example of reading TsFile via Flink DataStream API. */
public class FlinkTsFileStreamSource {
- public static void main(String[] args) throws IOException {
+ public static void main(String[] args) {
String path = "test.tsfile";
TsFileUtils.writeTsFile(path);
new File(path).deleteOnExit();
diff --git a/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java b/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
index d82d1c8..346ff1e 100644
--- a/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
+++ b/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java
@@ -27,7 +27,6 @@ import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import java.io.IOException;
-import java.net.URISyntaxException;
/**
* One example for reading TsFile with MapReduce. This MR Job is used to get the result of
@@ -37,7 +36,7 @@ import java.net.URISyntaxException;
public class TSFMRReadExample {
public static void main(String[] args)
- throws IOException, ClassNotFoundException, TSFHadoopException, URISyntaxException {
+ throws IOException, ClassNotFoundException, TSFHadoopException {
if (args.length != 3) {
System.out.println("Please give hdfs url, input path, output path");
diff --git a/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java b/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
index 756af3c..0ea44c3 100644
--- a/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
+++ b/example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java
@@ -40,13 +40,12 @@ import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.Reducer;
import java.io.IOException;
-import java.net.URISyntaxException;
/** One example for writing TsFile with MapReduce. */
public class TSMRWriteExample {
public static void main(String[] args)
- throws IOException, ClassNotFoundException, TSFHadoopException, URISyntaxException {
+ throws IOException, ClassNotFoundException, TSFHadoopException {
if (args.length != 3) {
System.out.println("Please give hdfs url, input path, output path");
diff --git a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
index 50dec4e..a56bbe0 100644
--- a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
+++ b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
@@ -170,7 +170,7 @@ public class IoTDBSink<IN> extends RichSinkFunction<IN> {
}
@Override
- public void close() throws Exception {
+ public void close() {
if (pool != null) {
try {
flush();
diff --git a/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java b/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
index d5e887b..779b636 100644
--- a/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
+++ b/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
@@ -39,7 +39,7 @@ public class IoTDBSinkBatchInsertTest {
private SessionPool pool;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
IoTDBOptions options = new IoTDBOptions();
options.setTimeseriesOptionList(
Lists.newArrayList(new IoTDBOptions.TimeseriesOption("root.sg.D01.temperature")));
diff --git a/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java b/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
index 1938a81..338f845 100644
--- a/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
+++ b/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
@@ -39,7 +39,7 @@ public class IoTDBSinkBatchTimerTest {
private SessionPool pool;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
IoTDBOptions options = new IoTDBOptions();
options.setTimeseriesOptionList(
Lists.newArrayList(new IoTDBOptions.TimeseriesOption("root.sg.D01.temperature")));
@@ -74,7 +74,7 @@ public class IoTDBSinkBatchTimerTest {
}
@Test
- public void close() throws Exception {
+ public void close() {
ioTDBSink.close();
verify(pool).close();
}
diff --git a/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java b/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java
index 381f458..3d8c483 100644
--- a/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java
+++ b/flink-tsfile-connector/src/main/java/org/apache/iotdb/flink/tsfile/RowTSRecordConverter.java
@@ -37,7 +37,6 @@ import org.apache.flink.api.java.typeutils.RowTypeInfo;
import org.apache.flink.types.Row;
import org.apache.flink.util.Collector;
-import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
@@ -57,7 +56,7 @@ public class RowTSRecordConverter implements TSRecordConverter<Row> {
}
@Override
- public void open(Schema schema) throws IOException {
+ public void open(Schema schema) {
this.tsRecordIndexMapping = new int[rowTypeInfo.getArity()];
this.dataPointIndexMapping = new int[rowTypeInfo.getArity()];
List<TSRecord> outputTemplateList = new ArrayList<>();
@@ -112,7 +111,7 @@ public class RowTSRecordConverter implements TSRecordConverter<Row> {
}
@Override
- public void convert(Row input, Collector<TSRecord> collector) throws IOException {
+ public void convert(Row input, Collector<TSRecord> collector) {
long timestamp = (long) input.getField(timeIndex);
for (TSRecord tsRecord : reuse) {
tsRecord.dataPointList.clear();
@@ -159,7 +158,7 @@ public class RowTSRecordConverter implements TSRecordConverter<Row> {
}
@Override
- public void close() throws IOException {
+ public void close() {
outputTemplate = null;
timeIndex = -1;
tsRecordIndexMapping = null;
diff --git a/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java
index 7781098..5140337 100644
--- a/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java
+++ b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileConnectorTestBase.java
@@ -63,7 +63,7 @@ public abstract class RowTsFileConnectorTestBase {
protected RowTypeInfo rowTypeInfo = new RowTypeInfo(typeInformations, filedNames);
@Before
- public void prepareTempDirectory() throws Exception {
+ public void prepareTempDirectory() {
tmpDir = String.join(File.separator, TsFileWriteUtil.TMP_DIR, UUID.randomUUID().toString());
new File(tmpDir).mkdirs();
config.setBatchSize(500);
diff --git a/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java
index 2518dc0..36ebb13 100644
--- a/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java
+++ b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatITCase.java
@@ -78,7 +78,7 @@ public class RowTsFileInputFormatITCase extends RowTsFileInputFormatTestBase {
}
@Test
- public void testStreamExecution() throws Exception {
+ public void testStreamExecution() {
// read files in a directory
TsFileInputFormat<Row> inputFormat = prepareInputFormat(tmpDir);
DataStream<Row> source = senv.createInput(inputFormat);
diff --git a/grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java b/grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
index e66676a..7f0f796 100644
--- a/grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
+++ b/grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
@@ -26,10 +26,10 @@ import org.springframework.test.util.ReflectionTestUtils;
public class BasicDaoImplTest {
@Before
- public void setUp() throws Exception {}
+ public void setUp() {}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void getInterval() {
diff --git a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java
index 3e4b244..50252bb 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSFile.java
@@ -37,7 +37,6 @@ import java.io.FilenameFilter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
-import java.net.MalformedURLException;
import java.net.URI;
import java.net.URL;
import java.util.ArrayList;
@@ -305,17 +304,17 @@ public class HDFSFile extends File {
}
@Override
- public String getCanonicalPath() throws IOException {
+ public String getCanonicalPath() {
throw new UnsupportedOperationException(UNSUPPORT_OPERATION);
}
@Override
- public File getCanonicalFile() throws IOException {
+ public File getCanonicalFile() {
throw new UnsupportedOperationException(UNSUPPORT_OPERATION);
}
@Override
- public URL toURL() throws MalformedURLException {
+ public URL toURL() {
throw new UnsupportedOperationException(UNSUPPORT_OPERATION);
}
diff --git a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java
index f1448d5..a0480b1 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSInput.java
@@ -101,22 +101,22 @@ public class HDFSInput implements TsFileInput {
}
@Override
- public int read() throws IOException {
+ public int read() {
throw new UnsupportedOperationException();
}
@Override
- public int read(byte[] b, int off, int len) throws IOException {
+ public int read(byte[] b, int off, int len) {
throw new UnsupportedOperationException();
}
@Override
- public FileChannel wrapAsFileChannel() throws IOException {
+ public FileChannel wrapAsFileChannel() {
throw new UnsupportedOperationException();
}
@Override
- public InputStream wrapAsInputStream() throws IOException {
+ public InputStream wrapAsInputStream() {
return fsDataInputStream;
}
@@ -126,7 +126,7 @@ public class HDFSInput implements TsFileInput {
}
@Override
- public int readInt() throws IOException {
+ public int readInt() {
throw new UnsupportedOperationException();
}
diff --git a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java
index d1f2788..de11c04 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/fileSystem/HDFSOutput.java
@@ -67,7 +67,7 @@ public class HDFSOutput implements TsFileOutput {
}
@Override
- public void write(ByteBuffer b) throws IOException {
+ public void write(ByteBuffer b) {
throw new UnsupportedOperationException("Unsupported operation.");
}
@@ -82,7 +82,7 @@ public class HDFSOutput implements TsFileOutput {
}
@Override
- public OutputStream wrapAsStream() throws IOException {
+ public OutputStream wrapAsStream() {
return fsDataOutputStream;
}
diff --git a/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java b/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java
index 25ade9c..894e8aa 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordReader.java
@@ -125,7 +125,7 @@ public class TSFRecordReader extends RecordReader<NullWritable, MapWritable> imp
}
@Override
- public boolean nextKeyValue() throws IOException, InterruptedException {
+ public boolean nextKeyValue() throws IOException {
while (currentIndex < dataSetList.size()) {
if (!dataSetList.get(currentIndex).hasNext()) {
currentIndex++;
@@ -140,7 +140,7 @@ public class TSFRecordReader extends RecordReader<NullWritable, MapWritable> imp
}
@Override
- public NullWritable getCurrentKey() throws IOException, InterruptedException {
+ public NullWritable getCurrentKey() {
return NullWritable.get();
}
diff --git a/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java b/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java
index a334d8c..1be6659 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFRecordWriter.java
@@ -55,7 +55,7 @@ public class TSFRecordWriter extends RecordWriter<NullWritable, HDFSTSRecord> {
}
@Override
- public void close(TaskAttemptContext context) throws IOException, InterruptedException {
+ public void close(TaskAttemptContext context) throws IOException {
logger.info("Close the record writer, the task attempt id is {}", context.getTaskAttemptID());
writer.close();
}
diff --git a/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java b/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java
index 05880cf..0a6c35c 100644
--- a/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java
+++ b/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFHadoopTest.java
@@ -43,14 +43,14 @@ public class TSFHadoopTest {
private String tsfilePath = TestConstant.BASE_OUTPUT_PATH.concat("example_mr.tsfile");
@Before
- public void setUp() throws Exception {
+ public void setUp() {
TsFileTestHelper.deleteTsFile(tsfilePath);
inputFormat = new TSFInputFormat();
}
@After
- public void tearDown() throws Exception {
+ public void tearDown() {
TsFileTestHelper.deleteTsFile(tsfilePath);
}
diff --git a/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java b/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java
index ebc0d66..5b6f11e 100644
--- a/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java
+++ b/hadoop/src/test/java/org/apache/iotdb/hadoop/tsfile/TSFInputSplitTest.java
@@ -37,7 +37,7 @@ public class TSFInputSplitTest {
private DataOutputBuffer dataOutputBuffer = new DataOutputBuffer();
@Before
- public void setUp() throws Exception {
+ public void setUp() {
// For the test data
Path path = new Path("input");
diff --git a/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java b/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java
index e9d741c..b9d7ebb 100644
--- a/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java
+++ b/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveOutputFormat.java
@@ -71,5 +71,5 @@ public class TSFHiveOutputFormat extends TSFOutputFormat
// Not doing any check
@Override
- public void checkOutputSpecs(FileSystem ignored, JobConf job) throws IOException {}
+ public void checkOutputSpecs(FileSystem ignored, JobConf job) {}
}
diff --git a/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java b/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java
index b705ef8..8447907 100644
--- a/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java
+++ b/hive-connector/src/main/java/org/apache/iotdb/hive/TSFHiveRecordReader.java
@@ -104,7 +104,7 @@ public class TSFHiveRecordReader implements RecordReader<NullWritable, MapWritab
}
@Override
- public long getPos() throws IOException {
+ public long getPos() {
// can't know
return 0;
}
diff --git a/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java b/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java
index 1036452..0f861e9 100644
--- a/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java
+++ b/hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDe.java
@@ -105,7 +105,7 @@ public class TsFileSerDe extends AbstractSerDe {
}
@Override
- public Writable serialize(Object obj, ObjectInspector objInspector) throws SerDeException {
+ public Writable serialize(Object obj, ObjectInspector objInspector) {
// Not support yet
return null;
}
@@ -122,7 +122,7 @@ public class TsFileSerDe extends AbstractSerDe {
}
@Override
- public ObjectInspector getObjectInspector() throws SerDeException {
+ public ObjectInspector getObjectInspector() {
return oi;
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java
index e95fac5..630af44 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java
@@ -317,7 +317,7 @@ public class IoTDBConnection implements Connection {
}
@Override
- public boolean isValid(int arg0) throws SQLException {
+ public boolean isValid(int arg0) {
return !isClosed;
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSource.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSource.java
index 1e2a897..debecc0 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSource.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSource.java
@@ -23,7 +23,6 @@ import javax.sql.DataSource;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.SQLException;
-import java.sql.SQLFeatureNotSupportedException;
import java.util.Properties;
public class IoTDBDataSource implements DataSource {
@@ -94,7 +93,7 @@ public class IoTDBDataSource implements DataSource {
}
@Override
- public Connection getConnection(String username, String password) throws SQLException {
+ public Connection getConnection(String username, String password) {
try {
Properties newProp = new Properties();
newProp.setProperty("user", username);
@@ -107,33 +106,33 @@ public class IoTDBDataSource implements DataSource {
}
@Override
- public PrintWriter getLogWriter() throws SQLException {
+ public PrintWriter getLogWriter() {
return null;
}
@Override
- public void setLogWriter(PrintWriter printWriter) throws SQLException {}
+ public void setLogWriter(PrintWriter printWriter) {}
@Override
- public void setLoginTimeout(int i) throws SQLException {}
+ public void setLoginTimeout(int i) {}
@Override
- public int getLoginTimeout() throws SQLException {
+ public int getLoginTimeout() {
return 0;
}
@Override
- public java.util.logging.Logger getParentLogger() throws SQLFeatureNotSupportedException {
+ public java.util.logging.Logger getParentLogger() {
return null;
}
@Override
- public <T> T unwrap(Class<T> aClass) throws SQLException {
+ public <T> T unwrap(Class<T> aClass) {
return null;
}
@Override
- public boolean isWrapperFor(Class<?> aClass) throws SQLException {
+ public boolean isWrapperFor(Class<?> aClass) {
return false;
}
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java
index f4876ae..c1eb0d9 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java
@@ -26,7 +26,6 @@ import javax.sql.DataSource;
import javax.sql.XADataSource;
import java.sql.Driver;
-import java.sql.SQLException;
import java.util.Properties;
public class IoTDBDataSourceFactory implements DataSourceFactory {
@@ -34,7 +33,7 @@ public class IoTDBDataSourceFactory implements DataSourceFactory {
private final Logger logger = LoggerFactory.getLogger(IoTDBDataSourceFactory.class);
@Override
- public DataSource createDataSource(Properties properties) throws SQLException {
+ public DataSource createDataSource(Properties properties) {
IoTDBDataSource ds = new IoTDBDataSource();
setProperties(ds, properties);
return ds;
@@ -64,18 +63,17 @@ public class IoTDBDataSourceFactory implements DataSourceFactory {
}
@Override
- public ConnectionPoolDataSource createConnectionPoolDataSource(Properties properties)
- throws SQLException {
+ public ConnectionPoolDataSource createConnectionPoolDataSource(Properties properties) {
return null;
}
@Override
- public XADataSource createXADataSource(Properties properties) throws SQLException {
+ public XADataSource createXADataSource(Properties properties) {
return null;
}
@Override
- public Driver createDriver(Properties properties) throws SQLException {
+ public Driver createDriver(Properties properties) {
return new IoTDBDriver();
}
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java
index f111739..4a90fed 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java
@@ -180,7 +180,7 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
}
@Override
- public String getDatabaseProductVersion() throws SQLException {
+ public String getDatabaseProductVersion() {
return DATABASE_VERSION;
}
@@ -200,12 +200,12 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
}
@Override
- public String getDriverName() throws SQLException {
+ public String getDriverName() {
return org.apache.iotdb.jdbc.IoTDBDriver.class.getName();
}
@Override
- public String getDriverVersion() throws SQLException {
+ public String getDriverVersion() {
return DATABASE_VERSION;
}
@@ -499,7 +499,7 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
}
@Override
- public String getUserName() throws SQLException {
+ public String getUserName() {
return client.toString();
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDriver.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDriver.java
index 6b339c6..7bef48a 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDriver.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDriver.java
@@ -53,7 +53,7 @@ public class IoTDBDriver implements Driver {
}
@Override
- public boolean acceptsURL(String url) throws SQLException {
+ public boolean acceptsURL(String url) {
return Pattern.matches(TSFILE_URL_PREFIX, url);
}
@@ -86,7 +86,7 @@ public class IoTDBDriver implements Driver {
}
@Override
- public DriverPropertyInfo[] getPropertyInfo(String url, Properties info) throws SQLException {
+ public DriverPropertyInfo[] getPropertyInfo(String url, Properties info) {
// TODO Auto-generated method stub
return new DriverPropertyInfo[0];
}
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedStatement.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedStatement.java
index df3916e..786a975 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedStatement.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedStatement.java
@@ -95,20 +95,20 @@ public class IoTDBPreparedStatement extends IoTDBStatement implements PreparedSt
}
@Override
- public ParameterMetaData getParameterMetaData() throws SQLException {
+ public ParameterMetaData getParameterMetaData() {
return new ParameterMetaData() {
@Override
- public int getParameterCount() throws SQLException {
+ public int getParameterCount() {
return parameters.size();
}
@Override
- public int isNullable(int param) throws SQLException {
+ public int isNullable(int param) {
return ParameterMetaData.parameterNullableUnknown;
}
@Override
- public boolean isSigned(int param) throws SQLException {
+ public boolean isSigned(int param) {
try {
return Integer.parseInt(parameters.get(param)) < 0;
} catch (Exception e) {
@@ -117,12 +117,12 @@ public class IoTDBPreparedStatement extends IoTDBStatement implements PreparedSt
}
@Override
- public int getPrecision(int param) throws SQLException {
+ public int getPrecision(int param) {
return parameters.get(param).length();
}
@Override
- public int getScale(int param) throws SQLException {
+ public int getScale(int param) {
try {
double d = Double.parseDouble(parameters.get(param));
if (d >= 1) { // we only need the fraction digits
@@ -144,32 +144,32 @@ public class IoTDBPreparedStatement extends IoTDBStatement implements PreparedSt
}
@Override
- public int getParameterType(int param) throws SQLException {
+ public int getParameterType(int param) {
return 0;
}
@Override
- public String getParameterTypeName(int param) throws SQLException {
+ public String getParameterTypeName(int param) {
return null;
}
@Override
- public String getParameterClassName(int param) throws SQLException {
+ public String getParameterClassName(int param) {
return null;
}
@Override
- public int getParameterMode(int param) throws SQLException {
+ public int getParameterMode(int param) {
return 0;
}
@Override
- public <T> T unwrap(Class<T> iface) throws SQLException {
+ public <T> T unwrap(Class<T> iface) {
return null;
}
@Override
- public boolean isWrapperFor(Class<?> iface) throws SQLException {
+ public boolean isWrapperFor(Class<?> iface) {
return false;
}
};
diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
index c839acb..a3ecfba 100644
--- a/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
+++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBStatement.java
@@ -631,7 +631,7 @@ public class IoTDBStatement implements Statement {
}
@Override
- public int getUpdateCount() throws SQLException {
+ public int getUpdateCount() {
return -1;
}
diff --git a/jdbc/src/test/java/org/apache/iotdb/jdbc/BatchTest.java b/jdbc/src/test/java/org/apache/iotdb/jdbc/BatchTest.java
index 9ef545e..74947d8 100644
--- a/jdbc/src/test/java/org/apache/iotdb/jdbc/BatchTest.java
+++ b/jdbc/src/test/java/org/apache/iotdb/jdbc/BatchTest.java
@@ -62,7 +62,7 @@ public class BatchTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@SuppressWarnings("serial")
@Test
diff --git a/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBConnectionTest.java b/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBConnectionTest.java
index 98d60a1..25ea6e6 100644
--- a/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBConnectionTest.java
+++ b/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBConnectionTest.java
@@ -51,12 +51,12 @@ public class IoTDBConnectionTest {
private long sessionId;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
MockitoAnnotations.initMocks(this);
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testSetTimeZone() throws IoTDBSQLException, TException {
@@ -68,7 +68,7 @@ public class IoTDBConnectionTest {
}
@Test
- public void testGetTimeZone() throws IoTDBSQLException, TException {
+ public void testGetTimeZone() throws TException {
String timeZone = ZoneId.systemDefault().toString();
sessionId = connection.getSessionId();
when(client.getTimeZone(sessionId)).thenReturn(new TSGetTimeZoneResp(successStatus, timeZone));
diff --git a/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBResultMetadataTest.java b/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBResultMetadataTest.java
index 7509fec..cd208f8 100644
--- a/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBResultMetadataTest.java
+++ b/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBResultMetadataTest.java
@@ -38,10 +38,10 @@ public class IoTDBResultMetadataTest {
private IoTDBResultMetadata metadata;
@Before
- public void setUp() throws Exception {}
+ public void setUp() {}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testGetColumnCount() {
diff --git a/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBStatementTest.java b/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBStatementTest.java
index 67cd75e..579d1df 100644
--- a/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBStatementTest.java
+++ b/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBStatementTest.java
@@ -60,7 +60,7 @@ public class IoTDBStatementTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@SuppressWarnings("resource")
@Test
diff --git a/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java b/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java
index e89d731..aa28d6e 100644
--- a/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java
+++ b/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java
@@ -34,10 +34,10 @@ import static org.junit.Assert.fail;
public class UtilsTest {
@Before
- public void setUp() throws Exception {}
+ public void setUp() {}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testParseURL() throws IoTDBURLException {
diff --git a/server/src/main/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizer.java b/server/src/main/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizer.java
index 2563f05..965aa56 100644
--- a/server/src/main/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizer.java
+++ b/server/src/main/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizer.java
@@ -202,7 +202,7 @@ public class OpenIdAuthorizer extends BasicAuthorizer {
}
@Override
- public void createUser(String username, String password) throws AuthException {
+ public void createUser(String username, String password) {
throwUnsupportedOperationException();
}
@@ -212,7 +212,7 @@ public class OpenIdAuthorizer extends BasicAuthorizer {
}
@Override
- public void deleteUser(String username) throws AuthException {
+ public void deleteUser(String username) {
throwUnsupportedOperationException();
}
@@ -276,7 +276,7 @@ public class OpenIdAuthorizer extends BasicAuthorizer {
}
@Override
- public void updateUserPassword(String username, String newPassword) throws AuthException {
+ public void updateUserPassword(String username, String newPassword) {
throwUnsupportedOperationException();
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
index 5ee675d..499994b 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
@@ -746,7 +746,7 @@ public class StorageEngine implements IService {
return true;
}
- public void setTTL(PartialPath storageGroup, long dataTTL) throws StorageEngineException {
+ public void setTTL(PartialPath storageGroup, long dataTTL) {
// storage group has no data
if (!processorMap.containsKey(storageGroup)) {
return;
@@ -853,8 +853,7 @@ public class StorageEngine implements IService {
processorMap.get(storageGroup).setPartitionVersionToMax(partitionId, newMaxVersion);
}
- public void removePartitions(PartialPath storageGroupPath, TimePartitionFilter filter)
- throws StorageEngineException {
+ public void removePartitions(PartialPath storageGroupPath, TimePartitionFilter filter) {
processorMap.get(storageGroupPath).removePartitions(filter);
}
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 8d97690..efdb120 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -1318,11 +1318,6 @@ public class StorageGroupProcessor {
if (storageGroupFolder.exists()) {
org.apache.iotdb.db.utils.FileUtils.deleteDirectory(storageGroupFolder);
}
- } catch (IOException e) {
- logger.error(
- "Cannot delete the folder in storage group {}, because",
- logicalStorageGroupName + "-" + virtualStorageGroupId,
- e);
} finally {
writeUnlock();
}
@@ -1395,11 +1390,7 @@ public class StorageGroupProcessor {
fsFactory.getFile(
tsfilePath, logicalStorageGroupName + File.separator + virtualStorageGroupId);
if (storageGroupFolder.exists()) {
- try {
- org.apache.iotdb.db.utils.FileUtils.deleteDirectory(storageGroupFolder);
- } catch (IOException e) {
- logger.error("Delete TsFiles failed", e);
- }
+ org.apache.iotdb.db.utils.FileUtils.deleteDirectory(storageGroupFolder);
}
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java b/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
index d9d45ce..9b16493 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
@@ -937,7 +937,7 @@ public class MTree implements Serializable {
}
/** Traverse the MTree to get the count of devices. */
- private int getDevicesCount(MNode node, String[] nodes, int idx) throws MetadataException {
+ private int getDevicesCount(MNode node, String[] nodes, int idx) {
String nodeReg = MetaUtils.getNodeRegByIdx(idx, nodes);
int cnt = 0;
if (!(PATH_WILDCARD).equals(nodeReg)) {
@@ -963,8 +963,7 @@ public class MTree implements Serializable {
}
/** Traverse the MTree to get the count of storage group. */
- private int getStorageGroupCount(MNode node, String[] nodes, int idx, String parent)
- throws MetadataException {
+ private int getStorageGroupCount(MNode node, String[] nodes, int idx, String parent) {
int cnt = 0;
if (node instanceof StorageGroupMNode && idx >= nodes.length) {
cnt++;
diff --git a/server/src/main/java/org/apache/iotdb/db/metrics/server/JettyUtil.java b/server/src/main/java/org/apache/iotdb/db/metrics/server/JettyUtil.java
index 8b17742..7028e4d 100644
--- a/server/src/main/java/org/apache/iotdb/db/metrics/server/JettyUtil.java
+++ b/server/src/main/java/org/apache/iotdb/db/metrics/server/JettyUtil.java
@@ -27,7 +27,6 @@ import org.eclipse.jetty.servlet.DefaultServlet;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
-import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@@ -50,7 +49,7 @@ public class JettyUtil {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
- throws ServletException, IOException {
+ throws IOException {
resp.setContentType("text/html;charset=utf-8");
resp.setStatus(HttpServletResponse.SC_OK);
PrintWriter out = resp.getWriter();
@@ -60,8 +59,7 @@ public class JettyUtil {
}
@Override
- public void doPost(HttpServletRequest req, HttpServletResponse resp)
- throws ServletException, IOException {
+ public void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOException {
doGet(req, resp);
}
};
diff --git a/server/src/main/java/org/apache/iotdb/db/metrics/server/QueryServlet.java b/server/src/main/java/org/apache/iotdb/db/metrics/server/QueryServlet.java
index bc5b22a..e153cbe 100644
--- a/server/src/main/java/org/apache/iotdb/db/metrics/server/QueryServlet.java
+++ b/server/src/main/java/org/apache/iotdb/db/metrics/server/QueryServlet.java
@@ -20,7 +20,6 @@ package org.apache.iotdb.db.metrics.server;
import org.apache.iotdb.db.metrics.ui.MetricsPage;
-import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@@ -39,8 +38,7 @@ public class QueryServlet extends HttpServlet {
}
@Override
- protected void doGet(HttpServletRequest req, HttpServletResponse resp)
- throws ServletException, IOException {
+ protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException {
resp.setContentType("text/html;charset=utf-8");
req.setCharacterEncoding("utf-8");
resp.setStatus(HttpServletResponse.SC_OK);
@@ -52,8 +50,7 @@ public class QueryServlet extends HttpServlet {
}
@Override
- protected void doPost(HttpServletRequest req, HttpServletResponse resp)
- throws ServletException, IOException {
+ protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOException {
doGet(req, resp);
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
index c35ae48..991a0ac 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
@@ -985,7 +985,7 @@ public class PlanExecutor implements IPlanExecutor {
try {
IoTDB.metaManager.setTTL(plan.getStorageGroup(), plan.getDataTTL());
StorageEngine.getInstance().setTTL(plan.getStorageGroup(), plan.getDataTTL());
- } catch (MetadataException | StorageEngineException e) {
+ } catch (MetadataException e) {
throw new QueryProcessException(e);
} catch (IOException e) {
throw new QueryProcessException(e.getMessage());
diff --git a/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/CountAggrResult.java b/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/CountAggrResult.java
index a049b50..adf0069 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/CountAggrResult.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/CountAggrResult.java
@@ -101,5 +101,5 @@ public class CountAggrResult extends AggregateResult {
protected void deserializeSpecificFields(ByteBuffer buffer) {}
@Override
- protected void serializeSpecificFields(OutputStream outputStream) throws IOException {}
+ protected void serializeSpecificFields(OutputStream outputStream) {}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxValueAggrResult.java b/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxValueAggrResult.java
index 25ca468..cd00df2 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxValueAggrResult.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxValueAggrResult.java
@@ -49,7 +49,7 @@ public class MaxValueAggrResult extends AggregateResult {
}
@Override
- public void updateResultFromPageData(BatchData dataInThisPage) throws IOException {
+ public void updateResultFromPageData(BatchData dataInThisPage) {
updateResultFromPageData(dataInThisPage, Long.MIN_VALUE, Long.MAX_VALUE);
}
@@ -98,7 +98,7 @@ public class MaxValueAggrResult extends AggregateResult {
protected void deserializeSpecificFields(ByteBuffer buffer) {}
@Override
- protected void serializeSpecificFields(OutputStream outputStream) throws IOException {}
+ protected void serializeSpecificFields(OutputStream outputStream) {}
private void updateResult(Comparable<Object> maxVal) {
if (maxVal == null) {
diff --git a/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinValueAggrResult.java b/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinValueAggrResult.java
index 0a67fa4..8b17d75 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinValueAggrResult.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinValueAggrResult.java
@@ -49,13 +49,12 @@ public class MinValueAggrResult extends AggregateResult {
}
@Override
- public void updateResultFromPageData(BatchData dataInThisPage) throws IOException {
+ public void updateResultFromPageData(BatchData dataInThisPage) {
updateResultFromPageData(dataInThisPage, Long.MIN_VALUE, Long.MAX_VALUE);
}
@Override
- public void updateResultFromPageData(BatchData dataInThisPage, long minBound, long maxBound)
- throws IOException {
+ public void updateResultFromPageData(BatchData dataInThisPage, long minBound, long maxBound) {
while (dataInThisPage.hasCurrent()
&& dataInThisPage.currentTime() < maxBound
&& dataInThisPage.currentTime() >= minBound) {
@@ -97,7 +96,7 @@ public class MinValueAggrResult extends AggregateResult {
protected void deserializeSpecificFields(ByteBuffer buffer) {}
@Override
- protected void serializeSpecificFields(OutputStream outputStream) throws IOException {}
+ protected void serializeSpecificFields(OutputStream outputStream) {}
private void updateResult(Comparable<Object> minVal) {
if (minVal == null) {
diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/SingleDataSet.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/SingleDataSet.java
index eea0c07..1ec179a 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/dataset/SingleDataSet.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/SingleDataSet.java
@@ -23,7 +23,6 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.read.common.RowRecord;
import org.apache.iotdb.tsfile.read.query.dataset.QueryDataSet;
-import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
@@ -41,12 +40,12 @@ public class SingleDataSet extends QueryDataSet {
}
@Override
- public boolean hasNextWithoutConstraint() throws IOException {
+ public boolean hasNextWithoutConstraint() {
return i == 0;
}
@Override
- public RowRecord nextWithoutConstraint() throws IOException {
+ public RowRecord nextWithoutConstraint() {
i++;
return record;
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
index 46287f0..c83c84b 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
@@ -88,7 +88,7 @@ public class GroupByTimeDataSet extends QueryDataSet {
}
@Override
- public boolean hasNextWithoutConstraint() throws IOException {
+ public boolean hasNextWithoutConstraint() {
return index < records.size();
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/DiskChunkLoader.java b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/DiskChunkLoader.java
index 269326a..03fba4f 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/DiskChunkLoader.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/DiskChunkLoader.java
@@ -46,7 +46,7 @@ public class DiskChunkLoader implements IChunkLoader {
}
@Override
- public void close() throws IOException {
+ public void close() {
// do nothing
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkLoader.java b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkLoader.java
index 5a19672..d5cb2d8 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkLoader.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkLoader.java
@@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.file.metadata.ChunkMetadata;
import org.apache.iotdb.tsfile.read.common.Chunk;
import org.apache.iotdb.tsfile.read.controller.IChunkLoader;
-import java.io.IOException;
-
/** To read one chunk from memory, and only used in iotdb server module */
public class MemChunkLoader implements IChunkLoader {
@@ -41,7 +39,7 @@ public class MemChunkLoader implements IChunkLoader {
}
@Override
- public void close() throws IOException {
+ public void close() {
// no resources need to close
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkReader.java b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkReader.java
index 70a682b..7f20c43 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkReader.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/MemChunkReader.java
@@ -100,7 +100,7 @@ public class MemChunkReader implements IChunkReader, IPointReader {
}
@Override
- public List<IPageReader> loadPageReaderList() throws IOException {
+ public List<IPageReader> loadPageReaderList() {
return this.pageReaderList;
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/metadata/MemChunkMetadataLoader.java b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/metadata/MemChunkMetadataLoader.java
index e786416..f8d7898 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/metadata/MemChunkMetadataLoader.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/reader/chunk/metadata/MemChunkMetadataLoader.java
@@ -27,7 +27,6 @@ import org.apache.iotdb.tsfile.file.metadata.TimeseriesMetadata;
import org.apache.iotdb.tsfile.read.controller.IChunkMetadataLoader;
import org.apache.iotdb.tsfile.read.filter.basic.Filter;
-import java.io.IOException;
import java.util.List;
public class MemChunkMetadataLoader implements IChunkMetadataLoader {
@@ -76,7 +75,7 @@ public class MemChunkMetadataLoader implements IChunkMetadataLoader {
}
@Override
- public void setDiskChunkLoader(List<ChunkMetadata> chunkMetadataList) throws IOException {
+ public void setDiskChunkLoader(List<ChunkMetadata> chunkMetadataList) {
// DO NOTHING
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReader.java b/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReader.java
index 15a9d05..04cb907 100644
--- a/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReader.java
+++ b/server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReader.java
@@ -76,7 +76,7 @@ public class SeriesAggregateReader implements IAggregateReader {
}
@Override
- public Statistics currentFileStatistics() throws IOException {
+ public Statistics currentFileStatistics() {
return seriesReader.currentFileStatistics();
}
diff --git a/server/src/main/java/org/apache/iotdb/db/service/JMXService.java b/server/src/main/java/org/apache/iotdb/db/service/JMXService.java
index cea28dd..9fe9cee 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/JMXService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/JMXService.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.db.service;
import org.apache.iotdb.db.conf.IoTDBConstant;
-import org.apache.iotdb.db.exception.StartupException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -81,7 +80,7 @@ public class JMXService implements IService {
}
@Override
- public void start() throws StartupException {
+ public void start() {
String jmxPort = System.getProperty(IoTDBConstant.IOTDB_JMX_PORT);
if (jmxPort == null) {
logger.debug("{} JMX port is undefined", this.getID().getName());
diff --git a/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java b/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
index 2ca6e19..582d2cd 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/MQTTService.java
@@ -20,7 +20,6 @@ package org.apache.iotdb.db.service;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.mqtt.BrokerAuthenticator;
import org.apache.iotdb.db.mqtt.PublishHandler;
@@ -45,7 +44,7 @@ public class MQTTService implements IService {
private MQTTService() {}
@Override
- public void start() throws StartupException {
+ public void start() {
startup();
}
diff --git a/server/src/main/java/org/apache/iotdb/db/service/MetricsService.java b/server/src/main/java/org/apache/iotdb/db/service/MetricsService.java
index fd8b3ee..e910dcc 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/MetricsService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/MetricsService.java
@@ -85,7 +85,7 @@ public class MetricsService implements MetricsServiceMBean, IService {
}
@Override
- public synchronized void startService() throws StartupException {
+ public synchronized void startService() {
if (!IoTDBDescriptor.getInstance().getConfig().isEnableMetricService()) {
return;
}
@@ -120,7 +120,7 @@ public class MetricsService implements MetricsServiceMBean, IService {
}
@Override
- public void restartService() throws StartupException {
+ public void restartService() {
stopService();
startService();
}
diff --git a/server/src/main/java/org/apache/iotdb/db/service/RPCService.java b/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
index 216648d..5bbddec 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/RPCService.java
@@ -59,8 +59,7 @@ public class RPCService extends ThriftService implements RPCServiceMBean {
}
@Override
- public void initThriftServiceThread()
- throws IllegalAccessException, InstantiationException, ClassNotFoundException {
+ public void initThriftServiceThread() throws IllegalAccessException {
IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
try {
thriftServiceThread =
diff --git a/server/src/main/java/org/apache/iotdb/db/service/UpgradeSevice.java b/server/src/main/java/org/apache/iotdb/db/service/UpgradeSevice.java
index 876f210..9e4d1b5 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/UpgradeSevice.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/UpgradeSevice.java
@@ -22,7 +22,6 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.engine.StorageEngine;
import org.apache.iotdb.db.engine.upgrade.UpgradeLog;
import org.apache.iotdb.db.engine.upgrade.UpgradeTask;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.utils.UpgradeUtils;
@@ -49,7 +48,7 @@ public class UpgradeSevice implements IService {
}
@Override
- public void start() throws StartupException {
+ public void start() {
int updateThreadNum = IoTDBDescriptor.getInstance().getConfig().getUpgradeThreadNum();
if (updateThreadNum <= 0) {
updateThreadNum = 1;
diff --git a/server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManager.java b/server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManager.java
index ed04771..96ec8ef 100644
--- a/server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManager.java
@@ -66,8 +66,7 @@ public class SyncServerManager extends ThriftService implements SyncServerManage
}
@Override
- public void initThriftServiceThread()
- throws IllegalAccessException, InstantiationException, ClassNotFoundException {
+ public void initThriftServiceThread() {
IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
thriftServiceThread =
new ThriftServiceThread(
diff --git a/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java
index 506837f..38cd717 100644
--- a/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java
@@ -42,7 +42,6 @@ import org.apache.iotdb.service.sync.thrift.ConfirmInfo;
import org.apache.iotdb.service.sync.thrift.SyncService;
import org.apache.iotdb.service.sync.thrift.SyncStatus;
-import org.apache.thrift.TException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -165,7 +164,7 @@ public class SyncServiceImpl implements SyncService.Iface {
}
@Override
- public SyncStatus syncDeletedFileName(String fileName) throws TException {
+ public SyncStatus syncDeletedFileName(String fileName) {
try {
syncLog
.get()
@@ -185,7 +184,7 @@ public class SyncServiceImpl implements SyncService.Iface {
@SuppressWarnings("squid:S2095") // Suppress unclosed resource warning
@Override
- public SyncStatus initSyncData(String filename) throws TException {
+ public SyncStatus initSyncData(String filename) {
try {
File file;
if (currentSG.get() == null) { // schema mlog.txt file
@@ -232,7 +231,7 @@ public class SyncServiceImpl implements SyncService.Iface {
@SuppressWarnings("squid:S2095") // Suppress unclosed resource warning
@Override
- public SyncStatus checkDataDigest(String digestOfSender) throws TException {
+ public SyncStatus checkDataDigest(String digestOfSender) {
String digestOfReceiver = (new BigInteger(1, messageDigest.get().digest())).toString(16);
try {
if (currentFileWriter.get() != null) {
@@ -306,7 +305,7 @@ public class SyncServiceImpl implements SyncService.Iface {
}
@Override
- public SyncStatus endSync() throws TException {
+ public SyncStatus endSync() {
try {
if (syncLog.get() != null) {
syncLog.get().close();
diff --git a/server/src/main/java/org/apache/iotdb/db/tools/watermark/WatermarkDetector.java b/server/src/main/java/org/apache/iotdb/db/tools/watermark/WatermarkDetector.java
index fa43bb3..13568d8 100644
--- a/server/src/main/java/org/apache/iotdb/db/tools/watermark/WatermarkDetector.java
+++ b/server/src/main/java/org/apache/iotdb/db/tools/watermark/WatermarkDetector.java
@@ -188,7 +188,7 @@ public class WatermarkDetector {
* @param alpha significance level
* @return the minimum b
*/
- private static int calMin(int l, double alpha) throws IOException {
+ private static int calMin(int l, double alpha) {
int b = l;
BigDecimal sum = new BigDecimal("1");
diff --git a/server/src/main/java/org/apache/iotdb/db/utils/FileUtils.java b/server/src/main/java/org/apache/iotdb/db/utils/FileUtils.java
index 65d21d6..881cd61 100644
--- a/server/src/main/java/org/apache/iotdb/db/utils/FileUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/utils/FileUtils.java
@@ -23,7 +23,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
-import java.io.IOException;
import java.nio.file.DirectoryNotEmptyException;
import java.nio.file.Files;
import java.nio.file.NoSuchFileException;
@@ -34,7 +33,7 @@ public class FileUtils {
private FileUtils() {}
- public static void deleteDirectory(File folder) throws IOException {
+ public static void deleteDirectory(File folder) {
if (folder.isDirectory()) {
for (File file : folder.listFiles()) {
deleteDirectory(file);
diff --git a/server/src/main/java/org/apache/iotdb/db/utils/SchemaUtils.java b/server/src/main/java/org/apache/iotdb/db/utils/SchemaUtils.java
index dadc0c0..a3b6920 100644
--- a/server/src/main/java/org/apache/iotdb/db/utils/SchemaUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/utils/SchemaUtils.java
@@ -160,7 +160,7 @@ public class SchemaUtils {
* @throws MetadataException
*/
public static List<TSDataType> getAggregatedDataTypes(
- List<TSDataType> measurementDataType, String aggregation) throws MetadataException {
+ List<TSDataType> measurementDataType, String aggregation) {
TSDataType dataType = getAggregationType(aggregation);
if (dataType != null) {
return Collections.nCopies(measurementDataType.size(), dataType);
diff --git a/server/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java b/server/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java
index dfaff9a..08498d7 100644
--- a/server/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/auth/authorizer/OpenIdAuthorizerTest.java
@@ -40,7 +40,7 @@ public class OpenIdAuthorizerTest {
private static final IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
@Test
- public void loginWithJWT() throws AuthException, ParseException, URISyntaxException {
+ public void loginWithJWT() throws AuthException, ParseException {
String jwt =
"eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJxMS1XbTBvelE1TzBtUUg4LVNKYXAyWmNONE1tdWNXd25RV0tZeFpKNG93In0.eyJleHAiOjE1OTAzMTcxNzYsImlhdCI6MTU5MDMxNjg3NiwianRpIjoiY2MyNWQ3MDAtYjc5NC00OTA4LTg0OGUtOTRhNzYzNmM5YzQxIiwiaXNzIjoiaHR0cDovL2F1dGguZGVtby5wcmFnbWF0aWNpbmR1c3RyaWVzLmRlL2F1dGgvcmVhbG1zL0lvVERCIiwiYXVkIjoiYWNjb3VudCIsInN1YiI6Ijg2YWRmNGIzLWE4ZTUtNDc1NC1iNWEwLTQ4OGI0OWY0M2VkMiIsInR5cCI6IkJlYXJlciIsImF6cCI6ImlvdGRiIiwic2Vzc2lvbl9zdGF0ZSI6Ijk0ZmI5NGZjLTg3YTMtNDg4Ny04M2Q3LWE [...]
diff --git a/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleAccessorTest.java b/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleAccessorTest.java
index 03513d2..00e6ef8 100644
--- a/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleAccessorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleAccessorTest.java
@@ -43,7 +43,7 @@ public class LocalFileRoleAccessorTest {
private LocalFileRoleAccessor accessor;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
testFolder = new File(TestConstant.BASE_OUTPUT_PATH.concat("test"));
testFolder.mkdirs();
diff --git a/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleManagerTest.java b/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleManagerTest.java
index 62a672c..c7fe76d 100644
--- a/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleManagerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/auth/role/LocalFileRoleManagerTest.java
@@ -43,7 +43,7 @@ public class LocalFileRoleManagerTest {
private LocalFileRoleManager manager;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
testFolder = new File(TestConstant.BASE_OUTPUT_PATH.concat("test"));
testFolder.mkdirs();
diff --git a/server/src/test/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessorTest.java b/server/src/test/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessorTest.java
index f404cd0..604cb2b 100644
--- a/server/src/test/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/auth/user/LocalFileUserAccessorTest.java
@@ -44,7 +44,7 @@ public class LocalFileUserAccessorTest {
private LocalFileUserAccessor accessor;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
testFolder = new File(TestConstant.BASE_OUTPUT_PATH.concat("test"));
testFolder.mkdirs();
diff --git a/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBDefaultThreadExceptionHandlerTest.java b/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBDefaultThreadExceptionHandlerTest.java
index c96da16..9a05015 100644
--- a/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBDefaultThreadExceptionHandlerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBDefaultThreadExceptionHandlerTest.java
@@ -33,14 +33,14 @@ public class IoTDBDefaultThreadExceptionHandlerTest {
private AtomicInteger count;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
handler = Thread.getDefaultUncaughtExceptionHandler();
Thread.setDefaultUncaughtExceptionHandler(new TestExceptionHandler(message));
count = new AtomicInteger(0);
}
@After
- public void tearDown() throws Exception {
+ public void tearDown() {
Thread.setDefaultUncaughtExceptionHandler(handler);
}
diff --git a/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactoryTest.java b/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactoryTest.java
index ddfdd08..72de1f6 100644
--- a/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactoryTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactoryTest.java
@@ -50,7 +50,7 @@ public class IoTDBThreadPoolFactoryTest {
public void tearDown() throws Exception {}
@Test
- public void testNewFixedThreadPool() throws InterruptedException, ExecutionException {
+ public void testNewFixedThreadPool() {
String reason = "(can be ignored in Tests) NewFixedThreadPool";
Thread.UncaughtExceptionHandler handler = new TestExceptionHandler(reason);
int threadCount = 4;
@@ -70,7 +70,7 @@ public class IoTDBThreadPoolFactoryTest {
}
@Test
- public void testNewSingleThreadExecutor() throws InterruptedException {
+ public void testNewSingleThreadExecutor() {
String reason = "(can be ignored in Tests)NewSingleThreadExecutor";
Thread.UncaughtExceptionHandler handler = new TestExceptionHandler(reason);
int threadCount = 2;
@@ -89,7 +89,7 @@ public class IoTDBThreadPoolFactoryTest {
}
@Test
- public void testNewCachedThreadPool() throws InterruptedException {
+ public void testNewCachedThreadPool() {
String reason = "(can be ignored in Tests) NewCachedThreadPool";
Thread.UncaughtExceptionHandler handler = new TestExceptionHandler(reason);
int threadCount = 4;
@@ -162,7 +162,7 @@ public class IoTDBThreadPoolFactoryTest {
}
@Test
- public void testCreateJDBCClientThreadPool() throws InterruptedException {
+ public void testCreateJDBCClientThreadPool() {
String reason = "(can be ignored in Tests) CreateJDBCClientThreadPool";
TThreadPoolServer.Args args = new Args(null);
args.maxWorkerThreads = 4;
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskTest.java b/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskTest.java
index a9af3ab..a1b5d55 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemTableFlushTaskTest.java
@@ -30,7 +30,6 @@ import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import java.io.IOException;
import java.util.concurrent.ExecutionException;
import static org.junit.Assert.assertEquals;
@@ -62,7 +61,7 @@ public class MemTableFlushTaskTest {
}
@Test
- public void testFlushMemTable() throws ExecutionException, InterruptedException, IOException {
+ public void testFlushMemTable() throws ExecutionException, InterruptedException {
MemTableTestUtils.produceData(
memTable,
startTime,
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemtableBenchmark.java b/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemtableBenchmark.java
index 0d5a76a..0e0951f 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemtableBenchmark.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/memtable/MemtableBenchmark.java
@@ -18,7 +18,6 @@
*/
package org.apache.iotdb.db.engine.memtable;
-import org.apache.iotdb.db.exception.WriteProcessException;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
@@ -39,7 +38,7 @@ public class MemtableBenchmark {
}
}
- public static void main(String[] args) throws WriteProcessException {
+ public static void main(String[] args) {
IMemTable memTable = new PrimitiveMemTable();
final long startTime = System.currentTimeMillis();
// cpu not locality
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionFileNodeTest.java b/server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionFileNodeTest.java
index 180e906..bfe9522 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionFileNodeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionFileNodeTest.java
@@ -277,8 +277,7 @@ public class DeletionFileNodeTest {
}
@Test
- public void testDeleteInOverflowFile()
- throws StorageEngineException, QueryProcessException, IllegalPathException {
+ public void testDeleteInOverflowFile() throws StorageEngineException, IllegalPathException {
// insert into BufferWrite
for (int i = 101; i <= 200; i++) {
TSRecord record = new TSRecord(i, processorName);
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/modification/io/LocalTextModificationAccessorTest.java b/server/src/test/java/org/apache/iotdb/db/engine/modification/io/LocalTextModificationAccessorTest.java
index ed835b6..bfd4dc6 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/modification/io/LocalTextModificationAccessorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/modification/io/LocalTextModificationAccessorTest.java
@@ -71,7 +71,7 @@ public class LocalTextModificationAccessorTest {
}
@Test
- public void readNull() throws IOException {
+ public void readNull() {
String tempFileName = TestConstant.BASE_OUTPUT_PATH.concat("mod.temp");
LocalTextModificationAccessor accessor = new LocalTextModificationAccessor(tempFileName);
new File(tempFileName).delete();
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TTLTest.java b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TTLTest.java
index fd2dd5e..1943ef3 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TTLTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TTLTest.java
@@ -25,7 +25,6 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.conf.directories.DirectoryManager;
import org.apache.iotdb.db.engine.flush.TsFileFlushPolicy.DirectFlushPolicy;
import org.apache.iotdb.db.engine.querycontext.QueryDataSource;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.StorageGroupProcessorException;
import org.apache.iotdb.db.exception.WriteProcessException;
@@ -86,8 +85,7 @@ public class TTLTest {
private int prevUnseqLevelNum;
@Before
- public void setUp()
- throws MetadataException, IOException, StartupException, StorageGroupProcessorException {
+ public void setUp() throws MetadataException, StorageGroupProcessorException {
prevUnseqLevelNum = IoTDBDescriptor.getInstance().getConfig().getUnseqLevelNum();
IoTDBDescriptor.getInstance().getConfig().setUnseqLevelNum(2);
prevPartitionInterval = IoTDBDescriptor.getInstance().getConfig().getPartitionInterval();
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
index 1fef861..f972a83 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
@@ -72,7 +72,7 @@ public class TsFileProcessorTest {
protected static final int INIT_ARRAY_SIZE = 64;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
MetadataManagerHelper.initMetadata();
context = EnvironmentUtils.TEST_QUERY_CONTEXT;
diff --git a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/HashVirtualPartitionerTest.java b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/HashVirtualPartitionerTest.java
index 3fc7976..b58e29a 100644
--- a/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/HashVirtualPartitionerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/HashVirtualPartitionerTest.java
@@ -34,7 +34,7 @@ import static org.junit.Assert.assertEquals;
public class HashVirtualPartitionerTest {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
// init file dir
StorageEngine.getInstance();
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
index a2a7011..8f9b7ce 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBAutoCreateSchemaIT.java
@@ -42,7 +42,7 @@ import java.sql.Statement;
public class IoTDBAutoCreateSchemaIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCheckConfigIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCheckConfigIT.java
index c5f66ee..56d8dea 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCheckConfigIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCheckConfigIT.java
@@ -63,7 +63,7 @@ public class IoTDBCheckConfigIT {
private ByteArrayOutputStream bytes = null;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBClearCacheIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBClearCacheIT.java
index eb289db..bceb825 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBClearCacheIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBClearCacheIT.java
@@ -32,7 +32,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.assertFalse;
@@ -127,7 +126,7 @@ public class IoTDBClearCacheIT {
EnvironmentUtils.cleanEnv();
}
- private static void importData() throws ClassNotFoundException, SQLException {
+ private static void importData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCloseIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCloseIT.java
index ce36f23..66f6b75 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCloseIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCloseIT.java
@@ -33,7 +33,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.fail;
@@ -81,7 +80,7 @@ public class IoTDBCloseIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompleteIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompleteIT.java
index 1da4ebc..383f8d8 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompleteIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompleteIT.java
@@ -38,7 +38,7 @@ import java.sql.*;
public class IoTDBCompleteIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
// test different partition
HashVirtualPartitioner.getInstance().setStorageGroupNum(16);
EnvironmentUtils.closeStatMonitor();
@@ -53,7 +53,7 @@ public class IoTDBCompleteIT {
}
@Test
- public void test() throws ClassNotFoundException, SQLException {
+ public void test() throws ClassNotFoundException {
String[] sqls = {"SET STORAGE GROUP TO root.vehicle"};
executeSQL(sqls);
// simpleTest();
@@ -66,7 +66,7 @@ public class IoTDBCompleteIT {
// funcTestWithOutTimeGenerator();
}
- public void simpleTest() throws ClassNotFoundException, SQLException {
+ public void simpleTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"SHOW TIMESERIES",
@@ -183,7 +183,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- public void insertTest() throws ClassNotFoundException, SQLException {
+ public void insertTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.vehicle.d0(timestamp,s0) values(1,101)",
@@ -198,7 +198,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- public void deleteTest() throws ClassNotFoundException, SQLException {
+ public void deleteTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.vehicle.d0(timestamp,s0) values(1,101)",
@@ -256,7 +256,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- public void selectTest() throws ClassNotFoundException, SQLException {
+ public void selectTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.vehicle.d0(timestamp,s0) values(1,101)",
@@ -289,7 +289,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- public void funcTest() throws ClassNotFoundException, SQLException {
+ public void funcTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.vehicle.d0(timestamp,s0) values(1,110)",
@@ -337,7 +337,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- public void funcTestWithOutTimeGenerator() throws ClassNotFoundException, SQLException {
+ public void funcTestWithOutTimeGenerator() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.vehicle.d0(timestamp,s0) values(1,110)",
@@ -392,7 +392,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- public void groupByTest() throws ClassNotFoundException, SQLException {
+ public void groupByTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.vehicle.d0.s0 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.vehicle.d0(timestamp,s0) values(1,110)",
@@ -427,7 +427,7 @@ public class IoTDBCompleteIT {
executeSQL(sqlS);
}
- private void executeSQL(String[] sqls) throws ClassNotFoundException, SQLException {
+ private void executeSQL(String[] sqls) throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompressTypeIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompressTypeIT.java
index a213c1c..c04a4e9 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompressTypeIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompressTypeIT.java
@@ -39,7 +39,7 @@ import java.sql.Statement;
*/
public class IoTDBCompressTypeIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateSnapshotIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateSnapshotIT.java
index e1df1fc..6f0ce2e 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateSnapshotIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateSnapshotIT.java
@@ -144,7 +144,7 @@ public class IoTDBCreateSnapshotIT {
}
}
- private static void prepareData() throws SQLException {
+ private static void prepareData() {
try (Connection connection =
DriverManager.getConnection(
Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDaemonIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDaemonIT.java
index e4ddfd7..f1c7775 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDaemonIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDaemonIT.java
@@ -106,7 +106,7 @@ public class IoTDBDaemonIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -215,7 +215,7 @@ public class IoTDBDaemonIT {
}
@Test
- public void selectAllSQLTest() throws ClassNotFoundException, SQLException {
+ public void selectAllSQLTest() throws ClassNotFoundException {
String[] retArray =
new String[] {
"1,101,1101,null,null,999",
@@ -290,7 +290,7 @@ public class IoTDBDaemonIT {
}
@Test
- public void selectWildCardSQLTest() throws ClassNotFoundException, SQLException {
+ public void selectWildCardSQLTest() throws ClassNotFoundException {
String[] retArray =
new String[] {"2,2.22", "3,3.33", "4,4.44", "102,10.0", "105,11.11", "1000,1000.11"};
@@ -321,7 +321,7 @@ public class IoTDBDaemonIT {
}
@Test
- public void dnfErrorSQLTest() throws ClassNotFoundException, SQLException {
+ public void dnfErrorSQLTest() throws ClassNotFoundException {
String[] retArray =
new String[] {
"1,101,1101",
@@ -366,7 +366,7 @@ public class IoTDBDaemonIT {
}
@Test
- public void selectAndOperatorTest() throws ClassNotFoundException, SQLException {
+ public void selectAndOperatorTest() throws ClassNotFoundException {
String[] retArray = new String[] {"1000,22222,55555,888"};
Class.forName(Config.JDBC_DRIVER_NAME);
@@ -403,7 +403,7 @@ public class IoTDBDaemonIT {
}
@Test
- public void selectAndOpeCrossTest() throws ClassNotFoundException, SQLException {
+ public void selectAndOpeCrossTest() throws ClassNotFoundException {
String[] retArray = new String[] {"1000,22222,55555"};
Class.forName(Config.JDBC_DRIVER_NAME);
@@ -437,7 +437,7 @@ public class IoTDBDaemonIT {
}
@Test
- public void selectOneColumnWithFilterTest() throws ClassNotFoundException, SQLException {
+ public void selectOneColumnWithFilterTest() throws ClassNotFoundException {
String[] retArray = new String[] {"102,180", "104,190", "946684800000,100"};
Class.forName(Config.JDBC_DRIVER_NAME);
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteStorageGroupIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteStorageGroupIT.java
index 712ecbf..13c0e84 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteStorageGroupIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteStorageGroupIT.java
@@ -40,7 +40,7 @@ import static org.junit.Assert.assertTrue;
public class IoTDBDeleteStorageGroupIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteTimeseriesIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteTimeseriesIT.java
index 15af541..558d7ba 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteTimeseriesIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBDeleteTimeseriesIT.java
@@ -41,7 +41,7 @@ public class IoTDBDeleteTimeseriesIT {
private CompactionStrategy tsFileManagementStrategy;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
memtableSizeThreshold = IoTDBDescriptor.getInstance().getConfig().getMemtableSizeThreshold();
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBEngineTimeGeneratorIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBEngineTimeGeneratorIT.java
index a283ed0..a407796 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBEngineTimeGeneratorIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBEngineTimeGeneratorIT.java
@@ -44,7 +44,6 @@ import org.junit.Test;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
-import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
@@ -100,7 +99,7 @@ public class IoTDBEngineTimeGeneratorIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFillIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFillIT.java
index c70811d..1647f29 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFillIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFillIT.java
@@ -30,7 +30,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.fail;
@@ -149,7 +148,7 @@ public class IoTDBFillIT {
}
@Test
- public void LinearFillCommonTest() throws SQLException {
+ public void LinearFillCommonTest() {
String[] retArray1 =
new String[] {"3,3.3,false,33", "70,70.34,false,374", "70,70.34,false,374"};
try (Connection connection =
@@ -232,7 +231,7 @@ public class IoTDBFillIT {
}
@Test
- public void LinearFillWithBeforeOrAfterValueNullTest() throws SQLException {
+ public void LinearFillWithBeforeOrAfterValueNullTest() {
String[] retArray1 =
new String[] {"70,null,null,null", "80,null,null,null", "625,null,false,null"};
try (Connection connection =
@@ -395,7 +394,7 @@ public class IoTDBFillIT {
}
@Test
- public void EmptyTimeRangeFillTest() throws SQLException {
+ public void EmptyTimeRangeFillTest() {
String[] retArray1 = new String[] {"3,3.3,false,33", "70,70.34,false,374"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -454,7 +453,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillWithOnlySeqFileTest() throws SQLException {
+ public void PreviousFillWithOnlySeqFileTest() {
String[] retArray = new String[] {"1050,1020.5,false", "800,55.2,true"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -503,7 +502,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillWithOnlyUnseqFileOverlappedTest() throws SQLException {
+ public void PreviousFillWithOnlyUnseqFileOverlappedTest() {
String[] retArray = new String[] {"58,82.1,true", "40,121.22,true", "80,32.2,false"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -577,7 +576,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillMultiUnseqFileWithSameLastTest() throws SQLException {
+ public void PreviousFillMultiUnseqFileWithSameLastTest() {
String[] retArray =
new String[] {
"59,82.1,true", "52,32.2,false",
@@ -639,7 +638,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillSeqFileFilterOverlappedFilesTest() throws SQLException {
+ public void PreviousFillSeqFileFilterOverlappedFilesTest() {
String[] retArray1 =
new String[] {
"886,55.2,true", "730,121.22,true",
@@ -704,7 +703,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillUnseqFileFilterOverlappedFilesTest() throws SQLException {
+ public void PreviousFillUnseqFileFilterOverlappedFilesTest() {
String[] retArray1 =
new String[] {
"990,121.22,true", "925,33.1,false",
@@ -772,7 +771,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillWithNullUnseqFilesTest() throws SQLException {
+ public void PreviousFillWithNullUnseqFilesTest() {
String[] retArray1 =
new String[] {
"990,1020.5,true",
@@ -817,7 +816,7 @@ public class IoTDBFillIT {
}
@Test
- public void PreviousFillWithDeletionTest() throws SQLException {
+ public void PreviousFillWithDeletionTest() {
String[] retArray1 =
new String[] {
"1080,21.6,true",
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFloatPrecisionIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFloatPrecisionIT.java
index bc3dd38..933f230 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFloatPrecisionIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBFloatPrecisionIT.java
@@ -32,7 +32,6 @@ import java.math.RoundingMode;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
@@ -87,7 +86,7 @@ public class IoTDBFloatPrecisionIT {
}
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -103,7 +102,7 @@ public class IoTDBFloatPrecisionIT {
}
@Test
- public void selectAllSQLTest() throws ClassNotFoundException, SQLException {
+ public void selectAllSQLTest() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLargeDataIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLargeDataIT.java
index 3bc5738..a0fbae6 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLargeDataIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLargeDataIT.java
@@ -35,7 +35,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.assertEquals;
@@ -93,8 +92,7 @@ public class IoTDBLargeDataIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData()
- throws ClassNotFoundException, SQLException, InterruptedException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -242,7 +240,7 @@ public class IoTDBLargeDataIT {
// "select * from root.vehicle" : test select wild data
@Test
- public void selectAllTest() throws ClassNotFoundException, SQLException {
+ public void selectAllTest() throws ClassNotFoundException {
String selectSql = "select * from root.vehicle";
Class.forName(Config.JDBC_DRIVER_NAME);
@@ -292,7 +290,7 @@ public class IoTDBLargeDataIT {
// "select s0 from root.vehicle.d0 where s0 >= 20" : test select same series with same series
// filter
@Test
- public void selectOneSeriesWithValueFilterTest() throws ClassNotFoundException, SQLException {
+ public void selectOneSeriesWithValueFilterTest() throws ClassNotFoundException {
String selectSql = "select s0 from root.vehicle.d0 where s0 >= 20";
@@ -327,7 +325,7 @@ public class IoTDBLargeDataIT {
// "select s0 from root.vehicle.d0 where time > 22987 " : test select clause with only global time
// filter
@Test
- public void seriesGlobalTimeFilterTest() throws ClassNotFoundException, SQLException {
+ public void seriesGlobalTimeFilterTest() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
@@ -363,7 +361,7 @@ public class IoTDBLargeDataIT {
// "select s1 from root.vehicle.d0 where s0 < 111" : test select clause with different series
// filter
@Test
- public void crossSeriesReadUpdateTest() throws ClassNotFoundException, SQLException {
+ public void crossSeriesReadUpdateTest() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
boolean hasResultSet;
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLastIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLastIT.java
index f8a8856..c1327e3 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLastIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLastIT.java
@@ -441,7 +441,7 @@ public class IoTDBLastIT {
}
@Test
- public void lastAfterDeletionTest() throws SQLException, MetadataException {
+ public void lastAfterDeletionTest() throws SQLException {
String[] retArray =
new String[] {
"350,root.ln.wf01.wt05.temperature,31.2", "200,root.ln.wf01.wt05.temperature,78.2"
@@ -497,7 +497,7 @@ public class IoTDBLastIT {
}
@Test
- public void lastWithFilterTest() throws SQLException, MetadataException {
+ public void lastWithFilterTest() throws SQLException {
String[] retArray = new String[] {"500,root.ln.wf01.wt01.temperature,22.1"};
try (Connection connection =
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLimitSlimitIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLimitSlimitIT.java
index a251171..41d8276 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLimitSlimitIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBLimitSlimitIT.java
@@ -33,7 +33,6 @@ import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.fail;
@@ -84,7 +83,7 @@ public class IoTDBLimitSlimitIT {
};
@BeforeClass
- public static void setUp() throws Exception {
+ public static void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
@@ -94,7 +93,7 @@ public class IoTDBLimitSlimitIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -111,12 +110,12 @@ public class IoTDBLimitSlimitIT {
}
@Test
- public void Test() throws ClassNotFoundException, SQLException {
+ public void Test() throws ClassNotFoundException {
insertData();
SelectTest();
}
- public void SelectTest() throws ClassNotFoundException, SQLException {
+ public void SelectTest() throws ClassNotFoundException {
String[] sqlS = {
"SELECT s1 FROM root.vehicle.d0 WHERE time<200 limit 3",
"1,1101,\n" + "2,40000,\n" + "50,50000,\n",
@@ -146,7 +145,7 @@ public class IoTDBLimitSlimitIT {
executeSQL(sqlS);
}
- private void executeSQL(String[] sqls) throws ClassNotFoundException, SQLException {
+ private void executeSQL(String[] sqls) throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMetadataFetchIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMetadataFetchIT.java
index 2cfb4a9..5359640 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMetadataFetchIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMetadataFetchIT.java
@@ -55,7 +55,7 @@ public class IoTDBMetadataFetchIT {
private DatabaseMetaData databaseMetaData;
private static final Logger logger = LoggerFactory.getLogger(IoTDBMetadataFetchIT.class);
- private static void insertSQL() throws ClassNotFoundException, SQLException {
+ private static void insertSQL() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiDeviceIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiDeviceIT.java
index 5298006..5ffac74 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiDeviceIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiDeviceIT.java
@@ -34,7 +34,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.assertEquals;
@@ -95,7 +94,7 @@ public class IoTDBMultiDeviceIT {
.setCompactionStrategy(CompactionStrategy.LEVEL_COMPACTION);
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiSeriesIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiSeriesIT.java
index ddf142f..b74d43c 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiSeriesIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiSeriesIT.java
@@ -99,7 +99,7 @@ public class IoTDBMultiSeriesIT {
.setCompactionStrategy(CompactionStrategy.LEVEL_COMPACTION);
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -318,7 +318,7 @@ public class IoTDBMultiSeriesIT {
// "select s0 from root.vehicle.d0 where s0 >= 20" : test select same series with same series
// filter
@Test
- public void selectOneSeriesWithValueFilterTest() throws ClassNotFoundException, SQLException {
+ public void selectOneSeriesWithValueFilterTest() throws ClassNotFoundException {
String selectSql = "select s0 from root.vehicle.d0 where s0 >= 20";
@@ -352,7 +352,7 @@ public class IoTDBMultiSeriesIT {
// "select s0 from root.vehicle.d0 where time > 22987 " : test select clause with only global time
// filter
@Test
- public void seriesGlobalTimeFilterTest() throws ClassNotFoundException, SQLException {
+ public void seriesGlobalTimeFilterTest() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
@@ -387,7 +387,7 @@ public class IoTDBMultiSeriesIT {
// "select s1 from root.vehicle.d0 where s0 < 111" : test select clause with different series
// filter
@Test
- public void crossSeriesReadUpdateTest() throws ClassNotFoundException, SQLException {
+ public void crossSeriesReadUpdateTest() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
boolean hasResultSet;
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiStatementsIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiStatementsIT.java
index 557c584..633a0ee 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiStatementsIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBMultiStatementsIT.java
@@ -34,7 +34,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.fail;
@@ -88,7 +87,7 @@ public class IoTDBMultiStatementsIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNumberPathIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNumberPathIT.java
index acfddeb..cccc5dc 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNumberPathIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBNumberPathIT.java
@@ -32,7 +32,6 @@ import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
-import java.sql.SQLException;
import java.sql.Statement;
/**
@@ -42,7 +41,7 @@ import java.sql.Statement;
public class IoTDBNumberPathIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
@@ -53,7 +52,7 @@ public class IoTDBNumberPathIT {
}
@Test
- public void test() throws ClassNotFoundException, SQLException {
+ public void test() throws ClassNotFoundException {
String[] sqls = {"SET STORAGE GROUP TO root.123"};
executeSQL(sqls);
// simpleTest();
@@ -66,7 +65,7 @@ public class IoTDBNumberPathIT {
// funcTestWithOutTimeGenerator();
}
- public void simpleTest() throws ClassNotFoundException, SQLException {
+ public void simpleTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"SHOW TIMESERIES",
@@ -183,7 +182,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- public void insertTest() throws ClassNotFoundException, SQLException {
+ public void insertTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.123.456(timestamp,789) values(1,101)",
@@ -198,7 +197,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- public void deleteTest() throws ClassNotFoundException, SQLException {
+ public void deleteTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.123.456(timestamp,789) values(1,101)",
@@ -256,7 +255,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- public void selectTest() throws ClassNotFoundException, SQLException {
+ public void selectTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.123.456(timestamp,789) values(1,101)",
@@ -289,7 +288,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- public void funcTest() throws ClassNotFoundException, SQLException {
+ public void funcTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.123.456(timestamp,789) values(1,110)",
@@ -337,7 +336,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- public void funcTestWithOutTimeGenerator() throws ClassNotFoundException, SQLException {
+ public void funcTestWithOutTimeGenerator() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.123.456(timestamp,789) values(1,110)",
@@ -392,7 +391,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- public void groupByTest() throws ClassNotFoundException, SQLException {
+ public void groupByTest() throws ClassNotFoundException {
String[] sqlS = {
"CREATE TIMESERIES root.123.456.789 WITH DATATYPE=INT32,ENCODING=RLE",
"INSERT INTO root.123.456(timestamp,789) values(1,110)",
@@ -427,7 +426,7 @@ public class IoTDBNumberPathIT {
executeSQL(sqlS);
}
- private void executeSQL(String[] sqls) throws ClassNotFoundException, SQLException {
+ private void executeSQL(String[] sqls) throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryDemoIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryDemoIT.java
index f059c8a..208478c 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryDemoIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryDemoIT.java
@@ -127,7 +127,7 @@ public class IoTDBQueryDemoIT {
EnvironmentUtils.cleanEnv();
}
- private static void importData() throws ClassNotFoundException, SQLException {
+ private static void importData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQuotedPathIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQuotedPathIT.java
index 38e4a05..79bd685 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQuotedPathIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBQuotedPathIT.java
@@ -52,7 +52,7 @@ public class IoTDBQuotedPathIT {
}
@Test
- public void test() throws SQLException {
+ public void test() {
try (Connection connection =
DriverManager.getConnection(
Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverIT.java
index 350dd16..5190853 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverIT.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.db.integration;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.utils.EnvironmentUtils;
import org.apache.iotdb.jdbc.Config;
@@ -28,7 +27,6 @@ import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
-import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
@@ -95,7 +93,7 @@ public class IoTDBRecoverIT {
}
@Test
- public void mergeTest() throws SQLException, IOException, StartupException {
+ public void mergeTest() {
String[] retArray = new String[] {"0,2", "0,4", "0,3"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverUnclosedIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverUnclosedIT.java
index 0a2e527..3143653 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverUnclosedIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverUnclosedIT.java
@@ -221,7 +221,7 @@ public class IoTDBRecoverUnclosedIT {
}
}
- private void prepareData() throws SQLException {
+ private void prepareData() {
try (Connection connection =
DriverManager.getConnection(
Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
@@ -239,7 +239,7 @@ public class IoTDBRecoverUnclosedIT {
}
}
- private void insertMoreData() throws SQLException {
+ private void insertMoreData() {
try (Connection connection =
DriverManager.getConnection(
Config.IOTDB_URL_PREFIX + "127.0.0.1:6667/", "root", "root");
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
index 14a8287..1be2626 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBRemovePartitionIT.java
@@ -20,7 +20,6 @@
package org.apache.iotdb.db.integration;
import org.apache.iotdb.db.engine.StorageEngine;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.metadata.PartialPath;
import org.apache.iotdb.db.utils.EnvironmentUtils;
@@ -62,7 +61,7 @@ public class IoTDBRemovePartitionIT {
}
@Test
- public void testRemoveNoPartition() throws StorageEngineException, IllegalPathException {
+ public void testRemoveNoPartition() throws IllegalPathException {
StorageEngine.getInstance()
.removePartitions(
new PartialPath("root.test1"), (storageGroupName, timePartitionId) -> false);
@@ -86,7 +85,7 @@ public class IoTDBRemovePartitionIT {
}
@Test
- public void testRemovePartialPartition() throws StorageEngineException, IllegalPathException {
+ public void testRemovePartialPartition() throws IllegalPathException {
StorageEngine.getInstance()
.removePartitions(
new PartialPath("root.test1"),
@@ -125,7 +124,7 @@ public class IoTDBRemovePartitionIT {
}
@Test
- public void testRemoveAllPartition() throws StorageEngineException, IllegalPathException {
+ public void testRemoveAllPartition() throws IllegalPathException {
StorageEngine.getInstance()
.removePartitions(
new PartialPath("root.test1"), (storageGroupName, timePartitionId) -> true);
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSameMeasurementsDifferentTypesIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSameMeasurementsDifferentTypesIT.java
index a53c696..a5fd296 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSameMeasurementsDifferentTypesIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSameMeasurementsDifferentTypesIT.java
@@ -33,7 +33,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.fail;
@@ -81,7 +80,7 @@ public class IoTDBSameMeasurementsDifferentTypesIT {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSimpleQueryIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSimpleQueryIT.java
index b2a6638..533ebec 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSimpleQueryIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBSimpleQueryIT.java
@@ -52,7 +52,7 @@ import static org.junit.Assert.fail;
public class IoTDBSimpleQueryIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagAlterIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagAlterIT.java
index 8d1f60c..66d4cb5 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagAlterIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagAlterIT.java
@@ -38,7 +38,7 @@ import static org.junit.Assert.fail;
public class IoTDBTagAlterIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagIT.java
index 1e7dd2d..ad6a17f 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBTagIT.java
@@ -42,7 +42,7 @@ import static org.junit.Assert.fail;
public class IoTDBTagIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBVersionIT.java b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBVersionIT.java
index d7cf617..cde97a3 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/IoTDBVersionIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/IoTDBVersionIT.java
@@ -34,7 +34,7 @@ import java.sql.Statement;
public class IoTDBVersionIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationIT.java b/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationIT.java
index 81eaf95..7f5981e 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationIT.java
@@ -126,7 +126,7 @@ public class IoTDBAggregationIT {
// add test for part of points in page don't satisfy filter
// details in: https://issues.apache.org/jira/projects/IOTDB/issues/IOTDB-54
@Test
- public void test() throws SQLException {
+ public void test() {
String[] retArray = new String[] {"0,2", "0,4", "0,3"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -207,7 +207,7 @@ public class IoTDBAggregationIT {
}
@Test
- public void countTest() throws SQLException {
+ public void countTest() {
String[] retArray = new String[] {"0,2001,2001,2001,2001", "0,7500,7500,7500,7500"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -400,7 +400,7 @@ public class IoTDBAggregationIT {
}
@Test
- public void lastTest() throws SQLException {
+ public void lastTest() {
String[] retArray = new String[] {"0,8499,8499.0", "0,1499,1499.0", "0,2200,2200.0"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -512,7 +512,7 @@ public class IoTDBAggregationIT {
}
@Test
- public void maxminTimeTest() throws SQLException {
+ public void maxminTimeTest() {
String[] retArray = new String[] {"0,8499,500", "0,2499,2000"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
@@ -618,7 +618,7 @@ public class IoTDBAggregationIT {
}
@Test
- public void maxminValueTest() throws SQLException {
+ public void maxminValueTest() {
String[] retArray = new String[] {"0,8499,500.0", "0,2499,500.0"};
try (Connection connection =
DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", "root", "root");
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationLargeDataIT.java b/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationLargeDataIT.java
index db23680..294f02e 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationLargeDataIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBAggregationLargeDataIT.java
@@ -32,7 +32,6 @@ import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.apache.iotdb.db.constant.TestConstant.avg;
@@ -114,7 +113,7 @@ public class IoTDBAggregationLargeDataIT {
private long prevPartitionInterval;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
prevPartitionInterval = IoTDBDescriptor.getInstance().getConfig().getPartitionInterval();
IoTDBDescriptor.getInstance()
@@ -133,7 +132,7 @@ public class IoTDBAggregationLargeDataIT {
}
@Test
- public void test() throws ClassNotFoundException, SQLException {
+ public void test() throws ClassNotFoundException {
insertSQL();
lastValueAggreWithSingleFilterTest();
@@ -842,7 +841,7 @@ public class IoTDBAggregationLargeDataIT {
}
}
- private void maxTimeAggreWithMultiFilterTest() throws ClassNotFoundException, SQLException {
+ private void maxTimeAggreWithMultiFilterTest() throws ClassNotFoundException {
String[] retArray = new String[] {"0,3999,3999,3999,3599,100"};
Class.forName(Config.JDBC_DRIVER_NAME);
diff --git a/server/src/test/java/org/apache/iotdb/db/integration/auth/IoTDBAuthorizationIT.java b/server/src/test/java/org/apache/iotdb/db/integration/auth/IoTDBAuthorizationIT.java
index 6642d41..dd5628d 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/auth/IoTDBAuthorizationIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/auth/IoTDBAuthorizationIT.java
@@ -43,7 +43,7 @@ import static org.junit.Assert.assertTrue;
public class IoTDBAuthorizationIT {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java b/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
index a4f007d..7fb41a3 100644
--- a/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
@@ -50,7 +50,7 @@ public class MManagerBasicTest {
private CompressionType compressionType;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
compressionType = TSFileDescriptor.getInstance().getConfig().getCompressor();
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/metadata/MTreeTest.java b/server/src/test/java/org/apache/iotdb/db/metadata/MTreeTest.java
index d154981..e7c0b25 100644
--- a/server/src/test/java/org/apache/iotdb/db/metadata/MTreeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/metadata/MTreeTest.java
@@ -45,7 +45,7 @@ import static org.junit.Assert.fail;
public class MTreeTest {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/metadata/PartialPathTest.java b/server/src/test/java/org/apache/iotdb/db/metadata/PartialPathTest.java
index 38cb01d..d621a6f 100644
--- a/server/src/test/java/org/apache/iotdb/db/metadata/PartialPathTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/metadata/PartialPathTest.java
@@ -31,7 +31,7 @@ import java.util.List;
public class PartialPathTest {
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/qp/logical/IndexLogicalPlanTest.java b/server/src/test/java/org/apache/iotdb/db/qp/logical/IndexLogicalPlanTest.java
index ce2b646..1e09934 100644
--- a/server/src/test/java/org/apache/iotdb/db/qp/logical/IndexLogicalPlanTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/qp/logical/IndexLogicalPlanTest.java
@@ -18,7 +18,6 @@
*/
package org.apache.iotdb.db.qp.logical;
-import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.index.common.IndexType;
import org.apache.iotdb.db.qp.logical.Operator.OperatorType;
import org.apache.iotdb.db.qp.logical.crud.QueryOperator;
@@ -110,7 +109,7 @@ public class IndexLogicalPlanTest {
}
@Test
- public void testParseQueryIndexWholeMatching() throws IllegalPathException {
+ public void testParseQueryIndexWholeMatching() {
String sqlStr =
"SELECT TOP 2 Glu FROM root.Ery.* WHERE Glu LIKE (0, 120, 20, 80, 120, 100, 80, 0)";
Operator op = generator.generate(sqlStr, ZoneId.systemDefault());
@@ -129,7 +128,7 @@ public class IndexLogicalPlanTest {
}
@Test
- public void testParseQueryIndexSubMatching() throws IllegalPathException {
+ public void testParseQueryIndexSubMatching() {
String sqlStr =
"SELECT Speed.* FROM root.Wind.AZQ02 WHERE Speed "
+ "CONTAIN (15, 14, 12, 12, 12, 11) WITH TOLERANCE 1 "
diff --git a/server/src/test/java/org/apache/iotdb/db/qp/sql/IoTDBsqlVisitorTest.java b/server/src/test/java/org/apache/iotdb/db/qp/sql/IoTDBsqlVisitorTest.java
index b946764..234627b 100644
--- a/server/src/test/java/org/apache/iotdb/db/qp/sql/IoTDBsqlVisitorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/qp/sql/IoTDBsqlVisitorTest.java
@@ -38,13 +38,13 @@ public class IoTDBsqlVisitorTest {
IoTDBSqlVisitor visitor;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
visitor = new IoTDBSqlVisitor();
visitor.setZoneId(ZonedDateTime.now().getOffset());
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testParseTimeFormatNow() {
diff --git a/server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java b/server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java
index 01710e1..c1783e3 100644
--- a/server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java
@@ -23,7 +23,6 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor;
import org.apache.iotdb.db.constant.TestConstant;
import org.apache.iotdb.db.engine.fileSystem.SystemFileFactory;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.utils.EnvironmentUtils;
import org.apache.commons.io.FileUtils;
@@ -52,13 +51,13 @@ public class TracingManagerTest {
private Set<TsFileResource> seqResources = new HashSet<>();
@Before
- public void setUp() throws Exception {
+ public void setUp() {
tracingManager = TracingManager.getInstance();
prepareTsFileResources();
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() throws IOException {
FileUtils.deleteDirectory(new File(tracingDir));
EnvironmentUtils.cleanAllDir();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReaderTest.java b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReaderTest.java
index 3857777..55eea5c 100644
--- a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReaderTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReaderTest.java
@@ -21,10 +21,8 @@ package org.apache.iotdb.db.query.reader.series;
import org.apache.iotdb.db.engine.querycontext.QueryDataSource;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
-import org.apache.iotdb.db.exception.query.PathException;
import org.apache.iotdb.db.exception.query.QueryProcessException;
import org.apache.iotdb.db.metadata.PartialPath;
import org.apache.iotdb.db.query.aggregation.AggregateResult;
@@ -58,12 +56,12 @@ public class SeriesAggregateReaderTest {
private List<TsFileResource> unseqResources = new ArrayList<>();
@Before
- public void setUp() throws MetadataException, PathException, IOException, WriteProcessException {
+ public void setUp() throws MetadataException, IOException, WriteProcessException {
SeriesReaderTestUtil.setUp(measurementSchemas, deviceIds, seqResources, unseqResources);
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() throws IOException {
SeriesReaderTestUtil.tearDown(seqResources, unseqResources);
}
diff --git a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderByTimestampTest.java b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderByTimestampTest.java
index ec8e472..4e71afa 100644
--- a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderByTimestampTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderByTimestampTest.java
@@ -21,10 +21,8 @@ package org.apache.iotdb.db.query.reader.series;
import org.apache.iotdb.db.engine.querycontext.QueryDataSource;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
-import org.apache.iotdb.db.exception.query.PathException;
import org.apache.iotdb.db.metadata.PartialPath;
import org.apache.iotdb.db.query.context.QueryContext;
import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
@@ -52,12 +50,12 @@ public class SeriesReaderByTimestampTest {
private List<TsFileResource> unseqResources = new ArrayList<>();
@Before
- public void setUp() throws MetadataException, PathException, IOException, WriteProcessException {
+ public void setUp() throws MetadataException, IOException, WriteProcessException {
SeriesReaderTestUtil.setUp(measurementSchemas, deviceIds, seqResources, unseqResources);
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() throws IOException {
SeriesReaderTestUtil.tearDown(seqResources, unseqResources);
}
diff --git a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTest.java b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTest.java
index f64f3c2..a224896 100644
--- a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTest.java
@@ -20,10 +20,8 @@
package org.apache.iotdb.db.query.reader.series;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
-import org.apache.iotdb.db.exception.query.PathException;
import org.apache.iotdb.db.metadata.PartialPath;
import org.apache.iotdb.db.query.context.QueryContext;
import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
@@ -57,12 +55,12 @@ public class SeriesReaderTest {
private List<TsFileResource> unseqResources = new ArrayList<>();
@Before
- public void setUp() throws MetadataException, PathException, IOException, WriteProcessException {
+ public void setUp() throws MetadataException, IOException, WriteProcessException {
SeriesReaderTestUtil.setUp(measurementSchemas, deviceIds, seqResources, unseqResources);
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() throws IOException {
SeriesReaderTestUtil.tearDown(seqResources, unseqResources);
}
diff --git a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTestUtil.java b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTestUtil.java
index 4b97eb2..29721d9 100644
--- a/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTestUtil.java
+++ b/server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTestUtil.java
@@ -27,7 +27,6 @@ import org.apache.iotdb.db.engine.cache.TimeSeriesMetadataCache;
import org.apache.iotdb.db.engine.merge.manage.MergeManager;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
import org.apache.iotdb.db.exception.metadata.MetadataException;
-import org.apache.iotdb.db.exception.query.PathException;
import org.apache.iotdb.db.metadata.PartialPath;
import org.apache.iotdb.db.query.control.FileReaderManager;
import org.apache.iotdb.db.service.IoTDB;
@@ -66,7 +65,7 @@ public class SeriesReaderTestUtil {
List<String> deviceIds,
List<TsFileResource> seqResources,
List<TsFileResource> unseqResources)
- throws MetadataException, PathException, IOException, WriteProcessException {
+ throws MetadataException, IOException, WriteProcessException {
IoTDB.metaManager.init();
prepareSeries(measurementSchemas, deviceIds);
prepareFiles(seqResources, unseqResources, measurementSchemas, deviceIds);
@@ -200,8 +199,7 @@ public class SeriesReaderTestUtil {
}
private static void prepareSeries(
- List<MeasurementSchema> measurementSchemas, List<String> deviceIds)
- throws MetadataException, PathException {
+ List<MeasurementSchema> measurementSchemas, List<String> deviceIds) throws MetadataException {
for (int i = 0; i < measurementNum; i++) {
measurementSchemas.add(
new MeasurementSchema(
diff --git a/server/src/test/java/org/apache/iotdb/db/script/EnvScriptIT.java b/server/src/test/java/org/apache/iotdb/db/script/EnvScriptIT.java
index 081f09d..ef8961a 100644
--- a/server/src/test/java/org/apache/iotdb/db/script/EnvScriptIT.java
+++ b/server/src/test/java/org/apache/iotdb/db/script/EnvScriptIT.java
@@ -33,13 +33,13 @@ import static org.junit.Assert.assertTrue;
public class EnvScriptIT {
@Before
- public void setUp() throws Exception {}
+ public void setUp() {}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
- public void test() throws IOException, InterruptedException {
+ public void test() throws IOException {
String os = System.getProperty("os.name").toLowerCase();
if (os.startsWith("windows")) {
testStartClientOnWindows(".bat", os);
diff --git a/server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java b/server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java
index b371989..2ce45a0 100644
--- a/server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java
@@ -25,8 +25,6 @@ import org.apache.iotdb.db.engine.StorageEngine;
import org.apache.iotdb.db.engine.storagegroup.StorageGroupProcessor;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
import org.apache.iotdb.db.engine.storagegroup.virtualSg.HashVirtualPartitioner;
-import org.apache.iotdb.db.exception.DiskSpaceInsufficientException;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
@@ -65,9 +63,7 @@ public class FileLoaderTest {
private IFileLoader fileLoader;
@Before
- public void setUp()
- throws IOException, InterruptedException, StartupException, DiskSpaceInsufficientException,
- MetadataException {
+ public void setUp() throws Exception {
IoTDBDescriptor.getInstance().getConfig().setSyncEnable(true);
HashVirtualPartitioner.getInstance().setStorageGroupNum(1);
EnvironmentUtils.closeStatMonitor();
@@ -88,7 +84,7 @@ public class FileLoaderTest {
}
@After
- public void tearDown() throws InterruptedException, IOException, StorageEngineException {
+ public void tearDown() throws IOException, StorageEngineException {
EnvironmentUtils.cleanEnv();
IoTDBDescriptor.getInstance().getConfig().setSyncEnable(false);
HashVirtualPartitioner.getInstance()
diff --git a/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java b/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java
index 2f628b4..dd83553 100644
--- a/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java
@@ -25,7 +25,6 @@ import org.apache.iotdb.db.engine.StorageEngine;
import org.apache.iotdb.db.engine.storagegroup.StorageGroupProcessor;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
import org.apache.iotdb.db.exception.DiskSpaceInsufficientException;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
@@ -69,9 +68,7 @@ public class SyncReceiverLogAnalyzerTest {
private ISyncReceiverLogger receiverLogger;
@Before
- public void setUp()
- throws IOException, InterruptedException, StartupException, DiskSpaceInsufficientException,
- MetadataException {
+ public void setUp() throws DiskSpaceInsufficientException, MetadataException {
IoTDBDescriptor.getInstance().getConfig().setSyncEnable(true);
EnvironmentUtils.closeStatMonitor();
EnvironmentUtils.envSetUp();
@@ -92,7 +89,7 @@ public class SyncReceiverLogAnalyzerTest {
}
@After
- public void tearDown() throws InterruptedException, IOException, StorageEngineException {
+ public void tearDown() throws IOException, StorageEngineException {
EnvironmentUtils.cleanEnv();
IoTDBDescriptor.getInstance().getConfig().setSyncEnable(false);
}
diff --git a/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java b/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java
index 1848c25..cfcb5c6 100644
--- a/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java
@@ -20,7 +20,6 @@ package org.apache.iotdb.db.sync.receiver.recover;
import org.apache.iotdb.db.conf.directories.DirectoryManager;
import org.apache.iotdb.db.exception.DiskSpaceInsufficientException;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.sync.conf.SyncConstant;
import org.apache.iotdb.db.utils.EnvironmentUtils;
@@ -45,8 +44,7 @@ public class SyncReceiverLoggerTest {
private String dataDir;
@Before
- public void setUp()
- throws IOException, InterruptedException, StartupException, DiskSpaceInsufficientException {
+ public void setUp() throws DiskSpaceInsufficientException {
EnvironmentUtils.envSetUp();
dataDir =
new File(DirectoryManager.getInstance().getNextFolderForSequenceFile())
@@ -55,7 +53,7 @@ public class SyncReceiverLoggerTest {
}
@After
- public void tearDown() throws InterruptedException, IOException, StorageEngineException {
+ public void tearDown() throws IOException, StorageEngineException {
EnvironmentUtils.cleanEnv();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java b/server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java
index 1b47022..0764447 100644
--- a/server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java
@@ -22,7 +22,6 @@ import org.apache.iotdb.db.conf.IoTDBConstant;
import org.apache.iotdb.db.conf.directories.DirectoryManager;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
import org.apache.iotdb.db.exception.DiskSpaceInsufficientException;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
import org.apache.iotdb.db.metadata.PartialPath;
@@ -57,8 +56,7 @@ public class SyncFileManagerTest {
private String dataDir;
@Before
- public void setUp()
- throws IOException, InterruptedException, StartupException, DiskSpaceInsufficientException {
+ public void setUp() throws DiskSpaceInsufficientException {
EnvironmentUtils.envSetUp();
dataDir =
new File(DirectoryManager.getInstance().getNextFolderForSequenceFile())
@@ -68,7 +66,7 @@ public class SyncFileManagerTest {
}
@After
- public void tearDown() throws InterruptedException, IOException, StorageEngineException {
+ public void tearDown() throws IOException, StorageEngineException {
EnvironmentUtils.cleanEnv();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java b/server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java
index 1554b4a..91c03e7 100644
--- a/server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java
@@ -22,7 +22,6 @@ import org.apache.iotdb.db.conf.IoTDBConstant;
import org.apache.iotdb.db.conf.directories.DirectoryManager;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
import org.apache.iotdb.db.exception.DiskSpaceInsufficientException;
-import org.apache.iotdb.db.exception.StartupException;
import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.db.sync.conf.SyncSenderConfig;
import org.apache.iotdb.db.sync.conf.SyncSenderDescriptor;
@@ -59,8 +58,7 @@ public class SyncClientTest {
private ISyncSenderLogAnalyzer senderLogAnalyzer;
@Before
- public void setUp()
- throws IOException, InterruptedException, StartupException, DiskSpaceInsufficientException {
+ public void setUp() throws DiskSpaceInsufficientException {
EnvironmentUtils.envSetUp();
dataDir =
new File(DirectoryManager.getInstance().getNextFolderForSequenceFile())
@@ -71,7 +69,7 @@ public class SyncClientTest {
}
@After
- public void tearDown() throws InterruptedException, IOException, StorageEngineException {
+ public void tearDown() throws IOException, StorageEngineException {
EnvironmentUtils.cleanEnv();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/tools/IoTDBWatermarkTest.java b/server/src/test/java/org/apache/iotdb/db/tools/IoTDBWatermarkTest.java
index 7453b6b..1e10209 100644
--- a/server/src/test/java/org/apache/iotdb/db/tools/IoTDBWatermarkTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/tools/IoTDBWatermarkTest.java
@@ -37,7 +37,6 @@ import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
-import java.sql.SQLException;
import java.sql.Statement;
import static org.junit.Assert.fail;
@@ -103,7 +102,7 @@ public class IoTDBWatermarkTest {
EnvironmentUtils.cleanEnv();
}
- private static void insertData() throws ClassNotFoundException, SQLException {
+ private static void insertData() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -142,7 +141,7 @@ public class IoTDBWatermarkTest {
@Test
public void EncodeAndDecodeTest1()
- throws IOException, ClassNotFoundException, SQLException, LogicalOperatorException {
+ throws IOException, ClassNotFoundException, LogicalOperatorException {
// Watermark Embedding
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
@@ -195,7 +194,7 @@ public class IoTDBWatermarkTest {
@Test
public void EncodeAndDecodeTest2()
- throws IOException, ClassNotFoundException, SQLException, LogicalOperatorException {
+ throws IOException, ClassNotFoundException, LogicalOperatorException {
// No Watermark Embedding
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
diff --git a/server/src/test/java/org/apache/iotdb/db/tools/MLogParserTest.java b/server/src/test/java/org/apache/iotdb/db/tools/MLogParserTest.java
index 1f1225b..1cd6cf6 100644
--- a/server/src/test/java/org/apache/iotdb/db/tools/MLogParserTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/tools/MLogParserTest.java
@@ -52,7 +52,7 @@ public class MLogParserTest {
private static final Logger logger = LoggerFactory.getLogger(MLogParserTest.class);
@Before
- public void setUp() throws Exception {
+ public void setUp() {
EnvironmentUtils.envSetUp();
}
diff --git a/server/src/test/java/org/apache/iotdb/db/utils/FilePathUtilsTest.java b/server/src/test/java/org/apache/iotdb/db/utils/FilePathUtilsTest.java
index c5ff359..65c0a46 100644
--- a/server/src/test/java/org/apache/iotdb/db/utils/FilePathUtilsTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/utils/FilePathUtilsTest.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.db.utils;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
-import org.apache.iotdb.db.exception.StorageEngineException;
import org.apache.iotdb.tsfile.utils.Pair;
import org.apache.commons.io.FileUtils;
@@ -119,7 +118,7 @@ public class FilePathUtilsTest {
}
@After
- public void tearDown() throws IOException, StorageEngineException {
+ public void tearDown() {
Assert.assertTrue(tsFile.delete());
}
}
diff --git a/server/src/test/java/org/apache/iotdb/db/utils/SchemaUtilsTest.java b/server/src/test/java/org/apache/iotdb/db/utils/SchemaUtilsTest.java
index 7f074bd..c6b844d 100644
--- a/server/src/test/java/org/apache/iotdb/db/utils/SchemaUtilsTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/utils/SchemaUtilsTest.java
@@ -46,7 +46,7 @@ public class SchemaUtilsTest {
}
@Test
- public void getAggregatedDataTypesTest() throws MetadataException {
+ public void getAggregatedDataTypesTest() {
List<TSDataType> measurementTypes = new ArrayList<>();
measurementTypes.add(TSDataType.INT64);
measurementTypes.add(TSDataType.TEXT);
diff --git a/server/src/test/java/org/apache/iotdb/db/utils/datastructure/PrecisionTest.java b/server/src/test/java/org/apache/iotdb/db/utils/datastructure/PrecisionTest.java
index a1b8d25..848655a 100644
--- a/server/src/test/java/org/apache/iotdb/db/utils/datastructure/PrecisionTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/utils/datastructure/PrecisionTest.java
@@ -25,7 +25,6 @@ import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
@@ -47,7 +46,7 @@ public class PrecisionTest {
}
@Test
- public void testDoublePrecision1() throws IOException, ClassNotFoundException {
+ public void testDoublePrecision1() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -71,7 +70,7 @@ public class PrecisionTest {
}
@Test
- public void testDoublePrecision2() throws IOException, ClassNotFoundException {
+ public void testDoublePrecision2() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -95,7 +94,7 @@ public class PrecisionTest {
}
@Test
- public void testFloatPrecision1() throws IOException, ClassNotFoundException {
+ public void testFloatPrecision1() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
@@ -119,7 +118,7 @@ public class PrecisionTest {
}
@Test
- public void testFloatPrecision2() throws IOException, ClassNotFoundException {
+ public void testFloatPrecision2() throws ClassNotFoundException {
Class.forName(Config.JDBC_DRIVER_NAME);
try (Connection connection =
DriverManager.getConnection(
diff --git a/server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java b/server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java
index 79de71e..6a1df39 100644
--- a/server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java
@@ -20,7 +20,6 @@ package org.apache.iotdb.db.writelog;
import org.apache.iotdb.db.conf.IoTDBConfig;
import org.apache.iotdb.db.conf.IoTDBDescriptor;
-import org.apache.iotdb.db.exception.WriteProcessException;
import org.apache.iotdb.db.exception.metadata.IllegalPathException;
import org.apache.iotdb.db.exception.metadata.MetadataException;
import org.apache.iotdb.db.metadata.PartialPath;
@@ -55,7 +54,7 @@ public class PerformanceTest {
private boolean skip = true;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
enableWal = config.isEnableWal();
config.setEnableWal(true);
EnvironmentUtils.envSetUp();
@@ -138,7 +137,7 @@ public class PerformanceTest {
}
@Test
- public void recoverTest() throws IOException, MetadataException, WriteProcessException {
+ public void recoverTest() throws IOException, MetadataException {
// this test insert 1000000 * 3 logs , recover from them and report elapsed time
if (skip) {
return;
diff --git a/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java b/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java
index e9f285f..39b1a5c 100644
--- a/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java
@@ -53,7 +53,7 @@ public class WriteLogNodeManagerTest {
private boolean enableWal;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
enableWal = config.isEnableWal();
config.setEnableWal(true);
EnvironmentUtils.envSetUp();
diff --git a/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java b/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java
index 7093110..2767813 100644
--- a/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java
@@ -55,7 +55,7 @@ public class WriteLogNodeTest {
private boolean enableWal;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
enableWal = config.isEnableWal();
config.setEnableWal(true);
EnvironmentUtils.envSetUp();
diff --git a/server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java b/server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
index 63f803c..7e58c2f 100644
--- a/server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
@@ -240,9 +240,8 @@ public class LogReplayerTest {
*
* @return
* @throws IllegalPathException
- * @throws IOException
*/
- public InsertTabletPlan insertTablePlan() throws IllegalPathException, IOException {
+ public InsertTabletPlan insertTablePlan() throws IllegalPathException {
String[] measurements = new String[2];
measurements[0] = "sensor0";
measurements[1] = "sensor1";
diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java b/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java
index 4f434c4..8895bf3 100644
--- a/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java
+++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java
@@ -279,7 +279,7 @@ public class IoTDBRpcDataSet {
return isNull(index, rowsIndex - 1);
}
- public boolean isNull(String columnName) throws StatementExecutionException {
+ public boolean isNull(String columnName) {
int index = columnOrdinalMap.get(columnName) - START_INDEX;
// time column will never be null
if (index < 0) {
diff --git a/session/src/test/java/org/apache/iotdb/session/SessionCacheLeaderUT.java b/session/src/test/java/org/apache/iotdb/session/SessionCacheLeaderUT.java
index 9e431b8..4b52005 100644
--- a/session/src/test/java/org/apache/iotdb/session/SessionCacheLeaderUT.java
+++ b/session/src/test/java/org/apache/iotdb/session/SessionCacheLeaderUT.java
@@ -752,72 +752,63 @@ public class SessionCacheLeaderUT {
@Override
public SessionConnection constructSessionConnection(
- Session session, EndPoint endpoint, ZoneId zoneId) throws IoTDBConnectionException {
+ Session session, EndPoint endpoint, ZoneId zoneId) {
return new MockSessionConnection(session, endpoint, zoneId);
}
}
static class MockSessionConnection extends SessionConnection {
- public MockSessionConnection(Session session, EndPoint endPoint, ZoneId zoneId)
- throws IoTDBConnectionException {
+ public MockSessionConnection(Session session, EndPoint endPoint, ZoneId zoneId) {
super();
}
@Override
- public void close() throws IoTDBConnectionException {}
+ public void close() {}
@Override
- protected void setStorageGroup(String storageGroup)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void setStorageGroup(String storageGroup) throws RedirectException {
throw new RedirectException(endpoints.get(1));
}
@Override
- protected void deleteStorageGroups(List<String> storageGroups)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void deleteStorageGroups(List<String> storageGroups) throws RedirectException {
throw new RedirectException(endpoints.get(1));
}
@Override
- protected void insertRecord(TSInsertRecordReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void insertRecord(TSInsertRecordReq request) throws RedirectException {
throw new RedirectException(getDeviceIdBelongedEndpoint(request.deviceId));
}
@Override
- protected void insertRecord(TSInsertStringRecordReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void insertRecord(TSInsertStringRecordReq request) throws RedirectException {
throw new RedirectException(getDeviceIdBelongedEndpoint(request.deviceId));
}
@Override
- protected void insertRecords(TSInsertRecordsReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void insertRecords(TSInsertRecordsReq request) throws RedirectException {
throw new RedirectException(getDeviceIdBelongedEndpoint(request.deviceIds.get(0)));
}
@Override
- protected void insertRecords(TSInsertStringRecordsReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void insertRecords(TSInsertStringRecordsReq request) throws RedirectException {
throw new RedirectException(getDeviceIdBelongedEndpoint(request.deviceIds.get(0)));
}
@Override
protected void insertRecordsOfOneDevice(TSInsertRecordsOfOneDeviceReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ throws RedirectException {
throw new RedirectException(getDeviceIdBelongedEndpoint(request.deviceId));
}
@Override
- protected void insertTablet(TSInsertTabletReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void insertTablet(TSInsertTabletReq request) throws RedirectException {
throw new RedirectException(getDeviceIdBelongedEndpoint(request.deviceId));
}
@Override
- protected void insertTablets(TSInsertTabletsReq request)
- throws IoTDBConnectionException, StatementExecutionException, RedirectException {
+ protected void insertTablets(TSInsertTabletsReq request) throws RedirectException {
Map<String, EndPoint> deviceEndPointMap = new HashMap<>();
for (int i = 0; i < request.getDeviceIds().size(); i++) {
deviceEndPointMap.put(
diff --git a/spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/EnvironmentUtils.java b/spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/EnvironmentUtils.java
index ed458f2..a4cc0cb 100644
--- a/spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/EnvironmentUtils.java
+++ b/spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/EnvironmentUtils.java
@@ -165,7 +165,7 @@ public class EnvironmentUtils {
/**
* disable memory control</br> this function should be called before all code in the setup
*/
- public static void envSetUp() throws StartupException, IOException {
+ public static void envSetUp() throws StartupException {
IoTDB.metaManager.init();
createAllDir();
// disable the system monitor
diff --git a/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java b/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java
index 590183b..4686c47 100755
--- a/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java
+++ b/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/BasicOperator.java
@@ -18,8 +18,6 @@
*/
package org.apache.iotdb.spark.tsfile.qp.common;
-import org.apache.iotdb.spark.tsfile.qp.exception.BasicOperatorException;
-
/** basic operators include < > >= <= !=. */
public class BasicOperator extends FilterOperator {
@@ -42,7 +40,7 @@ public class BasicOperator extends FilterOperator {
return seriesValue;
}
- public void setReversedTokenIntType() throws BasicOperatorException {
+ public void setReversedTokenIntType() {
int intType = SQLConstant.reverseWords.get(tokenIntType);
setTokenIntType(intType);
}
diff --git a/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java b/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java
index 045cde8..19bd0dc 100755
--- a/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java
+++ b/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/optimizer/RemoveNotOptimizer.java
@@ -21,7 +21,6 @@ package org.apache.iotdb.spark.tsfile.qp.optimizer;
import org.apache.iotdb.spark.tsfile.qp.common.BasicOperator;
import org.apache.iotdb.spark.tsfile.qp.common.FilterOperator;
import org.apache.iotdb.spark.tsfile.qp.common.SQLConstant;
-import org.apache.iotdb.spark.tsfile.qp.exception.BasicOperatorException;
import org.apache.iotdb.spark.tsfile.qp.exception.RemoveNotException;
import org.slf4j.Logger;
@@ -64,30 +63,17 @@ public class RemoveNotOptimizer implements IFilterOptimizer {
children.set(1, removeNot(children.get(1)));
return filter;
case KW_NOT:
- try {
- return reverseFilter(filter.getChildren().get(0));
- } catch (BasicOperatorException e) {
- LOG.error("reverse Filter failed.");
- }
+ return reverseFilter(filter.getChildren().get(0));
default:
throw new RemoveNotException(
"Unknown token in removeNot: " + tokenInt + "," + SQLConstant.tokenNames.get(tokenInt));
}
}
- private FilterOperator reverseFilter(FilterOperator filter)
- throws RemoveNotException, BasicOperatorException {
+ private FilterOperator reverseFilter(FilterOperator filter) throws RemoveNotException {
int tokenInt = filter.getTokenIntType();
if (filter.isLeaf()) {
- try {
- ((BasicOperator) filter).setReversedTokenIntType();
- } catch (BasicOperatorException e) {
- throw new RemoveNotException(
- "convert BasicFuntion to reserved meet failed: previous token:"
- + tokenInt
- + "tokenSymbol:"
- + SQLConstant.tokenNames.get(tokenInt));
- }
+ ((BasicOperator) filter).setReversedTokenIntType();
return filter;
}
switch (tokenInt) {
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/ICompressor.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/ICompressor.java
index 206b6be..66d18f9 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/ICompressor.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/ICompressor.java
@@ -161,7 +161,7 @@ public interface ICompressor extends Serializable {
}
@Override
- public byte[] compress(byte[] data) throws IOException {
+ public byte[] compress(byte[] data) {
if (data == null) {
return new byte[0];
}
@@ -169,12 +169,12 @@ public interface ICompressor extends Serializable {
}
@Override
- public int compress(byte[] data, int offset, int length, byte[] compressed) throws IOException {
+ public int compress(byte[] data, int offset, int length, byte[] compressed) {
return compressor.compress(data, offset, length, compressed, 0);
}
@Override
- public int compress(ByteBuffer data, ByteBuffer compressed) throws IOException {
+ public int compress(ByteBuffer data, ByteBuffer compressed) {
compressor.compress(data, compressed);
return data.limit();
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/IUnCompressor.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/IUnCompressor.java
index 1593bf2..b4b333e 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/IUnCompressor.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/compress/IUnCompressor.java
@@ -204,12 +204,12 @@ public interface IUnCompressor {
}
@Override
- public int getUncompressedLength(byte[] array, int offset, int length) throws IOException {
+ public int getUncompressedLength(byte[] array, int offset, int length) {
throw new UnsupportedOperationException("unsupported get uncompress length");
}
@Override
- public int getUncompressedLength(ByteBuffer buffer) throws IOException {
+ public int getUncompressedLength(ByteBuffer buffer) {
throw new UnsupportedOperationException("unsupported get uncompress length");
}
@@ -267,7 +267,7 @@ public interface IUnCompressor {
class GZIPUnCompressor implements IUnCompressor {
@Override
- public int getUncompressedLength(byte[] array, int offset, int length) throws IOException {
+ public int getUncompressedLength(byte[] array, int offset, int length) {
throw new UnsupportedOperationException("unsupported get uncompress length");
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoder.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoder.java
index fa77718..b274b0e 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoder.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoder.java
@@ -75,20 +75,9 @@ public class BitmapDecoder extends Decoder {
@Override
public int readInt(ByteBuffer buffer) {
if (currentCount == 0) {
- try {
- reset();
- getLengthAndNumber(buffer);
- readNext();
- } catch (IOException e) {
- logger.error(
- "tsfile-encoding BitmapDecoder: error occurs when reading next number. lenght {}, "
- + "number {}, current number {}, result buffer {}",
- length,
- number,
- currentCount,
- this.buffer,
- e);
- }
+ reset();
+ getLengthAndNumber(buffer);
+ readNext();
}
int result = 0;
int index = (number - currentCount) / 8;
@@ -113,7 +102,7 @@ public class BitmapDecoder extends Decoder {
}
/** Decode all data from buffer and save them. */
- private void readNext() throws IOException {
+ private void readNext() {
int len = (this.number + 7) / 8;
while (byteCache.remaining() > 0) {
int value = ReadWriteForEncodingUtils.readUnsignedVarInt(byteCache);
@@ -182,7 +171,7 @@ public class BitmapDecoder extends Decoder {
* @throws IOException cannot read next value
*/
@Override
- public boolean hasNext(ByteBuffer buffer) throws IOException {
+ public boolean hasNext(ByteBuffer buffer) {
if (currentCount > 0 || buffer.remaining() > 0) {
return true;
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoder.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoder.java
index 5996fc8..5721fd2 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoder.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoder.java
@@ -106,8 +106,7 @@ public class LongRleDecoder extends RleDecoder {
}
@Override
- protected void readBitPackingBuffer(int bitPackedGroupCount, int lastBitPackedNum)
- throws IOException {
+ protected void readBitPackingBuffer(int bitPackedGroupCount, int lastBitPackedNum) {
currentBuffer = new long[bitPackedGroupCount * TSFileConfig.RLE_MIN_REPEATED_NUM];
byte[] bytes = new byte[bitPackedGroupCount * bitWidth];
int bytesToRead = bitPackedGroupCount * bitWidth;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/PlainDecoder.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/PlainDecoder.java
index 80f3f65..30c3bad 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/PlainDecoder.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/PlainDecoder.java
@@ -24,7 +24,6 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.utils.Binary;
import org.apache.iotdb.tsfile.utils.ReadWriteForEncodingUtils;
-import java.io.IOException;
import java.math.BigDecimal;
import java.nio.ByteBuffer;
@@ -73,7 +72,7 @@ public class PlainDecoder extends Decoder {
}
@Override
- public boolean hasNext(ByteBuffer buffer) throws IOException {
+ public boolean hasNext(ByteBuffer buffer) {
return buffer.remaining() > 0;
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SinglePrecisionEncoderV1.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SinglePrecisionEncoderV1.java
index 54f8f01..1e55735 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SinglePrecisionEncoderV1.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SinglePrecisionEncoderV1.java
@@ -22,7 +22,6 @@ package org.apache.iotdb.tsfile.encoding.encoder;
import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
import java.io.ByteArrayOutputStream;
-import java.io.IOException;
/** Encoder for int value using gorilla encoding. */
public class SinglePrecisionEncoderV1 extends GorillaEncoderV1 {
@@ -85,7 +84,7 @@ public class SinglePrecisionEncoderV1 extends GorillaEncoderV1 {
}
@Override
- public void flush(ByteArrayOutputStream out) throws IOException {
+ public void flush(ByteArrayOutputStream out) {
encode(Float.NaN, out);
clearBuffer(out);
reset();
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/UnClosedTsFileReader.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/UnClosedTsFileReader.java
index 22a70e5..a77727a 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/UnClosedTsFileReader.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/UnClosedTsFileReader.java
@@ -32,13 +32,13 @@ public class UnClosedTsFileReader extends TsFileSequenceReader {
/** unclosed file has no tail magic data. */
@Override
- public String readTailMagic() throws IOException {
+ public String readTailMagic() {
throw new NotImplementedException();
}
/** unclosed file has no file metadata. */
@Override
- public TsFileMetadata readFileMetadata() throws IOException {
+ public TsFileMetadata readFileMetadata() {
throw new NotImplementedException();
}
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java
index eab11b6..ae02551 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java
@@ -21,8 +21,6 @@ package org.apache.iotdb.tsfile.read.reader;
import org.apache.iotdb.tsfile.read.TimeValuePair;
import org.apache.iotdb.tsfile.read.common.BatchData;
-import java.io.IOException;
-
public class BatchDataIterator implements IPointReader {
private BatchData batchData;
@@ -50,7 +48,7 @@ public class BatchDataIterator implements IPointReader {
}
@Override
- public void close() throws IOException {
+ public void close() {
batchData = null;
}
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/LocalTsFileInput.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/LocalTsFileInput.java
index 969f572..26bd2cf 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/LocalTsFileInput.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/LocalTsFileInput.java
@@ -95,7 +95,7 @@ public class LocalTsFileInput implements TsFileInput {
}
@Override
- public int read() throws IOException {
+ public int read() {
throw new UnsupportedOperationException();
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkGroupWriterImpl.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkGroupWriterImpl.java
index 458d759..1dbc9f5 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkGroupWriterImpl.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ChunkGroupWriterImpl.java
@@ -71,7 +71,7 @@ public class ChunkGroupWriterImpl implements IChunkGroupWriter {
}
@Override
- public void write(Tablet tablet) throws WriteProcessException, IOException {
+ public void write(Tablet tablet) throws WriteProcessException {
List<MeasurementSchema> timeseries = tablet.getSchemas();
for (int i = 0; i < timeseries.size(); i++) {
String measurementId = timeseries.get(i).getMeasurementId();
@@ -83,8 +83,8 @@ public class ChunkGroupWriterImpl implements IChunkGroupWriter {
}
}
- private void writeByDataType(Tablet tablet, String measurementId, TSDataType dataType, int index)
- throws IOException {
+ private void writeByDataType(
+ Tablet tablet, String measurementId, TSDataType dataType, int index) {
int batchSize = tablet.rowSize;
switch (dataType) {
case INT32:
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/BooleanDataPoint.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/BooleanDataPoint.java
index 74b4493..b607a79 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/BooleanDataPoint.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/BooleanDataPoint.java
@@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
/**
* a subclass for Boolean data type extends DataPoint.
*
@@ -44,7 +42,7 @@ public class BooleanDataPoint extends DataPoint {
}
@Override
- public void writeTo(long time, IChunkWriter writer) throws IOException {
+ public void writeTo(long time, IChunkWriter writer) {
if (writer == null) {
LOG.warn("given IChunkWriter is null, do nothing and return");
return;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/DoubleDataPoint.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/DoubleDataPoint.java
index c6fdad5..b988ed7 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/DoubleDataPoint.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/DoubleDataPoint.java
@@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
/**
* a subclass for Double data type extends DataPoint.
*
@@ -44,7 +42,7 @@ public class DoubleDataPoint extends DataPoint {
}
@Override
- public void writeTo(long time, IChunkWriter writer) throws IOException {
+ public void writeTo(long time, IChunkWriter writer) {
if (writer == null) {
LOG.warn("given IChunkWriter is null, do nothing and return");
return;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/FloatDataPoint.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/FloatDataPoint.java
index 243858a..3d13f17 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/FloatDataPoint.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/FloatDataPoint.java
@@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
/**
* a subclass for Float data type extends DataPoint.
*
@@ -44,7 +42,7 @@ public class FloatDataPoint extends DataPoint {
}
@Override
- public void writeTo(long time, IChunkWriter writer) throws IOException {
+ public void writeTo(long time, IChunkWriter writer) {
if (writer == null) {
LOG.warn("given IChunkWriter is null, do nothing and return");
return;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/IntDataPoint.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/IntDataPoint.java
index d3a52d4..a66378e 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/IntDataPoint.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/IntDataPoint.java
@@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
/**
* a subclass for Integer data type extends DataPoint.
*
@@ -44,7 +42,7 @@ public class IntDataPoint extends DataPoint {
}
@Override
- public void writeTo(long time, IChunkWriter writer) throws IOException {
+ public void writeTo(long time, IChunkWriter writer) {
if (writer == null) {
LOG.warn("given IChunkWriter is null, do nothing and return");
return;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/LongDataPoint.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/LongDataPoint.java
index 2df1ab5..4bc2e9f 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/LongDataPoint.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/LongDataPoint.java
@@ -24,8 +24,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
/**
* a subclass for Long data type extends DataPoint.
*
@@ -44,7 +42,7 @@ public class LongDataPoint extends DataPoint {
}
@Override
- public void writeTo(long time, IChunkWriter writer) throws IOException {
+ public void writeTo(long time, IChunkWriter writer) {
if (writer == null) {
LOG.warn("given IChunkWriter is null, do nothing and return");
return;
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/StringDataPoint.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/StringDataPoint.java
index 0f873a9..3a3918c 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/StringDataPoint.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/record/datapoint/StringDataPoint.java
@@ -25,8 +25,6 @@ import org.apache.iotdb.tsfile.write.chunk.IChunkWriter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-
/**
* a subclass for Integer data type extends DataPoint.
*
@@ -45,7 +43,7 @@ public class StringDataPoint extends DataPoint {
}
@Override
- public void writeTo(long time, IChunkWriter writer) throws IOException {
+ public void writeTo(long time, IChunkWriter writer) {
if (writer == null) {
LOG.warn("given IChunkWriter is null, do nothing and return");
return;
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java
index eb5993d..901bc60 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java
@@ -23,14 +23,12 @@ import org.apache.iotdb.tsfile.encoding.encoder.SDTEncoder;
import org.junit.Test;
-import java.io.IOException;
-
import static org.junit.Assert.assertEquals;
public class SDTEncoderTest {
@Test
- public void testIntSingleValue() throws IOException {
+ public void testIntSingleValue() {
SDTEncoder encoder = new SDTEncoder();
encoder.setCompDeviation(0.01);
@@ -47,7 +45,7 @@ public class SDTEncoderTest {
}
@Test
- public void testDoubleSingleValue() throws IOException {
+ public void testDoubleSingleValue() {
SDTEncoder encoder = new SDTEncoder();
encoder.setCompDeviation(0.01);
@@ -64,7 +62,7 @@ public class SDTEncoderTest {
}
@Test
- public void testLongSingleValue() throws IOException {
+ public void testLongSingleValue() {
SDTEncoder encoder = new SDTEncoder();
encoder.setCompDeviation(0.01);
@@ -81,7 +79,7 @@ public class SDTEncoderTest {
}
@Test
- public void testFloatSingleValue() throws IOException {
+ public void testFloatSingleValue() {
SDTEncoder encoder = new SDTEncoder();
encoder.setCompDeviation(0.01);
@@ -118,7 +116,7 @@ public class SDTEncoderTest {
}
@Test
- public void testDoubleValueArray() throws IOException {
+ public void testDoubleValueArray() {
SDTEncoder encoder = new SDTEncoder();
encoder.setCompDeviation(0.01);
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoderTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoderTest.java
index 1a5e317..d9a9a4d 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoderTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/BitmapDecoderTest.java
@@ -44,7 +44,7 @@ public class BitmapDecoderTest {
private List<Boolean> booleanList;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
intList = new ArrayList<Integer>();
int[] int_array = {0, 1, 2, 3, 4, 5, 6, 7, 8};
int int_len = int_array.length;
@@ -63,7 +63,7 @@ public class BitmapDecoderTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testBitmapReadInt() throws Exception {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/FloatDecoderTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/FloatDecoderTest.java
index f1f51bc..cbbdc8e 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/FloatDecoderTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/FloatDecoderTest.java
@@ -48,7 +48,7 @@ public class FloatDecoderTest {
private List<Double> doubleList;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
floatList = new ArrayList<Float>();
int hybridCount = 11;
int hybridNum = 5;
@@ -82,7 +82,7 @@ public class FloatDecoderTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testRLEFloat() throws Exception {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/GorillaDecoderV1Test.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/GorillaDecoderV1Test.java
index a88a328..6d83183 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/GorillaDecoderV1Test.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/GorillaDecoderV1Test.java
@@ -47,7 +47,7 @@ public class GorillaDecoderV1Test {
private List<Double> doubleList;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
floatList = new ArrayList<Float>();
int hybridCount = 11;
int hybridNum = 50;
@@ -83,7 +83,7 @@ public class GorillaDecoderV1Test {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testNegativeNumber() throws IOException {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/IntRleDecoderTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/IntRleDecoderTest.java
index b04ab05..efd73b5 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/IntRleDecoderTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/IntRleDecoderTest.java
@@ -42,7 +42,7 @@ public class IntRleDecoderTest {
private List<Integer> hybridList;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
rleList = new ArrayList<>();
int rleCount = 11;
int rleNum = 18;
@@ -96,7 +96,7 @@ public class IntRleDecoderTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testRleReadBigInt() throws IOException {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoderTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoderTest.java
index 7ec0cea..072d235 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoderTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/LongRleDecoderTest.java
@@ -45,7 +45,7 @@ public class LongRleDecoderTest {
private int hybridWidth;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
rleList = new ArrayList<Long>();
int rleCount = 11;
int rleNum = 38;
@@ -103,7 +103,7 @@ public class LongRleDecoderTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testRleReadBigLong() throws IOException {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderIntegerTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderIntegerTest.java
index 0064afe..5d6513d 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderIntegerTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderIntegerTest.java
@@ -88,7 +88,7 @@ public class DeltaBinaryEncoderIntegerTest {
shouldReadAndWrite(data, ROW_NUM);
}
- private void writeData(int[] data, int length) throws IOException {
+ private void writeData(int[] data, int length) {
for (int i = 0; i < length; i++) {
writer.encode(data[i], out);
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderLongTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderLongTest.java
index 762c0de..be84b29 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderLongTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/delta/DeltaBinaryEncoderLongTest.java
@@ -181,7 +181,7 @@ public class DeltaBinaryEncoderLongTest {
return list;
}
- private void writeData(long[] data, int length) throws IOException {
+ private void writeData(long[] data, int length) {
for (int i = 0; i < length; i++) {
writer.encode(data[i], out);
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderIntegerTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderIntegerTest.java
index 3ea0484..dae70e2 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderIntegerTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderIntegerTest.java
@@ -124,7 +124,7 @@ public class RegularDataEncoderIntegerTest {
return data;
}
- private void writeData(int[] data, int length) throws IOException {
+ private void writeData(int[] data, int length) {
for (int i = 0; i < length; i++) {
regularDataEncoder.encode(data[i], out);
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderLongTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderLongTest.java
index e53774a..5aec47c 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderLongTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/regular/RegularDataEncoderLongTest.java
@@ -219,7 +219,7 @@ public class RegularDataEncoderLongTest {
return list;
}
- private void writeData(long[] data, int length) throws IOException {
+ private void writeData(long[] data, int length) {
for (int i = 0; i < length; i++) {
regularDataEncoder.encode(data[i], out);
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TimeSeriesMetadataTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TimeSeriesMetadataTest.java
index 98cf24c..bf67f61 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TimeSeriesMetadataTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TimeSeriesMetadataTest.java
@@ -50,7 +50,7 @@ public class TimeSeriesMetadataTest {
}
@Test
- public void testWriteIntoFile() throws IOException {
+ public void testWriteIntoFile() {
TimeseriesMetadata timeseriesMetadata =
TestHelper.createSimpleTimseriesMetaData(measurementUID);
serialized(timeseriesMetadata);
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TsFileMetadataTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TsFileMetadataTest.java
index 8118d91..6b8fc2d 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TsFileMetadataTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/file/metadata/TsFileMetadataTest.java
@@ -50,7 +50,7 @@ public class TsFileMetadataTest {
}
@Test
- public void testWriteFileMetaData() throws IOException {
+ public void testWriteFileMetaData() {
TsFileMetadata tsfMetaData = TestHelper.createSimpleFileMetaData();
serialized(tsfMetaData);
TsFileMetadata readMetaData = deSerialized();
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimePlainEncodeReadTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimePlainEncodeReadTest.java
index 04f9779..e7e1d26 100755
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimePlainEncodeReadTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimePlainEncodeReadTest.java
@@ -20,7 +20,6 @@ package org.apache.iotdb.tsfile.read;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
import org.apache.iotdb.tsfile.constant.TestConstant;
-import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
import org.apache.iotdb.tsfile.read.common.Field;
import org.apache.iotdb.tsfile.read.common.Path;
import org.apache.iotdb.tsfile.read.common.RowRecord;
@@ -53,7 +52,7 @@ public class TimePlainEncodeReadTest {
private static ReadOnlyTsFile roTsFile = null;
@Before
- public void prepare() throws IOException, InterruptedException, WriteProcessException {
+ public void prepare() throws IOException {
TSFileDescriptor.getInstance().getConfig().setTimeEncoder("PLAIN");
FileGenerator.generateFile();
TsFileSequenceReader reader = new TsFileSequenceReader(fileName);
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimeSeriesMetadataReadTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimeSeriesMetadataReadTest.java
index 46a919b..8015284 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimeSeriesMetadataReadTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimeSeriesMetadataReadTest.java
@@ -51,7 +51,7 @@ public class TimeSeriesMetadataReadTest {
}
@After
- public void after() throws IOException {
+ public void after() {
FileGenerator.after();
conf.setMaxDegreeOfIndexNode(maxDegreeOfIndexNode);
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/GroupByFilterTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/GroupByFilterTest.java
index 73feabf..ee4b8e1 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/GroupByFilterTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/GroupByFilterTest.java
@@ -32,7 +32,7 @@ public class GroupByFilterTest {
private GroupByFilter groupByFilter;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
groupByFilter = new GroupByFilter(3, 24, 8, 8 + 30 * 24 + 3 + 6);
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/executor/QueryExecutorTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/executor/QueryExecutorTest.java
index a53bfbf..9c8fc2c 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/executor/QueryExecutorTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/executor/QueryExecutorTest.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.tsfile.read.query.executor;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
-import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
import org.apache.iotdb.tsfile.read.TsFileSequenceReader;
import org.apache.iotdb.tsfile.read.common.Path;
import org.apache.iotdb.tsfile.read.common.RowRecord;
@@ -56,7 +55,7 @@ public class QueryExecutorTest {
private TsFileExecutor queryExecutorWithQueryFilter;
@Before
- public void before() throws InterruptedException, WriteProcessException, IOException {
+ public void before() throws IOException {
TSFileDescriptor.getInstance().getConfig().setTimeEncoder("TS_2DIFF");
TsFileGeneratorForTest.generateFile(rowCount, 16 * 1024 * 1024, 10000);
fileReader = new TsFileSequenceReader(FILE_PATH);
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/ReaderByTimestampTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/ReaderByTimestampTest.java
index b704850..7ae6252 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/ReaderByTimestampTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/ReaderByTimestampTest.java
@@ -19,7 +19,6 @@
package org.apache.iotdb.tsfile.read.query.timegenerator;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
-import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
import org.apache.iotdb.tsfile.file.metadata.ChunkMetadata;
import org.apache.iotdb.tsfile.read.TsFileSequenceReader;
import org.apache.iotdb.tsfile.read.common.BatchData;
@@ -47,7 +46,7 @@ public class ReaderByTimestampTest {
private int rowCount = 1000000;
@Before
- public void before() throws InterruptedException, WriteProcessException, IOException {
+ public void before() throws IOException {
TSFileDescriptor.getInstance().getConfig().setTimeEncoder("TS_2DIFF");
TsFileGeneratorForSeriesReaderByTimestamp.generateFile(rowCount, 10 * 1024 * 1024, 10000);
fileReader = new TsFileSequenceReader(FILE_PATH); // TODO remove this class
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/TsFileGeneratorForSeriesReaderByTimestamp.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/TsFileGeneratorForSeriesReaderByTimestamp.java
index 6cef24d..fc30773 100755
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/TsFileGeneratorForSeriesReaderByTimestamp.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/query/timegenerator/TsFileGeneratorForSeriesReaderByTimestamp.java
@@ -62,8 +62,7 @@ public class TsFileGeneratorForSeriesReaderByTimestamp {
private static int preChunkGroupSize;
private static int prePageSize;
- public static void generateFile(int rc, int rs, int ps)
- throws IOException, InterruptedException, WriteProcessException {
+ public static void generateFile(int rc, int rs, int ps) throws IOException {
rowCount = rc;
chunkGroupSize = rs;
pageSize = ps;
@@ -152,7 +151,7 @@ public class TsFileGeneratorForSeriesReaderByTimestamp {
fw.close();
}
- public static void write() throws IOException, InterruptedException, WriteProcessException {
+ public static void write() throws IOException {
File file = new File(outputDataFile);
File errorFile = new File(errorOutputDataFile);
if (file.exists()) {
@@ -227,8 +226,7 @@ public class TsFileGeneratorForSeriesReaderByTimestamp {
new Path("d2", "s4"), new MeasurementSchema("s4", TSDataType.TEXT, TSEncoding.PLAIN));
}
- public static void writeToFile(Schema schema)
- throws InterruptedException, IOException, WriteProcessException {
+ public static void writeToFile(Schema schema) throws IOException, WriteProcessException {
Scanner in = getDataFile(inputDataFile);
long lineCount = 0;
long startTime = System.currentTimeMillis();
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedMultiBatchReader.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedMultiBatchReader.java
index 1c83110..f580fd1 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedMultiBatchReader.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedMultiBatchReader.java
@@ -22,8 +22,6 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.read.common.BatchData;
import org.apache.iotdb.tsfile.read.filter.basic.Filter;
-import java.io.IOException;
-
public class FakedMultiBatchReader implements IBatchReader {
private long time = 0;
@@ -57,5 +55,5 @@ public class FakedMultiBatchReader implements IBatchReader {
}
@Override
- public void close() throws IOException {}
+ public void close() {}
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/BytesUtilsTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/BytesUtilsTest.java
index 52b76d3..3c63753 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/BytesUtilsTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/BytesUtilsTest.java
@@ -58,7 +58,7 @@ public class BytesUtilsTest {
}
@Test
- public void testFloatToBytes() throws Exception {
+ public void testFloatToBytes() {
// fail("NotFilter yet implemented");
float b = 25.0f;
byte[] bb = BytesUtils.floatToBytes(b);
@@ -80,7 +80,7 @@ public class BytesUtilsTest {
}
@Test
- public void testBoolToBytes() throws Exception {
+ public void testBoolToBytes() {
boolean b = true;
byte[] bb = BytesUtils.boolToBytes(b);
boolean bf = BytesUtils.bytesToBool(bb);
@@ -88,7 +88,7 @@ public class BytesUtilsTest {
}
@Test
- public void testBytesToBool() throws Exception {
+ public void testBytesToBool() {
boolean b = false;
byte[] bb = BytesUtils.boolToBytes(b);
boolean bf = BytesUtils.bytesToBool(bb);
@@ -211,7 +211,7 @@ public class BytesUtilsTest {
}
@Test
- public void testSubBytes() throws IOException {
+ public void testSubBytes() {
List<byte[]> list = new ArrayList<byte[]>();
float f1 = 12.4f;
boolean b1 = true;
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteStreamUtilsTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteStreamUtilsTest.java
index b3adb2c..018e7cf 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteStreamUtilsTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteStreamUtilsTest.java
@@ -38,7 +38,7 @@ public class ReadWriteStreamUtilsTest {
private List<Long> littleEndianLongList;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
unsignedVarIntList = new ArrayList<Integer>();
littleEndianIntList = new ArrayList<Integer>();
littleEndianLongList = new ArrayList<Long>();
@@ -66,7 +66,7 @@ public class ReadWriteStreamUtilsTest {
}
@After
- public void tearDown() throws Exception {}
+ public void tearDown() {}
@Test
public void testGetIntMinBitWidth() {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteToBytesUtilsTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteToBytesUtilsTest.java
index 1809daa..3958b1d 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteToBytesUtilsTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/ReadWriteToBytesUtilsTest.java
@@ -41,7 +41,7 @@ public class ReadWriteToBytesUtilsTest {
}
@Test
- public void testShort2() throws IOException {
+ public void testShort2() {
for (short i : new short[] {1, 2, 3, 4, 5}) {
ByteBuffer output = ByteBuffer.allocate(2);
ReadWriteIOUtils.write(i, output);
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtilsTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtilsTest.java
index 886bf11..fca1560 100755
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtilsTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtilsTest.java
@@ -20,7 +20,6 @@ package org.apache.iotdb.tsfile.utils;
import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
-import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.read.common.Path;
@@ -63,7 +62,7 @@ public class RecordUtilsTest {
}
@Before
- public void prepare() throws WriteProcessException {
+ public void prepare() {
schema = new Schema();
schema = generateTestData();
}
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/PerfTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/PerfTest.java
index 8c488b5..6ca7555 100755
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/PerfTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/PerfTest.java
@@ -114,7 +114,7 @@ public class PerfTest {
}
}
- private static void write() throws IOException, InterruptedException, WriteProcessException {
+ private static void write() throws IOException, InterruptedException {
File file = new File(outputDataFile);
File errorFile = new File(errorOutputDataFile);
if (file.exists()) {
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/ReadPageInMemTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/ReadPageInMemTest.java
index 0031054..b721a5f 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/ReadPageInMemTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/ReadPageInMemTest.java
@@ -98,7 +98,7 @@ public class ReadPageInMemTest {
}
@After
- public void tearDown() throws Exception {
+ public void tearDown() {
file.delete();
conf.setPageSizeInByte(pageSize);
conf.setGroupSizeInByte(ChunkGroupSize);
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileReadWriteTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileReadWriteTest.java
index 0556610..58b1cb6 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileReadWriteTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileReadWriteTest.java
@@ -58,7 +58,7 @@ public class TsFileReadWriteTest {
private File f;
@Before
- public void setUp() throws Exception {
+ public void setUp() {
f = new File(path);
if (f.exists()) {
assertTrue(f.delete());
@@ -66,7 +66,7 @@ public class TsFileReadWriteTest {
}
@After
- public void tearDown() throws Exception {
+ public void tearDown() {
f = new File(path);
if (f.exists()) {
assertTrue(f.delete());
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileWriterTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileWriterTest.java
index 5a08185..9f9e5cc 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileWriterTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/TsFileWriterTest.java
@@ -234,7 +234,7 @@ public class TsFileWriterTest {
}
@Test
- public void getIOWriter() throws IOException {
+ public void getIOWriter() {
// The interface is just for test
writer.getIOWriter();
closeFile();
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/WriteTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/WriteTest.java
index ce75944..4364f37 100755
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/write/WriteTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/write/WriteTest.java
@@ -75,7 +75,7 @@ public class WriteTest {
private String[] enums = {"MAN", "WOMAN"};
@Before
- public void prepare() throws IOException, WriteProcessException {
+ public void prepare() throws IOException {
inputDataFile = TestConstant.BASE_OUTPUT_PATH.concat("writeTestInputData");
outputDataFile = TestConstant.BASE_OUTPUT_PATH.concat("writeTestOutputData.tsfile");
errorOutputDataFile = TestConstant.BASE_OUTPUT_PATH.concat("writeTestErrorOutputData.tsfile");