Hello Guys What do we have in flink to become stat...
# troubleshooting
d
Hello Guys What do we have in flink to become stateful, as I don't have a Keyed stream so I can't use keyedStates.
Copy code
connectedStream.process(new BroadcastProcessFunction[]{
  "I want to persist an array here"
})
s
its similar to KeyedBroadcastProcessFunction : https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/broadcast_state/ essentially statefulness comes from StateDescriptor and using ctx.getBroadcastState