Robin Stephenson created FLINK-20147: ----------------------------------------
Summary: "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 / API Affects Versions: 1.12.0 Reporter: Robin Stephenson 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)