I meet some problem i wanna use kafka connect oracle and hdfs then use hive。 message:org.apache.hadoop.hive.serde2.avro.AvroSerdeException Invalid precision or scale for decimal type

Mon, 09 Oct 2017 08:55:00 -0700 

this is my oracle table

CREATE TABLE
    T_JR_CCQK
    (
        CC_ID INTEGER NOT NULL,
        CC_USER_FK INTEGER,
        CC_DEPT_FK INTEGER,
        CC_YEAR INTEGER,
        CC_MOUTH INTEGER,
        CC_DAY INTEGER,
        CC_STATES INTEGER,
        CC_ZCD VARCHAR2(80),
        CC_CCD VARCHAR2(80),
        CONSTRAINT P_KEY_JR_CCQK PRIMARY KEY (CC_ID)
    );


i use kafka-connector-jdbc。the topic data like this
{"CC_ID":"\u0001`","CC_USER_FK":{"bytes":"\u001Ed"},"CC_DEPT‌​_FK":{"bytes":"\u000‌​3I"},"CC_YEAR":{"byt‌​es":"\u0007à"},"CC_M‌​OUTH":{"bytes":"\f"}‌​,"CC_DAY":{"bytes":"‌​\u0012"},"CC_STATES"‌​:{"bytes":"\u0002"},‌​"CC_ZCD":{"string":"‌​泰安市"},"CC_CCD":{"str‌​ing":"海口市"}}

Reply via email to