mongodb2tdengine typo

This commit is contained in:
dingbo 2021-11-18 20:18:40 +08:00
parent 75d4f7e101
commit 485d2d8815
3 changed files with 2 additions and 3 deletions

View File

@ -197,7 +197,7 @@ CREATE STABLE IF NOT EXISTS market_snapshot (
)
TAGS(
industry NCHAR(64),
stockID NCHAR(64
stockID NCHAR(64)
);
```

View File

@ -3,7 +3,6 @@ package com.alibaba.datax.plugin.writer.tdenginewriter;
import com.alibaba.datax.common.element.Column;
import com.alibaba.datax.common.element.Record;
import com.alibaba.datax.common.exception.DataXException;
import com.alibaba.datax.common.plugin.AbstractTaskPlugin;
import com.alibaba.datax.common.plugin.TaskPluginCollector;
import com.taosdata.jdbc.TSDBPreparedStatement;
import org.slf4j.Logger;

View File

@ -48,7 +48,7 @@ public class SchemaManager {
case BOOL:
return "BOOL";
case BYTES:
return "BINARY";
return "BINARY(64)";
default:
throw DataXException.asDataXException(TDengineWriterErrorCode.TYPE_ERROR, type.toString());
}