fredia merged PR #24678:
URL: https://github.com/apache/flink/pull/24678
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
Zakelly commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1574232324
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -46,6 +46,12 @@ public
Zakelly commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1574232324
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -46,6 +46,12 @@ public
fredia commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1574075445
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -46,6 +46,12 @@ public
Zakelly commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1574052485
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -23,15 +23,15 @@
import
reswqa commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1572117471
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -23,15 +23,15 @@
import
flinkbot commented on PR #24678:
URL: https://github.com/apache/flink/pull/24678#issuecomment-2063745225
## CI report:
* 503f01052e16a806da7589a8dc0ed645ff00d282 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #24678:
URL: https://github.com/apache/flink/pull/24678
## What is the purpose of the change
This is a simple PR that wire the new introduced operators of DataStream V2
with the `AbstractAsyncStateStreamOperator`.
## Brief change log
