Juntao Hu created FLINK-28043:
-
Summary: "Invalid lambda deserialization" in AvroParquetReaders
Key: FLINK-28043
URL: https://issues.apache.org/jira/browse/FLINK-28043
Project: Flink
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/F
Shengkai Fang created FLINK-18857:
-
Summary: Invalid lambda deserialization when use
ElasticsearchSink#Builder to build ElasticserachSink
Key: FLINK-18857
URL: https://issues.apache.org/jira/browse/FLINK-18857
Shengkai Fang created FLINK-18006:
-
Summary: It will throw Invalid lambda deserialization Exception
when writing to elastic search with new format
Key: FLINK-18006
URL: https://issues.apache.org/jira/browse/FLINK
AM schrieb Amit Jain:
>>>
>>> Hi,
>>>>
>>>> I'm writing a job to merge old data with changelogs using DataSet API
>>>> where
>>>> I'm reading changelog using TextInputFormat and old data using
>>>> HadoopInputFor
rs are immediately going to failed state because of
*Caused by: java.lang.IllegalArgumentException: Invalid lambda
deserialization*
Complete stack trace
java.lang.RuntimeException: The initialization of the DataSource's outputs
caused an error: Could not read the user code wrapper:
tFormat.
>>
>> I can see, job manager has successfully deployed the program flow to
>> worker
>> nodes. However, workers are immediately going to failed state because of
>> *Caused by: java.lang.IllegalArgumentException: Invalid lambda
>> deserialization*
>>
;m reading changelog using TextInputFormat and old data using
HadoopInputFormat.
I can see, job manager has successfully deployed the program flow to worker
nodes. However, workers are immediately going to failed state because of
*Caused by: java.lang.IllegalArgumentException: Invalid lambda
deser
to failed state because of
*Caused by: java.lang.IllegalArgumentException: Invalid lambda
deserialization*
Complete stack trace
java.lang.RuntimeException: The initialization of the DataSource's outputs
caused an error: Could not read the user code wrapper: unexpected ex
