This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b7e1437 [FLINK-25160][docs] Clarified purpose of
execution.checkpointing.tolerable-failed-checkpoints
add a666ba2 [FLINK-25167][API / DataStream]Expose StreamOperatorFactory
in ConnectedStreams#transform
add c385772 [FLINK-25167][API / DataStream]mark StreamOperatorFactory as
@PublicEvolving and add the new volation
No new revisions were added by this update.
Summary of changes:
.../violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 1 +
.../streaming/api/datastream/ConnectedStreams.java | 20 +++++++++++++++++++-
.../api/operators/StreamOperatorFactory.java | 4 ++--
...rator.java => TwoInputStreamOperatorFactory.java} | 14 ++++++++------
.../flink/streaming/api/scala/ConnectedStreams.scala | 9 ++++++++-
5 files changed, 38 insertions(+), 10 deletions(-)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/{MultipleInputStreamOperator.java
=> TwoInputStreamOperatorFactory.java} (75%)
