You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2021/10/18 09:14:22 UTC

[GitHub] [flink] beyond1920 opened a new pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

beyond1920 opened a new pull request #17509:
URL: https://github.com/apache/flink/pull/17509


   ## What is the purpose of the change
   
   ### Problem description
   
   After recover from savepoint or checkpoint, unexpected behavior of cumulate window aggregate for late event may happened.
   
   ### Bug analyze
   
   Currently, for cumulate window aggregate, late events belongs to the cleaned slice would be merged into the merged window state, and would be counted into the later slice.
   
   For example, for a CUMULATE window, step is 1 minute, size is 1 day.
   
   SELECT window_start, window_end, COUNT(USER_ID)
     FROM TABLE(
       CUMULATE(TABLE Bid, DESCRIPTOR(bidtime), INTERVAL '1' MINUTES, INTERVAL '1' DAY))
     GROUP BY window_start, window_end;
   When the watermark already comes to 11:01, result of window [00:00, 11:01) would be emitted. Let's assume the result is INSERT (00:00, 11:01, 4)
   
   Then if a late record which event time is 11:00 comes, it would be merged into merged state, and would be counted into the later slice, for example, for window [00:00, 11:02), [00:00, 11:03)... But the emitted window result INSERT (00:00, 11:01, 4) would not be retracted and updated.
   
   The behavior would be different if the job recover from savepoint/checkpoint.
   
   Let's do a savepoint after watermark comes to 11:01 and emit (00:00, 11:01, 4).
   
   Then recover the job from savepoint. Watermarks are not checkpointed and they need to be repopulated again. So after recovered, the watermark may rollback to 11:00, then if a record which event time is 11:00 comes, it would not be processed as late event, after watermark comes to 11:01 again, a window result INSERT (00:00, 11:01, 5)  would be emitted to downstream.
   
   So the downstream operator would receive two INSERT record for WINDOW (00:00, 11:01) which may leads to wrong result.
   
    This pull request aims to solve the problem by storing window progress into state in order to check whether an input event is late or not.
   
   ## Brief change log
   
     - Update `WindowValueState` in order to reuse it store window progress
     - Update `AbstractWindowAggProcessor` to store window progress into keyed state
   
   ## Verifying this change
     - Update UT in `SlicingWindowAggOperatorTest#testEventTimeCumulativeWindows` to check the late event would still be processed as late event even if the job is restored from savepoint.
   
   ## Does this pull request potentially affect one of the following parts:
   
     - Dependencies (does it add or upgrade a dependency): (no)
     - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no)
     - The serializers: (no)
     - The runtime per-record code paths (performance sensitive): (no)
     - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no)
     - The S3 file system connector: (no)
   
   ## Documentation
   
     - Does this pull request introduce a new feature? (no)
     - If yes, how is the feature documented? (not applicable)
   


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701) 
   * 47e6223322b4e409c54080919c7954507f27fea1 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7c53a2fa1f78b950a455aada78caa624b7b14d7c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150) 
   * 3ccb32e9c58a2d5181b982c463afabe4b37193bf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot commented on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945572550


   Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community
   to review your pull request. We will use this comment to track the progress of the review.
   
   
   ## Automated Checks
   Last check on commit 7c53a2fa1f78b950a455aada78caa624b7b14d7c (Mon Oct 18 09:18:24 UTC 2021)
   
   **Warnings:**
    * No documentation files were touched! Remember to keep the Flink docs up to date!
   
   
   <sub>Mention the bot in a comment to re-run the automated checks.</sub>
   ## Review Progress
   
   * ❓ 1. The [description] looks good.
   * ❓ 2. There is [consensus] that the contribution should go into to Flink.
   * ❓ 3. Needs [attention] from.
   * ❓ 4. The change fits into the overall [architecture].
   * ❓ 5. Overall code [quality] is good.
   
   Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process.<details>
    The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`)
    - `@flinkbot approve all` to approve all aspects
    - `@flinkbot approve-until architecture` to approve everything until `architecture`
    - `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention
    - `@flinkbot disapprove architecture` to remove an approval you gave earlier
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 3ccb32e9c58a2d5181b982c463afabe4b37193bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] wenlong88 commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r742482235



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
##########
@@ -150,6 +158,8 @@ public void open() throws Exception {
                         getKeyedStateBackend(),
                         collector,
                         getRuntimeContext()));
+        // initialize progress of window processor
+        windowProcessor.advanceProgress(currentWatermark);

Review comment:
       I think we should not call advanceProgress here, because it may be possible that advanceProgress would generate outputs, which is not allowed in open. maybe just add an initialProgess paramter in the constructor?




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701) 
   * 47e6223322b4e409c54080919c7954507f27fea1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594






-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 47e6223322b4e409c54080919c7954507f27fea1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788) 
   * 8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7c53a2fa1f78b950a455aada78caa624b7b14d7c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150) 
   * 3ccb32e9c58a2d5181b982c463afabe4b37193bf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] wenlong88 commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r739943059



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
##########
@@ -170,6 +180,24 @@ public void open() throws Exception {
                         });
     }
 
+    @Override
+    public void initializeState(StateInitializationContext context) throws Exception {
+        super.initializeState(context);
+        ListStateDescriptor<Long> watermarkStateDesc =
+                new ListStateDescriptor<>("watermark", LongSerializer.INSTANCE);
+        this.watermarkState = context.getOperatorStateStore().getListState(watermarkStateDesc);
+        if (context.isRestored()) {
+            this.currentWatermark = this.watermarkState.get().iterator().next();

Review comment:
       use the min watermark as the initial watermark?




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] wenlong88 commented on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-961766089


   LGTM for now， cc  @JingsongLi would you help do the final review since this is a change on table-runtime
   


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594






-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594






-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] JingsongLi commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
JingsongLi commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r746186312



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/window/processors/RowTimeWindowRankProcessor.java
##########
@@ -81,7 +81,7 @@
     private transient JoinedRowData reuseOutput;
     private transient GenericRowData reuseRankRow;
 
-    public WindowRankProcessor(
+    public RowTimeWindowRankProcessor(

Review comment:
       Do we really need change class name? This will break compatibility.

##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
##########
@@ -116,6 +121,9 @@
     /** The tracked processing time triggered last time. */
     private transient long lastTriggeredProcessingTime;
 
+    /** The operator state to store watermark. */
+    private ListState<Long> watermarkState;

Review comment:
       transient




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] beyond1920 commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
beyond1920 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r742587958



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
##########
@@ -150,6 +158,8 @@ public void open() throws Exception {
                         getKeyedStateBackend(),
                         collector,
                         getRuntimeContext()));
+        // initialize progress of window processor
+        windowProcessor.advanceProgress(currentWatermark);

Review comment:
       Currently, there is no windowProcessor implementation flushes data to downstream.
   But I agree with you to add an intializeProgress method because the API is more clear.




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     }, {
       "hash" : "c683b88035514ec2decda77911bb5447f9932a21",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916",
       "triggerID" : "c683b88035514ec2decda77911bb5447f9932a21",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * c683b88035514ec2decda77911bb5447f9932a21 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] wenlong88 commented on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-961766089


   LGTM for now， cc  @JingsongLi would you help do the final review since this is a change on table-runtime
   


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot commented on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7c53a2fa1f78b950a455aada78caa624b7b14d7c UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 3ccb32e9c58a2d5181b982c463afabe4b37193bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157) 
   * 0dbb0411fb710a0d0082edb89782d99dc053140a UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] wenlong88 commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r742674481



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/window/processors/RowTimeWindowRankProcessor.java
##########
@@ -140,6 +140,11 @@ public void open(Context<Long> context) throws Exception {
         this.currentProgress = Long.MIN_VALUE;
     }
 
+    @Override
+    public void initializeWatermark(long watermark) {

Review comment:
       how about just use initializeProgress? keep aligned with advanceProgress




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594






-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594






-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] beyond1920 commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
beyond1920 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r742587958



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/slicing/SlicingWindowOperator.java
##########
@@ -150,6 +158,8 @@ public void open() throws Exception {
                         getKeyedStateBackend(),
                         collector,
                         getRuntimeContext()));
+        // initialize progress of window processor
+        windowProcessor.advanceProgress(currentWatermark);

Review comment:
       Currently, there is no windowProcessor implementation flushes data to downstream.




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] wenlong88 commented on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-961766089


   LGTM for now， cc  @JingsongLi would you help do the final review since this is a change on table-runtime
   


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     }, {
       "hash" : "c683b88035514ec2decda77911bb5447f9932a21",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916",
       "triggerID" : "c683b88035514ec2decda77911bb5447f9932a21",
       "triggerType" : "PUSH"
     }, {
       "hash" : "a010eb5ec6d5f36100d2a9a10ef57df393fdb32f",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26245",
       "triggerID" : "a010eb5ec6d5f36100d2a9a10ef57df393fdb32f",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * c683b88035514ec2decda77911bb5447f9932a21 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916) 
   * a010eb5ec6d5f36100d2a9a10ef57df393fdb32f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26245) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     }, {
       "hash" : "c683b88035514ec2decda77911bb5447f9932a21",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916",
       "triggerID" : "c683b88035514ec2decda77911bb5447f9932a21",
       "triggerType" : "PUSH"
     }, {
       "hash" : "a010eb5ec6d5f36100d2a9a10ef57df393fdb32f",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26245",
       "triggerID" : "a010eb5ec6d5f36100d2a9a10ef57df393fdb32f",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * a010eb5ec6d5f36100d2a9a10ef57df393fdb32f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26245) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     }, {
       "hash" : "c683b88035514ec2decda77911bb5447f9932a21",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916",
       "triggerID" : "c683b88035514ec2decda77911bb5447f9932a21",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834) 
   * c683b88035514ec2decda77911bb5447f9932a21 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] beyond1920 commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
beyond1920 commented on a change in pull request #17509:
URL: https://github.com/apache/flink/pull/17509#discussion_r742682263



##########
File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/window/processors/RowTimeWindowRankProcessor.java
##########
@@ -140,6 +140,11 @@ public void open(Context<Long> context) throws Exception {
         this.currentProgress = Long.MIN_VALUE;
     }
 
+    @Override
+    public void initializeWatermark(long watermark) {

Review comment:
       I prefer initializeWatermark.
   For event time, progress is equals to watermark.
   But for proctime, progress is processtime time.
   Here we only initialize watermark.




-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 47e6223322b4e409c54080919c7954507f27fea1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     }, {
       "hash" : "c683b88035514ec2decda77911bb5447f9932a21",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916",
       "triggerID" : "c683b88035514ec2decda77911bb5447f9932a21",
       "triggerType" : "PUSH"
     }, {
       "hash" : "a010eb5ec6d5f36100d2a9a10ef57df393fdb32f",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "a010eb5ec6d5f36100d2a9a10ef57df393fdb32f",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * c683b88035514ec2decda77911bb5447f9932a21 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25916) 
   * a010eb5ec6d5f36100d2a9a10ef57df393fdb32f UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7c53a2fa1f78b950a455aada78caa624b7b14d7c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150) 
   * 3ccb32e9c58a2d5181b982c463afabe4b37193bf UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 3ccb32e9c58a2d5181b982c463afabe4b37193bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157) 
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7c53a2fa1f78b950a455aada78caa624b7b14d7c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     }, {
       "hash" : "c683b88035514ec2decda77911bb5447f9932a21",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "c683b88035514ec2decda77911bb5447f9932a21",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25834) 
   * c683b88035514ec2decda77911bb5447f9932a21 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     }, {
       "hash" : "47e6223322b4e409c54080919c7954507f27fea1",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788",
       "triggerID" : "47e6223322b4e409c54080919c7954507f27fea1",
       "triggerType" : "PUSH"
     }, {
       "hash" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 47e6223322b4e409c54080919c7954507f27fea1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25788) 
   * 8b65b50eef16fd8d0f54ed64594d4d1fb3aaf4d2 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25701) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #17509:
URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25150",
       "triggerID" : "7c53a2fa1f78b950a455aada78caa624b7b14d7c",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25157",
       "triggerID" : "3ccb32e9c58a2d5181b982c463afabe4b37193bf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202",
       "triggerID" : "0dbb0411fb710a0d0082edb89782d99dc053140a",
       "triggerType" : "PUSH"
     }, {
       "hash" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700",
       "triggerID" : "dd5e72966a13ff58afb4c224c60731302a589322",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4f49c906baed3dc3b56c8462b20324e943e1eeee",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 0dbb0411fb710a0d0082edb89782d99dc053140a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25202) 
   * dd5e72966a13ff58afb4c224c60731302a589322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25700) 
   * 4f49c906baed3dc3b56c8462b20324e943e1eeee UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [flink] JingsongLi merged pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator.

Posted by GitBox <gi...@apache.org>.
JingsongLi merged pull request #17509:
URL: https://github.com/apache/flink/pull/17509


   


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org