Hi, appreciate if anyone can help with this question, thanks! 🙂 What are the options to sync input streams in time? https://stackoverflow.com/questions/75591993/in-flink-what-are-the-options-to-sync-inputs-in-time

As S.O. questions go, your question is somewhat confusing, and it's not clear what you want. My own (somewhat beginner level) understanding would first suggest using windowing functions, but all data might not hit the window as some data does not come frequently. So, something custom using the datastream api might be appropriate.

I've rewritten the SO question to make it easier to understand (hopefully).

• "I couldn't fit my logic into using windows, because there's a shared state that needs to be stored and queried. And AFAIK you cant have custom state with windows (please correct me if I'm wrong)" Here you can always have a keyed process function with state right

Windows can have custom state, though using a keyed process function may be more straightforward, depending on the requirements.