Insufficient number of network buffers for simple last_value aggregate

Dear list, when trying to compute a simple last_value aggregate, flink fails with an IOException. The query is defined as follows: from pyflink.table import EnvironmentSettings, StreamTableEnvironment env_settings = EnvironmentSettings.new_instance().in_streaming_mode().use_blink_planner().buil

PyFlink:

Dear list, I’m having my first go at using Flink and quickly stumbled over a problem I find no easy way around. I hope you may help me. I try to read an avro encoded kafka topic. Doing so, I do get a NoClassDefFoundError. Org.apache.avro.SchemaBuilder could not be found, but this should be inc