[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD)

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD)

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] Aitozi opened a new pull request #17846: [FLINK-24918][Runtime/State Backends]Support to specify the data dir …

2021-11-21 Thread GitBox
Aitozi opened a new pull request #17846: URL: https://github.com/apache/flink/pull/17846 …for state benchmark ## What is the purpose of the change Support to specify the data dir for state benchmark -- This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD)

[jira] [Updated] (FLINK-24918) Support to specify the data dir for state benchmark

2021-11-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24918: --- Labels: pull-request-available (was: ) > Support to specify the data dir for state benchmar

[GitHub] [flink-benchmarks] Aitozi opened a new pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

2021-11-21 Thread GitBox
Aitozi opened a new pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41 Rely on the Flink [PR](https://github.com/apache/flink/pull/17846) -- 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] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] flinkbot commented on pull request #17846: [FLINK-24918][Runtime/State Backends]Support to specify the data dir …

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

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD)

[GitHub] [flink] flinkbot edited a comment on pull request #17846: [FLINK-24918][Runtime/State Backends]Support to specify the data dir …

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

[GitHub] [flink-benchmarks] Aitozi commented on pull request #41: [FLINK-24918][Runtime/State Backends]Support to specify the data dir for state benchmark

2021-11-21 Thread GitBox
Aitozi commented on pull request #41: URL: https://github.com/apache/flink-benchmarks/pull/41#issuecomment-974774282 This build error due to it reply on the new api in [PR](https://github.com/apache/flink/pull/17846) -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[jira] [Commented] (FLINK-24918) Support to specify the data dir for state benchmark

2021-11-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446944#comment-17446944 ] Aitozi commented on FLINK-24918: I have create the two related pull request, please take

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD)

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD)

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * Unknown: [CANCELED](TBD) * 3814

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753769124 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753769187 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink-ml] lindong28 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753769359 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 38147f38be0a942edacc21b668aad7ea4e8f

[jira] [Created] (FLINK-24967) Make the IO pattern configureable in state benchmarks

2021-11-21 Thread Aitozi (Jira)
Aitozi created FLINK-24967: -- Summary: Make the IO pattern configureable in state benchmarks Key: FLINK-24967 URL: https://issues.apache.org/jira/browse/FLINK-24967 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-24967) Make the IO pattern configureable in state benchmarks

2021-11-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446952#comment-17446952 ] Aitozi commented on FLINK-24967: cc [~yunta] > Make the IO pattern configureable in sta

[jira] [Commented] (FLINK-24967) Make the IO pattern configureable in state benchmarks

2021-11-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446954#comment-17446954 ] Aitozi commented on FLINK-24967: I also notice some {{TODOs}} in {{StateBenchmarkConstan

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-21 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * f5ab7477f53088b7f6794e113fdb4be6248a

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

2021-11-21 Thread GitBox
zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r753775516 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] flinkbot edited a comment on pull request #17846: [FLINK-24918][Runtime/State Backends]Support to specify the data dir …

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

[jira] [Updated] (FLINK-14887) Provide a dedicated test class for SqlDateTimeUtils

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

[jira] [Updated] (FLINK-23342) State ownership: compute shared state on recovery

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23342: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-14950) Support getKey in WindowOperator.Context

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

[jira] [Updated] (FLINK-14882) Wrong null order when change flink default null order from NullCollation.LOW to NullCollation.FIRST

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

[jira] [Updated] (FLINK-14793) Add SPI interface to discovery state backend and establish well-known names

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

[jira] [Updated] (FLINK-14844) ConnectorCatalogTable should not patch the row type with TimeAttributes for batch mode

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

[jira] [Updated] (FLINK-14856) Allow setting "state.checkpoints.num-retained" for individual jobs

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

[jira] [Updated] (FLINK-14705) Remove nullables argument of BatchTestBase.registerCollection in blink planner

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

[jira] [Updated] (FLINK-14790) Custom state backend in job graph composition without depending on concrete state backend implementation

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

[jira] [Updated] (FLINK-14617) Dataset Parquet ClassCastException for SpecificRecord

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

[jira] [Updated] (FLINK-14757) scala.StreamExecutionEnvironment Doesn't set return type upon adding source

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

[jira] [Updated] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese)

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

[jira] [Updated] (FLINK-17437) Use StringData instead of BinaryStringData in code generation

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

[jira] [Updated] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

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

[jira] [Updated] (FLINK-16937) ParquetTableSource should generate correct isFilterPushedDown

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

[jira] [Updated] (FLINK-16780) improve Flink lookup join

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

[jira] [Updated] (FLINK-16751) Expose bind port for Flink metric query service

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

[jira] [Updated] (FLINK-16731) Support SHOW PARTITIONS table command in TableEnvironment and SQL Client

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

[jira] [Updated] (FLINK-17360) Support custom partitioners in JDBCReadOptions

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

[jira] [Updated] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes

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

[jira] [Updated] (FLINK-17532) Update tests to use BatchTestBase#checkTableResult

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

[jira] [Updated] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

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

[jira] [Updated] (FLINK-23551) Bump ORC to 1.6.10

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23551: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-24198) KafkaTableITCase fail with FlinkJobNotFoundException: Could not find Flink job

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24198: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

2021-11-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17378: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

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

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446998#comment-17446998 ] Yun Gao commented on FLINK-24935: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

2021-11-21 Thread Lai Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447000#comment-17447000 ] Lai Dai commented on FLINK-6573: [~monster#12] Hi, Could you tell when to open a pr for t

[jira] [Commented] (FLINK-24495) Python installdeps hangs

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446999#comment-17446999 ] Yun Gao commented on FLINK-24495: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447001#comment-17447001 ] Yun Gao commented on FLINK-24763: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Comment Edited] (FLINK-6573) Flink MongoDB Connector

2021-11-21 Thread Lai Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447000#comment-17447000 ] Lai Dai edited comment on FLINK-6573 at 11/21/21, 11:02 AM: [

[jira] [Created] (FLINK-24968) "Flink over NAT end-to-end test" failed on azure

2021-11-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-24968: --- Summary: "Flink over NAT end-to-end test" failed on azure Key: FLINK-24968 URL: https://issues.apache.org/jira/browse/FLINK-24968 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24968) "Flink over NAT end-to-end test" failed on azure

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447004#comment-17447004 ] Yun Gao commented on FLINK-24968: - It seems that the test first fail to download a packa

[jira] [Created] (FLINK-24969) pyflink/table/tests/test_pandas_udf.py hangs on azure

2021-11-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-24969: --- Summary: pyflink/table/tests/test_pandas_udf.py hangs on azure Key: FLINK-24969 URL: https://issues.apache.org/jira/browse/FLINK-24969 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-24969) pyflink/table/tests/test_pandas_udf.py hangs on azure

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24969: Description: {code:java} Nov 20 05:11:02 at java.net.SocketInputStream.socketRead(SocketInputStre

[jira] [Commented] (FLINK-24495) Python installdeps hangs

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447006#comment-17447006 ] Yun Gao commented on FLINK-24495: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447007#comment-17447007 ] Yun Gao commented on FLINK-24763: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Created] (FLINK-24970) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired after 60000 milliseconds while awaiting InitProducerId

2021-11-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-24970: --- Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired after 6 milliseconds while awaiting InitProducerId Key: FLINK-24970 URL: https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-24971) Streaming File Sink s3 end-to-end test stalled on azure

2021-11-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-24971: --- Summary: Streaming File Sink s3 end-to-end test stalled on azure Key: FLINK-24971 URL: https://issues.apache.org/jira/browse/FLINK-24971 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24971) Streaming File Sink s3 end-to-end test stalled on azure

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447008#comment-17447008 ] Yun Gao commented on FLINK-24971: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447009#comment-17447009 ] Yun Gao commented on FLINK-24935: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447010#comment-17447010 ] Yun Gao commented on FLINK-20498: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447011#comment-17447011 ] Yun Gao commented on FLINK-20498: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447013#comment-17447013 ] Yun Gao commented on FLINK-22194: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Updated] (FLINK-24840) JobManagerHAProcessFailureRecoveryITCase crashed on AZP

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24840: Affects Version/s: 1.14.0 > JobManagerHAProcessFailureRecoveryITCase crashed on AZP >

[jira] [Commented] (FLINK-24840) JobManagerHAProcessFailureRecoveryITCase crashed on AZP

2021-11-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447015#comment-17447015 ] Yun Gao commented on FLINK-24840: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Created] (FLINK-24972) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout due to failed to complete checkpoint

2021-11-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-24972: --- Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout due to failed to complete checkpoint Key: FLINK-24972 URL: https://issues.apache.org/jira/browse/FLINK-24972

[GitHub] [flink] flinkbot edited a comment on pull request #17845: Add null check for temporal table check on SqlSnapshot

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

[jira] [Created] (FLINK-24973) flink registercachedfile example no effect

2021-11-21 Thread anigkus (Jira)
anigkus created FLINK-24973: --- Summary: flink registercachedfile example no effect Key: FLINK-24973 URL: https://issues.apache.org/jira/browse/FLINK-24973 Project: Flink Issue Type: Technical Debt

[jira] [Updated] (FLINK-24973) flink registercachedfile example no effect

2021-11-21 Thread anigkus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] anigkus updated FLINK-24973: Description: {code:java} /* * Licensed to the Apache Software Foundation (ASF) under one or more * contr

[jira] [Commented] (FLINK-24352) Lookup join + WITH clause throws NPE

2021-11-21 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447028#comment-17447028 ] Yuval Itzchakov commented on FLINK-24352: - [~TsReaper] It's ready: [https://gith

[GitHub] [flink] MonsterChenzhuo opened a new pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-21 Thread GitBox
MonsterChenzhuo opened a new pull request #17847: URL: https://github.com/apache/flink/pull/17847 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[jira] [Updated] (FLINK-6573) Flink MongoDB Connector

2021-11-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6573: -- Labels: pull-request-available stale-assigned (was: stale-assigned) > Flink MongoDB Connector

[GitHub] [flink] flinkbot commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

  1   2   3   4   >