column 'load_ts'. Column type: TIMESTAMP, Parquet schema: optional byte_array load_ts
NiFi 가 load_ts 를 문자열로 썼다는 뜻이다. Infer Schema 로 읽으면 ${now():format(...)} 결과가 문자열이 된다.
INT96 Fields 에 load_ts 를 넣어 Impala 호환 INT96 로 기록{"name":"load_ts","type":{"type":"long","logicalType":"timestamp-millis"}} 로 쓰기. Hive 3 · Impala 는 timestamp-micros 도 읽지만 팀 규칙으로 timestamp-millis 통일REFRESH 가 아니라 ALTER TABLE ... ADD PARTITION 이 먼저여야 조회된다avro.schema 속성을 ${avro.schema:replace('"type":"string"','...')} 로 바꿔 ConvertRecord 에 넘기는 방법도 쓸 수 있다. MariaDB datetime(6) 컬럼은 Avro 로 문자열이 되므로 대상 컬럼도 STRING 이면 그대로 두고, TIMESTAMP 면 위 방법으로 바꾼다.
load_ts 를 붙이는 적재 흐름.