Hello, I have implemented stateful streaming functionality in the Spark Runner and am currently in the testing phase.
Since implementing timer functionality seems quite challenging at this point, I am considering creating a PR with state management implementation only. I have added logic to reject pipelines where timers are detected in the user's DoFn. I would like to get the community's opinion on this approach: 1. Is it acceptable to submit a PR with state-only implementation at this stage? 2. Or should the implementation include both state and timer functionality to be considered complete? The current implementation: - Fully supports state management in streaming context - Includes validation to reject pipelines that use timers - Has been tested for state management scenarios I believe this could be a good first step, allowing for timer implementation to be added later. However, I wanted to check with the community before proceeding with the PR. Thank you for your guidance. Best regards
