[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 6e6774bc6348749909c3a0f662cdc5b608990f42 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread wang shengzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437761#comment-17437761 ] wang shengzhi commented on FLINK-24733: --- [~syhily] I think that the wrong understa

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 6e6774bc6348749909c3a0f662cdc5b608990f42 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * a1619682d1eeaefeaec347c646e12f2b4ed7feb9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] Aitozi commented on a change in pull request #14893: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

2021-11-02 Thread GitBox
Aitozi commented on a change in pull request #14893: URL: https://github.com/apache/flink/pull/14893#discussion_r741654602 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBIncrementalCheckpointUtils.java ##

[GitHub] [flink] wsz94 commented on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
wsz94 commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-958691412 > I don't think this fixed the data loss issue. Pulsar [internally wrap](https://github.com/apache/pulsar/blob/f0413b1adad395319e5595a863764f8af943dbe8/pulsar-client/src/main/java/

[GitHub] [flink] wsz94 removed a comment on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
wsz94 removed a comment on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-958691150 > I don't think this fixed the data loss issue. Pulsar [internally wrap](https://github.com/apache/pulsar/blob/f0413b1adad395319e5595a863764f8af943dbe8/pulsar-client/src/ma

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * f6bd3590036c9bdd760751c7ca9640cc0b1a071a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 6e6774bc6348749909c3a0f662cdc5b608990f42 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wsz94 commented on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
wsz94 commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-958691150 > I don't think this fixed the data loss issue. Pulsar [internally wrap](https://github.com/apache/pulsar/blob/f0413b1adad395319e5595a863764f8af943dbe8/pulsar-client/src/main/java/

[GitHub] [flink] wsz94 closed pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
wsz94 closed pull request #17643: URL: https://github.com/apache/flink/pull/17643 -- 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-unsubscr.

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * a1619682d1eeaefeaec347c646e12f2b4ed7feb9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Mrart commented on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2021-11-02 Thread GitBox
Mrart commented on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-958690348 @flinkbot run azure -- 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 co

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * f6bd3590036c9bdd760751c7ca9640cc0b1a071a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xuyangzhong commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
xuyangzhong commented on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958689754 @flinkbot run azure -- 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 speci

[GitHub] [flink] flinkbot commented on pull request #17653: FLINK SQL checkpoint不生效

2021-11-02 Thread GitBox
flinkbot commented on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958687702 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 195d50be0242cc1eae5576dbf6ec79da67232db8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17653: FLINK SQL checkpoint不生效

2021-11-02 Thread GitBox
flinkbot commented on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 195d50be0242cc1eae5576dbf6ec79da67232db8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] zekai-li commented on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-11-02 Thread GitBox
zekai-li commented on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-958686225 @is Please help review. -- 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 sp

[GitHub] [flink] fanghj opened a new pull request #17653: FLINK SQL checkpoint不生效

2021-11-02 Thread GitBox
fanghj opened a new pull request #17653: URL: https://github.com/apache/flink/pull/17653 flink版本 1.13 cdc 版本 2.02 配置文件 flink-conf.yaml 设置如下 state.backend: filesystem state.checkpoints.dir: file:///tmp/flink-checkpoints state.savepoints.dir: file:///tmp/flink-savepoints

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * 87b6a197aeaa3dff11b7779cd62f26dbc6e1d046 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * 6bf9e572bd13b954cad07b009c65dd4b72cc18ee Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580 ## CI report: * 526b8eddd977adbcf7a839722374995b24d446be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xuyangzhong commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
xuyangzhong commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741632375 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -176,13 +176,13

[GitHub] [flink] xuyangzhong commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
xuyangzhong commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741632375 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -176,13 +176,13

[GitHub] [flink] curcur edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

2021-11-02 Thread GitBox
curcur edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-958666854 Hey folks, I’ve spent some time reading through the `FsStateChangelogWriter` and related `DFS` uploading implementation. Now I have a bit better understanding but with mor

[GitHub] [flink] curcur edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

2021-11-02 Thread GitBox
curcur edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-958666854 Hey folks, I’ve spent some time reading through the `FsStateChangelogWriter` and related `DFS` uploading implementation. Now I have a bit better understanding but with mor

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * 6bf9e572bd13b954cad07b009c65dd4b72cc18ee Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wsry commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-11-02 Thread GitBox
wsry commented on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-958667123 @flinkbot run azure -- 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 com

[GitHub] [flink] curcur commented on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

2021-11-02 Thread GitBox
curcur commented on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-958666854 Hey folks, I’ve spent some time reading through the `FsStateChangelogWriter` and related `DFS` uploading implementation. Now I have a bit better understanding but with more quest

[jira] [Updated] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished

2021-11-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-24713: --- Description: When ResourceManager started, JobManger will connect to the ResourceManager, this means the Re

[jira] [Comment Edited] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437733#comment-17437733 ] JING ZHANG edited comment on FLINK-24001 at 11/3/21, 5:08 AM:

[jira] [Commented] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437733#comment-17437733 ] JING ZHANG commented on FLINK-24001: After discussion with [~lzljs3620320] [~jark],

[jira] [Comment Edited] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412517#comment-17412517 ] JING ZHANG edited comment on FLINK-24001 at 11/3/21, 5:06 AM:

[jira] [Comment Edited] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412517#comment-17412517 ] JING ZHANG edited comment on FLINK-24001 at 11/3/21, 5:02 AM:

[GitHub] [flink] KurtYoung commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
KurtYoung commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741613565 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -176,13 +176,13 @

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * f6bd3590036c9bdd760751c7ca9640cc0b1a071a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
flinkbot commented on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647718 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 pro

[GitHub] [flink] flinkbot commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
flinkbot commented on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * f6bd3590036c9bdd760751c7ca9640cc0b1a071a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-24717) Push down partitions before filters

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24717: --- Labels: pull-request-available (was: ) > Push down partitions before filters >

[GitHub] [flink] xuyangzhong opened a new pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-02 Thread GitBox
xuyangzhong opened a new pull request #17652: URL: https://github.com/apache/flink/pull/17652 ## What is the purpose of the change In the optimized period, put the rule PushPartitionsDown before the rule PushFiltersDown to avoid PushFiltersDown consumes all filters and cause that Pu

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 6e6774bc6348749909c3a0f662cdc5b608990f42 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] KurtYoung commented on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
KurtYoung commented on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-958645030 If such issue already caused a bug, i'd prefer to at least add a test when we trying to fix it. Even the change itself looks tiny, but given it already causes real issue,

[jira] [Commented] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437723#comment-17437723 ] JING ZHANG commented on FLINK-24001: [~icshuo] Session window belongs to set-semanti

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

2021-11-02 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437722#comment-17437722 ] Yun Tang commented on FLINK-21543: -- [~Ming Li], you could refer to RocksDB's documentat

[GitHub] [flink] flinkbot edited a comment on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580 ## CI report: * 526b8eddd977adbcf7a839722374995b24d446be Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24000) window aggregate support allow lateness

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24000: --- Affects Version/s: (was: 1.15.0) > window aggregate support allow lateness > ---

[jira] [Updated] (FLINK-24002) Support count window with the window TVF

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24002: --- Affects Version/s: (was: 1.15.0) > Support count window with the window TVF > --

[jira] [Updated] (FLINK-24024) Support session Window TVF

2021-11-02 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24024: --- Affects Version/s: (was: 1.15.0) > Support session Window TVF > --- > >

[GitHub] [flink] flinkbot commented on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

2021-11-02 Thread GitBox
flinkbot commented on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958640045 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 pro

[GitHub] [flink] Myasuka commented on a change in pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

2021-11-02 Thread GitBox
Myasuka commented on a change in pull request #17645: URL: https://github.com/apache/flink/pull/17645#discussion_r741606981 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/mock/MockKeyedStateBackend.java ## @@ -221,9 +226,11 @@ public void notifyCh

[GitHub] [flink] flinkbot commented on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

2021-11-02 Thread GitBox
flinkbot commented on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580 ## CI report: * 526b8eddd977adbcf7a839722374995b24d446be UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * 2e9cea2efeb7e9f4722275a20f8551f27833fd95 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-02 Thread GitBox
flinkbot commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958639127 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 pro

[jira] [Updated] (FLINK-24656) Add user document for Window Deduplication

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24656: --- Labels: pull-request-available (was: ) > Add user document for Window Deduplication > -

[GitHub] [flink] beyond1920 opened a new pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

2021-11-02 Thread GitBox
beyond1920 opened a new pull request #17651: URL: https://github.com/apache/flink/pull/17651 ## What is the purpose of the change The pr adds documentation for Window deduplication. ## Brief change log Window-deduplication.md ## Verifying this change This c

[GitHub] [flink] flinkbot commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-02 Thread GitBox
flinkbot commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 150b5f9f464913cc83756cbadd233cdb279db0c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] JingsongLi commented on pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

2021-11-02 Thread GitBox
JingsongLi commented on pull request #17569: URL: https://github.com/apache/flink/pull/17569#issuecomment-958638514 Hi @snuyanzin , I'm a little confused. Is the beginning of the era 00 or 01? Have you investigated the behavior of other databases? -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * 2e9cea2efeb7e9f4722275a20f8551f27833fd95 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24475) Remove no longer used NestedMap* classes

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24475: --- Labels: pull-request-available (was: ) > Remove no longer used NestedMap* classes > ---

[GitHub] [flink] Zakelly opened a new pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-02 Thread GitBox
Zakelly opened a new pull request #17650: URL: https://github.com/apache/flink/pull/17650 ## What is the purpose of the change Since NestedStateMap is no longer used in production code after FLINK-21935, this PR removes all NestedMap* classes. ## Brief change log - Remo

[GitHub] [flink] JingsongLi commented on a change in pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

2021-11-02 Thread GitBox
JingsongLi commented on a change in pull request #17569: URL: https://github.com/apache/flink/pull/17569#discussion_r741603842 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -890,14 +890,24

[GitHub] [flink] lincoln-lil commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-02 Thread GitBox
lincoln-lil commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741603426 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -312,6 +35

[GitHub] [flink] lincoln-lil commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-02 Thread GitBox
lincoln-lil commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741602604 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -75,6 +77,

[jira] [Assigned] (FLINK-24728) Batch SQL file sink forgets to close the output stream

2021-11-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-24728: Assignee: Caizhi Weng > Batch SQL file sink forgets to close the output stream >

[jira] [Updated] (FLINK-24728) Batch SQL file sink forgets to close the output stream

2021-11-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-24728: - Priority: Major (was: Critical) > Batch SQL file sink forgets to close the output stream >

[GitHub] [flink] JingsongLi merged pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
JingsongLi merged pull request #17638: URL: https://github.com/apache/flink/pull/17638 -- 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-unsu

[GitHub] [flink] Myasuka commented on a change in pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
Myasuka commented on a change in pull request #17525: URL: https://github.com/apache/flink/pull/17525#discussion_r741597480 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBRocksStateKeysAndNamespacesIteratorTe

[jira] [Commented] (FLINK-24689) Add log file's time info in loglist

2021-11-02 Thread Fei Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437715#comment-17437715 ] Fei Feng commented on FLINK-24689: -- Hi @[~trohrmann] , I will add field called "Last Mo

[GitHub] [flink] tsreaper commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-02 Thread GitBox
tsreaper commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741595404 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -312,6 +355,4

[jira] [Updated] (FLINK-24689) Add log file's time info in loglist

2021-11-02 Thread Fei Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-24689: - Attachment: image-2021-11-03-11-22-36-220.png > Add log file's time info in loglist > --

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17632: URL: https://github.com/apache/flink/pull/17632#issuecomment-956326604 ## CI report: * 6d6de1e30a41f6bf218dae3e03615a222a6c42e3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17632: URL: https://github.com/apache/flink/pull/17632#issuecomment-956326604 ## CI report: * 6d6de1e30a41f6bf218dae3e03615a222a6c42e3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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-t

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 47e6223322b4e409c54080919c7954507f27fea1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-23015) Implement streaming window Deduplicate operator

2021-11-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23015. Resolution: Fixed master: 59d6a189b0aa4d8ccbbc39abb73fe317f0abfcf1 > Implement streaming window D

[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-t

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 47e6223322b4e409c54080919c7954507f27fea1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] JingsongLi commented on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

2021-11-02 Thread GitBox
JingsongLi commented on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-958618670 Minor: @beyond1920 We don't need add "blink" in the commit message, blink planner is the only planner. -- This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] JingsongLi merged pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

2021-11-02 Thread GitBox
JingsongLi merged pull request #17571: URL: https://github.com/apache/flink/pull/17571 -- 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-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-957219037 ## CI report: * 6ca5c75005b602ef88d184f14a4427ff86c24117 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17649: [FLINK-24742][table][docs] Add info about SQL client key strokes to docs

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17649: URL: https://github.com/apache/flink/pull/17649#issuecomment-958288236 ## CI report: * 7081987de10cb9601d16a1292862fb062cf002d5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24726) Hive Lookup Join SQL: decimal type UnsupportedOperationException

2021-11-02 Thread Zongwen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zongwen Li updated FLINK-24726: --- Description: exception trace: {code:java} java.lang.UnsupportedOperationException: org.apache.flink

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 6e6774bc6348749909c3a0f662cdc5b608990f42 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 6e6774bc6348749909c3a0f662cdc5b608990f42 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] mayuehappy commented on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-02 Thread GitBox
mayuehappy commented on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-958606761 @flinkbot run azure -- 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 specif

[GitHub] [flink] flinkbot edited a comment on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-957219037 ## CI report: * 6ca5c75005b602ef88d184f14a4427ff86c24117 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-957219037 ## CI report: * 6ca5c75005b602ef88d184f14a4427ff86c24117 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tsreaper commented on pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
tsreaper commented on pull request #17638: URL: https://github.com/apache/flink/pull/17638#issuecomment-958603402 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * fd4ec5a34a3b9004f0571c5a77795cb4a0cd5931 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * fd4ec5a34a3b9004f0571c5a77795cb4a0cd5931 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-24725) Update Cython to the latest version

2021-11-02 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24725. --- Fix Version/s: 1.15.0 Assignee: Martijn Visser Resolution: Fixed Merged to master via 397044

[GitHub] [flink] dianfu closed pull request #17644: [FLINK-24725] Update Cython to the latest version

2021-11-02 Thread GitBox
dianfu closed pull request #17644: URL: https://github.com/apache/flink/pull/17644 -- 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-unsubscr

[GitHub] [flink] JingsongLi commented on a change in pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-02 Thread GitBox
JingsongLi commented on a change in pull request #17605: URL: https://github.com/apache/flink/pull/17605#discussion_r741566910 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java ## @@ -75,6 +77,1

[jira] [Updated] (FLINK-24730) Support prompt in SqlCli

2021-11-02 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-24730: - Description: prompt is a very popular function in cli of traditional database like mysql, help users to

[GitHub] [flink] flinkbot edited a comment on pull request #17646: [FLINK-24740] Update testcontainers dependency to the latest version

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700 ## CI report: * 1772423646c8d93b4cb288e1b32233c87eabf80e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 7be470868e14bdfc6c424041cfb0edddf8f5b124 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19053) Flink Kafka Connector Dependency Error

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19053: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritize

[jira] [Updated] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19065: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-19059) Support to consume retractions for OVER WINDOW operator

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19059: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-19113) Add support for checkpointing with selectable inputs

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19113: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

  1   2   3   4   5   6   7   8   >