[
https://issues.apache.org/jira/browse/FLINK-20147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234159#comment-17234159
]
jackylau commented on FLINK-20147:
----------------------------------
Yes, I met this problem in cdc too, and also solved by replace lambda withÂ
anonymous classes. It will only exist in distribuited environment.
> "Invalid lambda deserialization" when trying to read metadata from Kafka in
> SQL
> -------------------------------------------------------------------------------
>
> Key: FLINK-20147
> URL: https://issues.apache.org/jira/browse/FLINK-20147
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Table SQL / Ecosystem
> Affects Versions: 1.12.0
> Reporter: Robin Stephenson
> Assignee: Timo Walther
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.12.0
>
> Attachments: stacktrace.txt
>
>
> When creating a table to read from Kafka like so using the recently added
> support for kafka metadata in 1.12:
> {noformat}
> CREATE TABLE test_table (
> `foo` STRING,
> `bar` STRING,
> `record` STRING,
> `offset` BIGINT METADATA VIRTUAL
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'kewltest.r-test.dummy',
> 'key.fields' = 'foo;bar',
> 'key.format' = 'json',
> 'value.format' = 'json',
> 'value.fields-include' = 'EXCEPT_KEY',
> 'scan.startup.mode' = 'earliest-offset',
> 'properties.bootstrap.servers' = '<HOST:PORT>',
> 'properties.group.id' = '<CONSUMER-GROUP>'
> )
> {noformat}
> the "offset" column causes queries of the table to fail with an exception:
> Caused by: java.lang.IllegalArgumentException: Invalid lambda deserialization
> Full stack trace is attached.
> Left priority as default as I wasn't sure what to set it to.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
