-
Notifications
You must be signed in to change notification settings - Fork 13.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-33810][Runtime] Propagate RecordAttributes that contains isProcessingBacklog status #23919
Commits on Dec 11, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 43991e2 - Browse repository at this point
Copy the full SHA 43991e2View commit details
Commits on Dec 13, 2023
-
[FLINK-33810][runtime] SourceCoordinator notify SourceOperator when b…
…acklog is changed
Configuration menu - View commit details
-
Copy full SHA for 0009454 - Browse repository at this point
Copy the full SHA 0009454View commit details -
Configuration menu - View commit details
-
Copy full SHA for 185b846 - Browse repository at this point
Copy the full SHA 185b846View commit details -
[FLINK-33810][runtime] Introduce processRecordAttributes method to In…
…put and TwoInputStreamOperator
Configuration menu - View commit details
-
Copy full SHA for 93bd627 - Browse repository at this point
Copy the full SHA 93bd627View commit details -
Configuration menu - View commit details
-
Copy full SHA for 5a3a684 - Browse repository at this point
Copy the full SHA 5a3a684View commit details -
[FLINK-33202][runtime] SourceOperator send Watermark and RecordAttrib…
…utes downstream when backlog status changed
Configuration menu - View commit details
-
Copy full SHA for 8fd80a3 - Browse repository at this point
Copy the full SHA 8fd80a3View commit details -
[FLINK-33810][runtime] Introduce and implement emitRecordAttributes m…
…ethod of PushingAsyncDataInput#DataOutput
Configuration menu - View commit details
-
Copy full SHA for 77728ef - Browse repository at this point
Copy the full SHA 77728efView commit details
Commits on Dec 14, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 1a27c32 - Browse repository at this point
Copy the full SHA 1a27c32View commit details -
Configuration menu - View commit details
-
Copy full SHA for 84d0516 - Browse repository at this point
Copy the full SHA 84d0516View commit details