zeyk created NIFI-7785:
--------------------------
Summary: CaptureChangeMySQL processor captures enum values as
"INDEX of those values" from Mysql DB"
Key: NIFI-7785
URL: https://issues.apache.org/jira/browse/NIFI-7785
Project: Apache NiFi
Issue Type: Bug
Components: Tools and Build
Affects Versions: 1.11.4
Environment: Ubuntu EC2 instance with 8 GB ram
Reporter: zeyk
CaptureChangeMySQL processor captures enum values as "INDEX of those values"
rather than the values specified.
for example:
A table has columns (id int, fruit enum ('apple','pears','orange'), price int)
On doing an insert:
insert into (1,'apple',45)
insert into (2,'pears',56)
I have used CaptureChangeMySql processor to capture the CDC changes, the
process does the capture but captures the enum column alone based on its index
like the sample below:
for 1st insert:
{
"type":"insert",
"timestamp":1599004442000,
"binlog_filename":"mysql-bin-changelog.000039",
"binlog_position":1537835,
"database":"sample",
"table_name":"sample",
"table_id":82,
"columns":[
{
"id":1,
"name":"id",
"column_type":-5,
"value":139
},
{
"id":2,
"name":"fruit",
"column_type":12,
"value":0
},
{
"id":3,
"name":"price",
"column_type":12,
"value":45
}
]
}
for 2nd insert:
{
"type":"insert",
"timestamp":1599004442000,
"binlog_filename":"mysql-bin-changelog.000039",
"binlog_position":1537835,
"database":"sample",
"table_name":"sample",
"table_id":82,
"columns":[
{
"id":1,
"name":"id",
"column_type":-5,
"value":139
},
{
"id":2,
"name":"fruit",
"column_type":12,
"value":1
},
{
"id":3,
"name":"price",
"column_type":12,
"value":56
}
]
}
So the above has 0 and 1 in place of apple and pears respectively.
Could you of you help me on this, if there are folks who have faced similar
kinda issue
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
