[jira] [Closed] (FLINK-28681) The number of windows allocated by sliding windows is inaccurate, when the window length is irregular

[ https://issues.apache.org/jira/browse/FLINK-28681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping closed FLINK-28681. - Resolution: Fixed > The number of windows allocated by sliding windows is inaccurate, when the > window

[jira] [Closed] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping closed FLINK-28504. - Resolution: Not A Bug > Local-Global aggregation causes watermark alignment > (table.exec.source.idle-t

[jira] [Updated] (FLINK-28681) The number of windows allocated by sliding windows is inaccurate, when the window length is irregular

[ https://issues.apache.org/jira/browse/FLINK-28681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28681: -- Description: In assignWindows, the initial length of the list of Windows is determined by '(int) (siz

[jira] [Created] (FLINK-28681) The number of windows allocated by sliding windows is inaccurate, when the window length is irregular

nyingping created FLINK-28681: - Summary: The number of windows allocated by sliding windows is inaccurate, when the window length is irregular Key: FLINK-28681 URL: https://issues.apache.org/jira/browse/FLINK-28681

[jira] [Commented] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567885#comment-17567885 ] nyingping commented on FLINK-28504: --- [~martijnvisser] Hi, Could you assign this task t

[jira] [Comment Edited] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565350#comment-17565350 ] nyingping edited comment on FLINK-28504 at 7/12/22 8:03 AM:

[jira] [Commented] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565350#comment-17565350 ] nyingping commented on FLINK-28504: --- yes,It is work when set like this {code:java} st.

[jira] [Updated] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28504: -- Affects Version/s: 1.14.5 (was: 1.14.2) > Local-Global aggregation causes w

[jira] [Commented] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565341#comment-17565341 ] nyingping commented on FLINK-28504: --- [~martijnvisser]  yeah,I have tested it on versi

[jira] [Updated] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28504: -- Environment: flink 1.14 kafka 2.4 was: flink 1.14.1 kafka 2.4 > Local-Global aggregation causes

[jira] [Updated] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28504: -- Description: I have a window topN test task, the code is as follows   {code:java}  Configuration conf

[jira] [Updated] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28504: -- Description: I have a window topN test task, the code is as follows   {code:java}  Configuration conf

[jira] [Updated] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28504: -- Description: I have a window topN test task, the code is as follows   {code:java}  Configuration conf

[jira] [Updated] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

[ https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28504: -- Description: I have a window topN test task, the code is as follows `  Configuration configuration =

[jira] [Created] (FLINK-28504) Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid

nyingping created FLINK-28504: - Summary: Local-Global aggregation causes watermark alignment (table.exec.source.idle-timeout) of idle partition invalid Key: FLINK-28504 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Closed] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping closed FLINK-26086. - Resolution: Fixed > fixed some causing ambiguities including the 'shit' comment > --

[jira] [Updated] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-26086: -- Description: such as [`@param shiftTimeZone the shit timezone of the window`|https://github.com/apa

[jira] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086 ] nyingping deleted comment on FLINK-26086: --- was (Author: JIRAUSER282677): Hi [~mapohl] could you assign this simple fix to me when you are free? if you think this fix is necessary. Thanks in a

[jira] [Commented] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497108#comment-17497108 ] nyingping commented on FLINK-26086: --- Hi [~trohrmann] could you assign this simple fix

[jira] [Comment Edited] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495824#comment-17495824 ] nyingping edited comment on FLINK-26086 at 2/22/22, 7:22 AM: -

[jira] [Comment Edited] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490908#comment-17490908 ] nyingping edited comment on FLINK-26086 at 2/22/22, 6:46 AM: -

[jira] [Comment Edited] (FLINK-25877) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490909#comment-17490909 ] nyingping edited comment on FLINK-25877 at 2/22/22, 6:46 AM: -

[jira] [Comment Edited] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495824#comment-17495824 ] nyingping edited comment on FLINK-26086 at 2/22/22, 2:21 AM: -

[jira] [Comment Edited] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495824#comment-17495824 ] nyingping edited comment on FLINK-26086 at 2/22/22, 2:21 AM: -

[jira] [Commented] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495824#comment-17495824 ] nyingping commented on FLINK-26086: --- @Matthias Pohl could you assign this simple fix

[jira] [Comment Edited] (FLINK-25877) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490909#comment-17490909 ] nyingping edited comment on FLINK-25877 at 2/17/22, 6:28 AM: -

[jira] [Comment Edited] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490908#comment-17490908 ] nyingping edited comment on FLINK-26086 at 2/17/22, 6:28 AM: -

[jira] [Updated] (FLINK-26096) Add isolationLevel for JDBC Connector Options

[ https://issues.apache.org/jira/browse/FLINK-26096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-26096: -- Summary: Add isolationLevel for JDBC Connector Options (was: add isolationLevel for jdbc Connector Op

[jira] [Commented] (FLINK-26096) add isolationLevel for jdbc Connector Options

[ https://issues.apache.org/jira/browse/FLINK-26096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491260#comment-17491260 ] nyingping commented on FLINK-26096: --- I would be happy and honored to implement this fe

[jira] [Created] (FLINK-26096) add isolationLevel for jdbc Connector Options

nyingping created FLINK-26096: - Summary: add isolationLevel for jdbc Connector Options Key: FLINK-26096 URL: https://issues.apache.org/jira/browse/FLINK-26096 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-25877) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490909#comment-17490909 ] nyingping commented on FLINK-25877: --- Can someone assign it to me,happy to fix it. tha

[jira] [Commented] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490908#comment-17490908 ] nyingping commented on FLINK-26086: --- Can someone assign it to me,happy to fix it. tha

[jira] [Created] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

nyingping created FLINK-26086: - Summary: fixed some causing ambiguities including the 'shit' comment Key: FLINK-26086 URL: https://issues.apache.org/jira/browse/FLINK-26086 Project: Flink Issue

[jira] [Updated] (FLINK-25877) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-25877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-25877: -- Description: * The current copyright year is 2014-2021 in NOTICE files. We should change it to 2014-20

[jira] [Created] (FLINK-25877) Update the copyright year in NOTICE files

nyingping created FLINK-25877: - Summary: Update the copyright year in NOTICE files Key: FLINK-25877 URL: https://issues.apache.org/jira/browse/FLINK-25877 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17472395#comment-17472395 ] nyingping commented on FLINK-24456: --- Will this feature be released in version 1.15? >