[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 78c60988637f6aa36c46e6df6af8f09724676d18 Azure:

[GitHub] [flink] flinkbot commented on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] flinkbot commented on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-01 Thread GitBox
flinkbot commented on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 78c60988637f6aa36c46e6df6af8f09724676d18 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * d3fc88995b30a57e2572047cfccae3ab61bfc9e5 Azure:

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-11-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24708: --- Labels: pull-request-available (was: ) > `ConvertToNotInOrInRule` has a bug which leads to

[GitHub] [flink] flinkbot edited a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * d3fc88995b30a57e2572047cfccae3ab61bfc9e5 Azure:

[GitHub] [flink] fsk119 opened a new pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-01 Thread GitBox
fsk119 opened a new pull request #17637: URL: https://github.com/apache/flink/pull/17637 ## What is the purpose of the change *Fix the wrong results of the IN opreator. The reason behind is it uses the type of the first element in the SEARCH argument as the type of the other

[GitHub] [flink] meetjunsu commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-11-01 Thread GitBox
meetjunsu commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-957121466 @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

[jira] [Commented] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-01 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437138#comment-17437138 ] JasonLee commented on FLINK-24490: -- Who can assign this to me thanks > The sample code is wrong in

[GitHub] [flink] liming30 commented on pull request #17179: [FLINK-24086][checkpoint] Rebuilding the SharedStateRegistry only when the restore method is called for the first time.

2021-11-01 Thread GitBox
liming30 commented on pull request #17179: URL: https://github.com/apache/flink/pull/17179#issuecomment-957115416 Hi, @dawidwys, I checked the registration of the shared state again. Maybe the shared state in `CompletedCheckpointStore` only needs to be re-registered in the

[GitHub] [flink] flinkbot edited a comment on pull request #17630: [hotfix][javadocs] Improve JavaDocs of SupportsAggregatePushDown

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17630: URL: https://github.com/apache/flink/pull/17630#issuecomment-956266960 ## CI report: * 16aa045cebb267749fdf426fe31fa8e07cccaa24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17630: [hotfix][javadocs] Improve JavaDocs of SupportsAggregatePushDown

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17630: URL: https://github.com/apache/flink/pull/17630#issuecomment-956266960 ## CI report: * 16aa045cebb267749fdf426fe31fa8e07cccaa24 Azure:

[GitHub] [flink] iyupeng commented on pull request #17630: [hotfix][javadocs] Improve JavaDocs of SupportsAggregatePushDown

2021-11-01 Thread GitBox
iyupeng commented on pull request #17630: URL: https://github.com/apache/flink/pull/17630#issuecomment-957109574 @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 #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] xuyangzhong commented on a change in pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-01 Thread GitBox
xuyangzhong commented on a change in pull request #17632: URL: https://github.com/apache/flink/pull/17632#discussion_r740708151 ## File path:

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

2021-11-01 Thread GitBox
tsreaper commented on a change in pull request #17571: URL: https://github.com/apache/flink/pull/17571#discussion_r740698131 ## File path:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * a76716059642a21592769cb39242be82d01091a5 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * a76716059642a21592769cb39242be82d01091a5 Azure:

[jira] [Commented] (FLINK-24716) Non-equality predicates on partition columns lead to incorrect plans

2021-11-01 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437103#comment-17437103 ] Wenlong Lyu commented on FLINK-24716: - the filter is pruned, not lost. I am also +1 for not keeping

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * a76716059642a21592769cb39242be82d01091a5 Azure:

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

2021-11-01 Thread GitBox
mayuehappy commented on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-957040774 @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

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

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437101#comment-17437101 ] Kurt Young commented on FLINK-24717: assigned to you [~xuyangzhong] > Push down partitions before

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

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-24717: -- Assignee: xuyang > Push down partitions before filters > ---

[jira] [Commented] (FLINK-24716) Non-equality predicates on partition columns lead to incorrect plans

2021-11-01 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437098#comment-17437098 ] xuyang commented on FLINK-24716: The plan seems correct, because the condition "d > '2012'" has been

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

2021-11-01 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437100#comment-17437100 ] xuyang commented on FLINK-24717: I'll try to fix it. > Push down partitions before filters >

[GitHub] [flink] meetjunsu commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-11-01 Thread GitBox
meetjunsu commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-957024848 @JingsongLi Would you like to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] meetjunsu removed a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-11-01 Thread GitBox
meetjunsu removed a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-956078481 @snuyanzin Could this PR be merged? The cornor test case I will add in another PR about reads composite types, because the code has dependencies,I will submit it

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

2021-11-01 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24717: --- Fix Version/s: 1.15.0 > Push down partitions before filters > --- >

[GitHub] [flink] flinkbot edited a comment on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-956476981 ## CI report: * e792679a9f83c8345bece7b15335ea680e844e51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17636: URL: https://github.com/apache/flink/pull/17636#issuecomment-956577935 ## CI report: * 0c66cb42528e83edb648029d8621fdc4a8056bb2 Azure:

[GitHub] [flink-web] sjwiesman commented on a change in pull request #478: add Flink Backward blog post

2021-11-01 Thread GitBox
sjwiesman commented on a change in pull request #478: URL: https://github.com/apache/flink-web/pull/478#discussion_r740504278 ## File path: _posts/2021-11-03-flink-backward.md ## @@ -0,0 +1,79 @@ +--- +layout: post +title: "Flink Backward - The Apache Flink Retrospective"

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * eca4a31f046721a1b1f98e338ad87393b6894a3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * bbb03788c8414baff5c1ffc4ff214a0d129b6bfb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17625: [FLINK-24719] Update Postgres test dependencies

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17625: URL: https://github.com/apache/flink/pull/17625#issuecomment-956206829 ## CI report: * 51de922c8dee15451a8360971786dcf2be011615 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 2dab3fdc8a18eebd2fca0b69f71d8834bde99738 Azure:

[jira] [Updated] (FLINK-19538) Support more complex routers in remote ingress definitions

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

[jira] [Updated] (FLINK-19744) Support Nebula Graph Connector

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

[jira] [Updated] (FLINK-19709) Support KeyedSortedMapState in DataStream API

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

[jira] [Updated] (FLINK-19634) Official Flink visualizer display bug

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

[jira] [Updated] (FLINK-19668) Fix the plan regression by Calcite upgrade to 1.26

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

[jira] [Updated] (FLINK-19595) Flink SQL support S3 select

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

[jira] [Updated] (FLINK-19761) Add lookup method for registered ShuffleDescriptor in ShuffleMaster

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

[jira] [Updated] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

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

[jira] [Updated] (FLINK-19798) Support creating hive table input splits in parallel

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

[jira] [Updated] (FLINK-19752) Convert BigDicimal TypeInformation to DataTypes error

2021-11-01 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19752: --- Labels: auto-deprioritized-major stale-minor table-type (was: auto-deprioritized-major

[jira] [Updated] (FLINK-19704) Flink checkpoint will fail when keytab dir meets a failure, and flink should handle it.

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

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

2021-11-01 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-24725: -- Summary: Update Cython to the latest version Key: FLINK-24725 URL: https://issues.apache.org/jira/browse/FLINK-24725 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-956476981 ## CI report: * e792679a9f83c8345bece7b15335ea680e844e51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-956476981 ## CI report: * e792679a9f83c8345bece7b15335ea680e844e51 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-01 Thread GitBox
MartijnVisser commented on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-956752220 @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

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 99dac03879947eb2a9e3774c0c6170f9389e5185 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17541: URL: https://github.com/apache/flink/pull/17541#issuecomment-948765818 ## CI report: * 9b84d08ded8b9bb26c497dd0b541a4c2c01bde4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17634: URL: https://github.com/apache/flink/pull/17634#issuecomment-956440201 ## CI report: * a623e14de144e5b5770a12f463caccb9e87bcf56 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 7c54778b3e19052e73a1e500a3a104e6ddff204f Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-956476981 ## CI report: * e792679a9f83c8345bece7b15335ea680e844e51 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17633: [FLINK-24723][archetype] Add ServicesResourceTransformer transformer

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17633: URL: https://github.com/apache/flink/pull/17633#issuecomment-956406134 ## CI report: * cc6f43d6c683e0d99ec29b21edae36ce40ae5f01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * a76716059642a21592769cb39242be82d01091a5 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17634: URL: https://github.com/apache/flink/pull/17634#issuecomment-956440201 ## CI report: * 69663b65a544da7820ce11a23e9f9b4a55b5e43d Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * dc0c76c162a28c4a93584b68fbc2a5c5576219a7 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17541: URL: https://github.com/apache/flink/pull/17541#issuecomment-948765818 ## CI report: * bc2203eaab919b4df93f2efd951e757c847a6c72 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17636: URL: https://github.com/apache/flink/pull/17636#issuecomment-956577935 ## CI report: * 0c66cb42528e83edb648029d8621fdc4a8056bb2 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] flinkbot commented on pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

2021-11-01 Thread GitBox
flinkbot commented on pull request #17636: URL: https://github.com/apache/flink/pull/17636#issuecomment-956577935 ## CI report: * 0c66cb42528e83edb648029d8621fdc4a8056bb2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

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

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-01 Thread GitBox
CrynetLogistics commented on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-956575496 @dannycranmer @fapaul I have implemented all of your kind suggestions to the best of my ability. Please re-review and let me know of any further thoughts. -- This is

[GitHub] [flink] snuyanzin opened a new pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

2021-11-01 Thread GitBox
snuyanzin opened a new pull request #17636: URL: https://github.com/apache/flink/pull/17636 ## What is the purpose of the change Typos cluser => cluster -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink-web] sjwiesman commented on a change in pull request #478: add Flink Backward blog post

2021-11-01 Thread GitBox
sjwiesman commented on a change in pull request #478: URL: https://github.com/apache/flink-web/pull/478#discussion_r740498181 ## File path: _posts/2021-11-03-flink-backward.md ## @@ -0,0 +1,79 @@ +--- +layout: post +title: "Flink Backward - The Apache Flink Retrospective"

[GitHub] [flink-web] sjwiesman commented on a change in pull request #478: add Flink Backward blog post

2021-11-01 Thread GitBox
sjwiesman commented on a change in pull request #478: URL: https://github.com/apache/flink-web/pull/478#discussion_r740504278 ## File path: _posts/2021-11-03-flink-backward.md ## @@ -0,0 +1,79 @@ +--- +layout: post +title: "Flink Backward - The Apache Flink Retrospective"

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 892d5c43086c3e97fa4707ab12d514f7d250ab01 Azure:

[GitHub] [flink-web] sjwiesman commented on a change in pull request #478: add Flink Backward blog post

2021-11-01 Thread GitBox
sjwiesman commented on a change in pull request #478: URL: https://github.com/apache/flink-web/pull/478#discussion_r740478608 ## File path: _posts/2021-11-03-flink-backward.md ## @@ -0,0 +1,79 @@ +--- +layout: post +title: "Flink Backward - The Apache Flink Retrospective"

[GitHub] [flink] flinkbot edited a comment on pull request #17633: [FLINK-24723][archetype] Add ServicesResourceTransformer transformer

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17633: URL: https://github.com/apache/flink/pull/17633#issuecomment-956406134 ## CI report: * aeba134bf55aa2db8386226242a5fadf459f Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 2390f627a2cd670044345dd8c47818f5993df98a Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 2390f627a2cd670044345dd8c47818f5993df98a Azure:

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

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 2390f627a2cd670044345dd8c47818f5993df98a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17580: [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment

2021-11-01 Thread GitBox
AHeise commented on a change in pull request #17580: URL: https://github.com/apache/flink/pull/17580#discussion_r740481614 ## File path: flink-clients/src/test/java/org/apache/flink/client/ExecutionEnvironmentTest.java ## @@ -91,9 +106,42 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17580: [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment

2021-11-01 Thread GitBox
AHeise commented on a change in pull request #17580: URL: https://github.com/apache/flink/pull/17580#discussion_r740481145 ## File path: flink-clients/src/test/java/org/apache/flink/client/ExecutionEnvironmentTest.java ## @@ -91,9 +106,42 @@ public void

[GitHub] [flink] AHeise commented on a change in pull request #17580: [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment

2021-11-01 Thread GitBox
AHeise commented on a change in pull request #17580: URL: https://github.com/apache/flink/pull/17580#discussion_r740480590 ## File path: flink-clients/src/test/java/org/apache/flink/client/ExecutionEnvironmentTest.java ## @@ -26,13 +26,22 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r740259768 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,189 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17625: [FLINK-24719] Update Postgres test dependencies

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17625: URL: https://github.com/apache/flink/pull/17625#issuecomment-956206829 ## CI report: * 004d026336a566ce0d8a019c124b4dd77590b6d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-01 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

  1   2   3   4   5   6   >