@@ -504,6 +504,7 @@ private void createSynopsisTable(String synopsisName, String schemaName, String
504
504
505
505
SqlDialect dialect = schemaManager .getDialect ();
506
506
if (importSynopsis
507
+ || mTable .getTableType ().equals ("JOIN" )
507
508
|| (dialect instanceof TrainDBSqlDialect
508
509
&& !((TrainDBSqlDialect ) dialect ).supportCreateTableAsSelect ())) {
509
510
sb .append ("(" );
@@ -829,6 +830,7 @@ public void createSynopsis(String synopsisName, TrainDBSqlCommand.SynopsisType s
829
830
catalogContext .createExternalTable (synopsisName , "csv" , synPath .toString ());
830
831
conn .refreshRootSchema ();
831
832
T_tracer .closeTaskTime ("SUCCESS" );
833
+ T_tracer .endTaskTracer ();
832
834
return ;
833
835
}
834
836
@@ -840,6 +842,7 @@ public void createSynopsis(String synopsisName, TrainDBSqlCommand.SynopsisType s
840
842
loadSynopsisIntoTable (synopsisName , mModel .getSchemaName (), mModel .getColumnNames (),
841
843
mModel .getTable (), outputPath );
842
844
T_tracer .closeTaskTime ("SUCCESS" );
845
+ T_tracer .endTaskTracer ();
843
846
} catch (Exception e ) {
844
847
try {
845
848
dropSynopsisTable (synopsisName );
@@ -854,8 +857,6 @@ public void createSynopsis(String synopsisName, TrainDBSqlCommand.SynopsisType s
854
857
855
858
throw new TrainDBException (msg );
856
859
}
857
- T_tracer .closeTaskTime ("SUCCESS" );
858
- T_tracer .endTaskTracer ();
859
860
}
860
861
861
862
private void dropSynopsisTable (String synopsisName ) throws Exception {
0 commit comments