-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Description
Search before asking
- I searched in the issues and found nothing similar.
Version
the version is 2.0.5
Describe the bug and provide the minimal reproduce step
my table is:
create database testdb2;
CREATE TABLE gwy6l(time TIMESTAMP TIME,measurementname STRING TAG,type STRING ATTRIBUTE,value STRING FIELD,status INT64 FIELD,source_time INT64 FIELD,server_time INT64 FIELD);
the custom pipe processor plugin is:
show pipeplugins is:
my pipe create cmd is:
CREATE PIPE task2742_outer_98785855 WITH SOURCE ('source'='iotdb-source','source.inclusion' = 'data.insert,data.delete', 'source.history.enable' = 'false', 'source.mode.streaming' = 'true') WITH PROCESSOR ('processor' = 'SYNC_IOTDB_IOTDBTABLE_11') WITH SINK ('sink' = 'do-nothing-sink')
insert into data and find in /logs/log_datanode_all.log is:
i can get the insert data , but the data is not complete.
logger.info("tablet schemas:{}",tablet.getSchemas());
logger.info("tablet columnsTypes:{}",tablet.getColumnTypes());
the print log
:[[measurementname,STRING,PLAIN,,LZ4], [server_time,INT64,TS_2DIFF,,LZ4], [source_time,INT64,TS_2DIFF,,LZ4], [status,INT64,TS_2DIFF,,LZ4], [value,STRING,PLAIN,,LZ4]]
not contains the type field ,the type field columnCategory is attribute ,
What did you expect to see?
i want to get the field value(the field is attribute ) from custom pipe processor ,
What did you see instead?
the pipe task should config ?
i can get the field value . the field columnCategory is attribute .
Anything else?
No response
Are you willing to submit a PR?
- I'm willing to submit a PR!