[
https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mahendran Ponnusamy updated FLINK-24494:
----------------------------------------
Description:
Given a schema registered to a topic with name and namespave
when the flink sql with upsert-kafka connector writes to the topic,
it fails coz row it tries to produce is not compatibale with the schema
registered
{color:#cc7832} {color}
{
{color:#9876aa}"type" {color}{color:#cc7832}:
{color}{color:#6a8759}"record"{color}{color:#cc7832},{color}
{color:#9876aa}"name" {color}{color:#cc7832}:
{color}{color:#6a8759}"SimpleCustomer"{color}{color:#cc7832},{color}
{color:#9876aa}"namespace" {color}{color:#cc7832}:
{color}{color:#6a8759}"com...example.model"{color}{color:#cc7832},{color}
{color:#9876aa}"fields" {color}{color:#cc7832}: {color}[ {
{color:#9876aa}"name" {color}{color:#cc7832}:
{color}{color:#6a8759}"customerId"{color}{color:#cc7832},{color}
{color:#9876aa}"type" {color}{color:#cc7832}:
{color}{color:#6a8759}"string"{color} }{color:#cc7832}, {color}{
{color:#9876aa}"name" {color}{color:#cc7832}:
{color}{color:#6a8759}"age"{color}{color:#cc7832},{color} {color:#9876aa}"type"
{color}{color:#cc7832}:
{color}{color:#6a8759}"int"{color}{color:#cc7832},{color}
{color:#9876aa}"default" {color}{color:#cc7832}: {color}{color:#6897bb}0{color}
}]
}
was:
Given a schema registered to a topic with default value as '0' for int,
when the flink sql with upsert-kafka connector writes to the topic,
it fails coz the schema registered is not compatible with the data [schema] it
is producing where there is not default value [{color:#9876aa}"default"
{color}{color:#cc7832}: {color}{color:#6897bb}0{color}] for the int.
{color:#cc7832} {color}
{
{color:#9876aa}"type" {color}{color:#cc7832}:
{color}{color:#6a8759}"record"{color}{color:#cc7832},{color}
{color:#9876aa}"name" {color}{color:#cc7832}:
{color}{color:#6a8759}"SimpleCustomer"{color}{color:#cc7832},{color}
{color:#9876aa}"namespace" {color}{color:#cc7832}:
{color}{color:#6a8759}"com...example.model"{color}{color:#cc7832},{color}
{color:#9876aa}"fields" {color}{color:#cc7832}: {color}[ {
{color:#9876aa}"name" {color}{color:#cc7832}:
{color}{color:#6a8759}"customerId"{color}{color:#cc7832},{color}
{color:#9876aa}"type" {color}{color:#cc7832}:
{color}{color:#6a8759}"string"{color} }{color:#cc7832}, {color}{
{color:#9876aa}"name" {color}{color:#cc7832}:
{color}{color:#6a8759}"age"{color}{color:#cc7832},{color} {color:#9876aa}"type"
{color}{color:#cc7832}:
{color}{color:#6a8759}"int"{color}{color:#cc7832},{color}
{color:#9876aa}"default" {color}{color:#cc7832}: {color}{color:#6897bb}0{color}
}]
}
> Avro Confluent Registry SQL kafka connector fails to write to the topic with
> schema
> -------------------------------------------------------------------------------------
>
> Key: FLINK-24494
> URL: https://issues.apache.org/jira/browse/FLINK-24494
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Table SQL / API
> Affects Versions: 1.13.2
> Reporter: Mahendran Ponnusamy
> Priority: Critical
> Attachments: Screen Shot 2021-10-12 at 10.38.55 AM.png,
> image-2021-10-12-12-09-30-374.png, image-2021-10-12-12-11-04-664.png
>
>
>
> Given a schema registered to a topic with name and namespave
> when the flink sql with upsert-kafka connector writes to the topic,
> it fails coz row it tries to produce is not compatibale with the schema
> registered
> {color:#cc7832} {color}
> {
> {color:#9876aa}"type" {color}{color:#cc7832}:
> {color}{color:#6a8759}"record"{color}{color:#cc7832},{color}
> {color:#9876aa}"name" {color}{color:#cc7832}:
> {color}{color:#6a8759}"SimpleCustomer"{color}{color:#cc7832},{color}
> {color:#9876aa}"namespace" {color}{color:#cc7832}:
> {color}{color:#6a8759}"com...example.model"{color}{color:#cc7832},{color}
> {color:#9876aa}"fields" {color}{color:#cc7832}: {color}[ {
> {color:#9876aa}"name" {color}{color:#cc7832}:
> {color}{color:#6a8759}"customerId"{color}{color:#cc7832},{color}
> {color:#9876aa}"type" {color}{color:#cc7832}:
> {color}{color:#6a8759}"string"{color} }{color:#cc7832}, {color}{
> {color:#9876aa}"name" {color}{color:#cc7832}:
> {color}{color:#6a8759}"age"{color}{color:#cc7832},{color}
> {color:#9876aa}"type" {color}{color:#cc7832}:
> {color}{color:#6a8759}"int"{color}{color:#cc7832},{color}
> {color:#9876aa}"default" {color}{color:#cc7832}:
> {color}{color:#6897bb}0{color} }]
> }
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
