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:46 UTC
[iotdb] 01/01: [IOTDB-1169] Clean up for redundant throw clause
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");