This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new df8136d8e0 Fix new standalone auto create aligned timeseries bug
(#6345)
df8136d8e0 is described below
commit df8136d8e09f0493432705e244a371c0f3a98574
Author: Haonan <[email protected]>
AuthorDate: Mon Jun 20 16:38:13 2022 +0800
Fix new standalone auto create aligned timeseries bug (#6345)
---
.../org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java
index cc61c86362..7d4ac12f5f 100644
---
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java
+++
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java
@@ -302,7 +302,7 @@ public class StandaloneSchemaFetcher implements
ISchemaFetcher {
schemaRegion.createTimeseries(createTimeSeriesPlan, -1);
}
}
- } catch (MetadataException e) {
+ } catch (Exception e) {
throw new RuntimeException("cannot auto create schema ", e);
}
}
diff --git
a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
index 3792ef5c6c..a8024c5504 100644
---
a/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
+++
b/server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
@@ -129,7 +129,7 @@ public class CreateAlignedTimeSeriesPlan extends
PhysicalPlan {
return compressors;
}
- public void setCompressors(List<CompressionType> compressor) {
+ public void setCompressors(List<CompressionType> compressors) {
this.compressors = compressors;
}