[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930981#comment-17930981
]
Yutong Han edited comment on FLINK-37067 at 2/27/25 5:41 AM:
-------------------------------------------------------------
Sync with [~yyhx] via Slack, Xu helped to merge
[https://github.com/apache/flink/pull/26179] to release-2.0 branch.
I built Flink binary from latest branch {{release-2.0}} And use Flink version
{{2.0-SNAPSHOT}} for test WordCount job. The WordCount job is using a stateful
function which implements {{OneInputStreamProcessFunction}} to do the counting.
The job is running as expected. Verifying the first item works as expected!
*Change need to do for documentation:*
[https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/context_and_state_processing/#state-processing]
{code:java}
Optional<ListState<Long>> stateOptional =
ctx.getStateManager().getState(LIST_STATE_DECLARATION);
ListState<Long> state = stateOptional.get();{code}
getState is no longer returning Optional, so we may need to change it to be
{code:java}
ListState<Long> state =
ctx.getStateManager().getState(LIST_STATE_DECLARATION){code}
was (Author: JIRAUSER308597):
Sync with [~yyhx] via Slack, Xu helped to merge
[https://github.com/apache/flink/pull/26179] to release-2.0 branch.
I built Flink binary from latest branch {{release-2.0}} And use Flink version
{{2.0-SNAPSHOT}} for test WordCount job. The WordCount job is using a stateful
function which implements {{OneInputStreamProcessFunction}} to do the counting.
The job is running as expected. Verifying the first item works as expected!
*Change need to do for documentation:*
[https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/context_and_state_processing/#state-processing]
Optional<ListState<Long>> stateOptional =
ctx.getStateManager().getState(LIST_STATE_DECLARATION);
ListState<Long> state = stateOptional.get();
getState is no longer returning Optional, so we need to change it to be
{code:java}
ListState<Long> state =
ctx.getStateManager().getState(LIST_STATE_DECLARATION){code}
> Cross-team verification for “Introduce DataStream API V2”
> ---------------------------------------------------------
>
> Key: FLINK-37067
> URL: https://issues.apache.org/jira/browse/FLINK-37067
> Project: Flink
> Issue Type: Sub-task
> Reporter: Xintong Song
> Assignee: Yutong Han
> Priority: Blocker
> Fix For: 2.0.0
>
>
> In Flink 2.0, we have introduce DataStream API V2. To verify this feature,
> you should test four scenarios:
> 1. Write a stateful DataStream program, such as WordCount. Use
> ProcessFunction to receive and process data, and use State to store the
> state. You can refer to the documentation:
> # [context and state
> processing|https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/context_and_state_processing/]
> 2. Write a window aggregation job using the event time extension and verify
> it. You can refer to the documentation:
> # Event Time
> ## [Event Timer
> Service|https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/time-processing/event_timer_service/]
> ## Examples listed in [FLIP-499: Support Event Time in DataStream
> V2|https://cwiki.apache.org/confluence/x/pQz0Ew]
> # Window
> ##
> [Windows|https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/builtin-funcs/windows/]
> ## Examples listed in [FLIP-501: Support Window in DataStream
> V2|https://cwiki.apache.org/confluence/x/z4kgF]
> 3. Write a Join job using the BuiltinFuncs#join and verify it. You can refer
> to the documentation:
> #
> [Joins|https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/builtin-funcs/joining/]
> # Examples listed in [FLIP-500: Support Join in DataStream
> V2|https://cwiki.apache.org/confluence/x/ywz0Ew]
> 4. Write a job define and using the Watermark and verify it. You can refer to
> the documentation:
> #
> [Watermark|https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream-v2/watermark/]
> # Examples listed in [FLIP-467: Introduce Generalized
> Watermarks|https://cwiki.apache.org/confluence/x/oA6TEg]\
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
