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;
   }
 

Reply via email to