Search before asking
What happened
when script mode the field type is keword, throw not support

What you expected to happen
support keyword type field
How to reproduce
{
"job":{
"content":[
{
"reader":{
"parameter":{
"password":"",
"column":[
{
"name":"id",
"type":"int"
},
{
"name":"age",
"type":"int"
},
{
"name":"name",
"type":"VARCHAR"
}
],
"connection":[
{
"jdbcUrl":[
""
],
"table":[
"source_table"
]
}
],
"username":"drpeco"
},
"name":"mysqlreader"
},
"writer":{
"parameter":{
"password":"null",
"hosts":[
"***:9200"
],
"column":[
{
"name":"ids",
"type":"int"
},
{
"name":"age",
"type":"int"
},
{
"name":"name",
"type":"keyword"
}
],
"index":"flinkx_test",
"ids":[
"ids",
"age"
],
"username":"null"
},
"name":"elasticsearch7writer"
}
}
],
"setting":{
"speed":{
"bytes":0,
"channel":1
}
}
}
}
Anything else
No response
Version
master
Are you willing to submit PR?
Code of Conduct
Search before asking
What happened
when script mode the field type is keword, throw not support

What you expected to happen
support keyword type field
How to reproduce
{
"job":{
"content":[
{
"reader":{
"parameter":{
"password":"",
"column":[
{
"name":"id",
"type":"int"
},
{
"name":"age",
"type":"int"
},
{
"name":"name",
"type":"VARCHAR"
}
],
"connection":[
{
"jdbcUrl":[
""
],
"table":[
"source_table"
]
}
],
"username":"drpeco"
},
"name":"mysqlreader"
},
"writer":{
"parameter":{
"password":"null",
"hosts":[
"***:9200"
],
"column":[
{
"name":"ids",
"type":"int"
},
{
"name":"age",
"type":"int"
},
{
"name":"name",
"type":"keyword"
}
],
"index":"flinkx_test",
"ids":[
"ids",
"age"
],
"username":"null"
},
"name":"elasticsearch7writer"
}
}
],
"setting":{
"speed":{
"bytes":0,
"channel":1
}
}
}
}
Anything else
No response
Version
master
Are you willing to submit PR?
Code of Conduct