Re: Unable to read state Witten by Beam application with Flink runner using Flink's State Processor API

2021-07-27 Thread David Morávek
This thread is duplicated on the dev mailing list [1]. [1] https://lists.apache.org/x/thread.html/r87fa8153137a4968f6a4f6b47c97c4d892664d864c51a79574821165@%3Cdev.flink.apache.org%3E Best, D. On Tue, Jul 27, 2021 at 5:38 PM Kathula, Sandeep wrote: > Hi, > > We have a simple Beam

Unable to read state Witten by Beam application with Flink runner using Flink's State Processor API

2021-07-27 Thread Kathula, Sandeep
Hi, We have a simple Beam application like a work count running with Flink runner (Beam 2.26 and Flink 1.9). We are using Beam’s value state. I am trying to read the state from savepoint using Flink's State Processor API but getting a NullPointerException. Converted the whole code into