[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

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

[GitHub] [flink] flinkbot commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

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

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

2021-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24490: --- Labels: pull-request-available (was: ) > The sample code is wrong in Apache Kafka Connector

[GitHub] [flink] JasonLeeCoding opened a new pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread GitBox
JasonLeeCoding opened a new pull request #17690: URL: https://github.com/apache/flink/pull/17690 ## What is the purpose of the change *Modify the error example in the Flink document* ## Brief change log *(for example:)* - *The TaskInfo is stored in the b

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

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

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

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-04 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743413889 ## File path: flink-ml-api/pom.xml ## @@ -38,6 +38,34 @@ under the License. ${flink.version} provided + + + org.apache.flink +

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-04 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743413672 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-04 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743413672 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-04 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743412694 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java ## @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-04 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743412553 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java ## @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-04 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r74341 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

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

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * Unknown: [CANCELED](TBD) * 8792e55dbc0639fdc32b5a1fe17ed391cda0e788 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

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

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * Unknown: [CANCELED](TBD) * 8792e55dbc0639fdc32b5a1fe17ed391cda0e788 UNKNOWN Bot commands The @flinkbot bot supports the fol

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

2021-11-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24490: --- Assignee: JasonLee > The sample code is wrong in Apache Kafka Connector page >

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

2021-11-04 Thread GitBox
xuyangzhong commented on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-961639325 @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

[jira] [Commented] (FLINK-24551) BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration

2021-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439040#comment-17439040 ] Yuan Mei commented on FLINK-24551: -- merged commit 3e341d0 into apache:release-1.14 [~a

[GitHub] [flink] curcur commented on pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

2021-11-04 Thread GitBox
curcur commented on pull request #17621: URL: https://github.com/apache/flink/pull/17621#issuecomment-961636576 @akalash , do you need to put this fix into master as well? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Commented] (FLINK-24533) Flink SQL Upsert To Hbase Appear data loss

2021-11-04 Thread licp (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439038#comment-17439038 ] licp commented on FLINK-24533: -- Thanks [~jark].I have made temporary modifications based on

[GitHub] [flink] curcur merged pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

2021-11-04 Thread GitBox
curcur merged pull request #17621: URL: https://github.com/apache/flink/pull/17621 -- 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] curcur commented on pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

2021-11-04 Thread GitBox
curcur commented on pull request #17621: URL: https://github.com/apache/flink/pull/17621#issuecomment-961636235 thanks @akalash for clarification! -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

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

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Lee Y S (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439030#comment-17439030 ] Lee Y S commented on FLINK-24767: - Hi [~sjwiesman], Because I set the random seed (0),

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

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

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

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

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

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439023#comment-17439023 ] JasonLee commented on FLINK-24490: --  [~jark]  Can you assign this to me ?  thanks > Th

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

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder KafkaSi

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

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder KafkaSi

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

2021-11-04 Thread GitBox
flinkbot commented on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619860 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 #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs or after running tow days

2021-11-04 Thread Leon Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439021#comment-17439021 ] Leon Xu commented on FLINK-21325: - Hi Is there any update on this ticket? I am experienc

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

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder KafkaSi

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

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

2021-11-04 Thread GitBox
lincoln-lil opened a new pull request #17689: URL: https://github.com/apache/flink/pull/17689 This pr cherry-pick FLINK-24704 from master to release-1.14 ## What is the purpose of the change Fix the exception when the input record loses monotonicity on the sort key field of Up

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

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder KafkaSi

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

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

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439017#comment-17439017 ] Zakelly Lan commented on FLINK-24046: - Moreover, we could remove this special value

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439015#comment-17439015 ] Zakelly Lan commented on FLINK-24046: - [~yunta] Good point. I think we could treat

[GitHub] [flink] cshuo commented on a change in pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

2021-11-04 Thread GitBox
cshuo commented on a change in pull request #17634: URL: https://github.com/apache/flink/pull/17634#discussion_r743368304 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/SumAggFunction.java ## @@ -66,7 +66,10 @@

[jira] [Comment Edited] (FLINK-24730) Support prompt style in SqlCli

2021-11-04 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439009#comment-17439009 ] Yubin Li edited comment on FLINK-24730 at 11/5/21, 3:27 AM:

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

2021-11-04 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439009#comment-17439009 ] Yubin Li commented on FLINK-24730: -- Hi, [~twalthr] After discussing with [~Sergey Nuya

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439002#comment-17439002 ] Yun Tang commented on FLINK-24046: -- [~Zakelly] Since {{DefaultConfigurableOptionsFactor

[GitHub] [flink] Myasuka commented on a change in pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

2021-11-04 Thread GitBox
Myasuka commented on a change in pull request #16582: URL: https://github.com/apache/flink/pull/16582#discussion_r743366210 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -339,78 +343,107 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

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

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

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

[GitHub] [flink] ruanhang1993 commented on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-11-04 Thread GitBox
ruanhang1993 commented on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-961592246 @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 spec

[jira] [Resolved] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24597. -- Resolution: Fixed Merged master: a907d92673a711612b287d184c00dad7fa42269f release-1.14: 547b3befcff50b

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

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

[jira] [Updated] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24597: - Fix Version/s: 1.13.4 1.14.1 1.15.0 > RocksdbStateBackend getKeysA

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

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

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

2021-11-04 Thread GitBox
Myasuka closed pull request #17525: URL: https://github.com/apache/flink/pull/17525 -- 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-unsubsc

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

2021-11-04 Thread GitBox
Zakelly commented on a change in pull request #17650: URL: https://github.com/apache/flink/pull/17650#discussion_r743359346 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java ## @@ -4376,7 +4373,7 @@ protected void testConcurrent

[jira] [Closed] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-18473. Resolution: Information Provided > Optimize RocksDB disk load balancing strategy > ---

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438997#comment-17438997 ] Yun Tang commented on FLINK-18473: -- [~fanrui] I think your proposed idea cannot resolve

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

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

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

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

[GitHub] [flink] beyond1920 commented on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-04 Thread GitBox
beyond1920 commented on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-961582912 @MartijnVisser @infoverload Thanks a lot for review. I updated pull request to address those typos. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] hililiwei commented on pull request #17648: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-11-04 Thread GitBox
hililiwei commented on pull request #17648: URL: https://github.com/apache/flink/pull/17648#issuecomment-961569348 > There are test failures for which I don't have an explanation. Could you please rebase on top of release-1.13 again? I'm suspecting someone broke the branch. @AHeise

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[jira] [Comment Edited] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438989#comment-17438989 ] Leonard Xu edited comment on FLINK-14527 at 11/5/21, 1:47 AM:

[jira] [Commented] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438989#comment-17438989 ] Leonard Xu commented on FLINK-14527: [~MartijnVisser] I think we need this, we did c

[GitHub] [flink] leonardBang commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-04 Thread GitBox
leonardBang commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-961556377 > @leonardBang Would you be able to help with a review? Yes, my pleasure -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

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

[GitHub] [flink-training] sjwiesman opened a new pull request #42: [FLINK-24782] Upgrade training exercises to 1.14

2021-11-04 Thread GitBox
sjwiesman opened a new pull request #42: URL: https://github.com/apache/flink-training/pull/42 Upgrades Flink to 1.14. After merging, we will create a release-1.14 branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-24782) Create 1.14 release branch for training repo

2021-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24782: --- Labels: pull-request-available (was: ) > Create 1.14 release branch for training repo > ---

[jira] [Updated] (FLINK-18255) Add API annotations to RocksDB user-facing classes

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

[jira] [Updated] (FLINK-18354) when use ParquetAvroWriters.forGenericRecord(Schema schema) error java.lang.ClassCastException: org.apache.flink.api.java.tuple.Tuple2 cannot be cast to org.apache.avro

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

[jira] [Updated] (FLINK-18245) Support to parse -1 for MemorySize and Duration ConfigOption

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

[jira] [Updated] (FLINK-18249) Cannot create index by time field?

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

[jira] [Updated] (FLINK-18210) The tmpdir will be clean up when stop historyserver

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

[jira] [Updated] (FLINK-18216) "Start time" column should not expand if a job is running

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

[jira] [Updated] (FLINK-18243) Flink SQL (1.10.0) From Kafkasource can not get data

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

[jira] [Updated] (FLINK-18167) Flink Job hangs there when one vertex is failed and another is cancelled.

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

[jira] [Updated] (FLINK-18379) Introduce asynchronous UDF/UDTF

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

[jira] [Updated] (FLINK-18180) unify the logic of time attribute derivation for both batch and streaming

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

[jira] [Updated] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

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

[jira] [Comment Edited] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438953#comment-17438953 ] Seth Wiesman edited comment on FLINK-24767 at 11/4/21, 10:19 PM: -

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

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

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

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

  1   2   3   4   5   6   7   8   >