[jira] [Commented] (FLINK-20747) ClassCastException when using MAX aggregate function

2021-01-29 Thread charlieme (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275506#comment-17275506 ] charlieme commented on FLINK-20747: --- What's the problem with Flink after it's taken ov

[GitHub] [flink] flinkbot edited a comment on pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

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

[GitHub] [flink] flinkbot commented on pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

2021-01-29 Thread GitBox
flinkbot commented on pull request #14816: URL: https://github.com/apache/flink/pull/14816#issuecomment-770164177 ## CI report: * daece76bc00e4dd9aab27b59c16fd67d57cc24d6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-21202) Introduce TimeWindow and CountWindow in PyFlink

2021-01-29 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275488#comment-17275488 ] Huang Xingbo commented on FLINK-21202: -- Hi [~wangpeibin] Why do you change the desc

[GitHub] [flink] flinkbot commented on pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

2021-01-29 Thread GitBox
flinkbot commented on pull request #14816: URL: https://github.com/apache/flink/pull/14816#issuecomment-770162262 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-21202) Introduce TimeWindow and CountWindow in PyFlink

2021-01-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21202: --- Labels: pull-request-available (was: ) > Introduce TimeWindow and CountWindow in PyFlink >

[GitHub] [flink] HuangXingBo opened a new pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

2021-01-29 Thread GitBox
HuangXingBo opened a new pull request #14816: URL: https://github.com/apache/flink/pull/14816 ## What is the purpose of the change *This pull request will Introduce TimeWindow, CountWindow and corresponding coders.* ## Brief change log - *Add `TimeWindow` and `Cou

[GitHub] [flink] flinkbot edited a comment on pull request #14813: [FLINK-21207] Fix 'csv.disable-quote-character' can not take effect during deserial…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14813: [FLINK-21207] Fix 'csv.disable-quote-character' can not take effect during deserial…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14813: [FLINK-21207] Fix 'csv.disable-quote-character' can not take effect during deserial…

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

[GitHub] [flink] sharkdtu commented on pull request #14813: [FLINK-21207] Fix 'csv.disable-quote-character' can not take effect during deserial…

2021-01-29 Thread GitBox
sharkdtu commented on pull request #14813: URL: https://github.com/apache/flink/pull/14813#issuecomment-770156048 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Created] (FLINK-21212) Can no longer cast INT to DATE

2021-01-29 Thread Rex Remind (Jira)
Rex Remind created FLINK-21212: -- Summary: Can no longer cast INT to DATE Key: FLINK-21212 URL: https://issues.apache.org/jira/browse/FLINK-21212 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #14724: [FLINK-19360] Fink startup fails when $JAVA_HOME have space

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14724: URL: https://github.com/apache/flink/pull/14724#issuecomment-765052737 ## CI report: * 6004f698719a1c91fc64a8a97663a361fb7d0dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14724: [FLINK-19360] Fink startup fails when $JAVA_HOME have space

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14724: URL: https://github.com/apache/flink/pull/14724#issuecomment-765052737 ## CI report: * 6004f698719a1c91fc64a8a97663a361fb7d0dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-01-29 Thread sharkd tu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sharkd tu updated FLINK-21207: -- Fix Version/s: 1.13.0 1.12.2 > 'csv.disable-quote-character' can not take effect d

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-01-29 Thread sharkd tu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sharkd tu updated FLINK-21207: -- Description: source table with 'csv.disable-quote-character' = 'true' can not take effect.   Caused

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-20654][FLINK-21104][network] Fix couple bugs in the handling of unaligned checkpoints and cancellations.

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

[jira] [Closed] (FLINK-20991) Create 1.12.1 official image

2021-01-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20991. Resolution: Done Fixed in https://github.com/docker-library/official-images/pull/9526 > Create 1.

[jira] [Updated] (FLINK-17061) Unset process/flink memory size from configuration once dynamic worker resource is activated.

2021-01-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17061: - Parent: FLINK-14187 Issue Type: Sub-task (was: Task) > Unset process/flink memory size

[jira] [Commented] (FLINK-17061) Unset process/flink memory size from configuration once dynamic worker resource is activated.

2021-01-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275439#comment-17275439 ] Xintong Song commented on FLINK-17061: -- Thanks for the notice. I think this should

[GitHub] [flink] flinkbot edited a comment on pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14814: URL: https://github.com/apache/flink/pull/14814#issuecomment-769949284 ## CI report: * 53237d304da31ce8b2bdba5103192007122f23c7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14810: [FLINK-9844][client] PackagedProgram#close() closes ClassLoader

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14810: URL: https://github.com/apache/flink/pull/14810#issuecomment-769830895 ## CI report: * 0dee1f6c07a80da9abc5690b2a87442dc1725fd9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-16520) Move Kafka client properties resolution in KafkaSinkProvider to KafkaEgressBuilder

2021-01-29 Thread Rui Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275407#comment-17275407 ] Rui Wang commented on FLINK-16520: -- [~tzulitai] I am looking for some ramp-up tasks fo

[jira] [Updated] (FLINK-21211) Looking for reviews on a framework based on flink-statefun

2021-01-29 Thread Zixuan Rao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zixuan Rao updated FLINK-21211: --- Description: Hi, I am currently developing a framework targeting back end state management. To ensu

[jira] [Created] (FLINK-21211) Looking for reviews on a framework based on flink-statefun

2021-01-29 Thread Zixuan Rao (Jira)
Zixuan Rao created FLINK-21211: -- Summary: Looking for reviews on a framework based on flink-statefun Key: FLINK-21211 URL: https://issues.apache.org/jira/browse/FLINK-21211 Project: Flink Issu

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-20654][FLINK-21104][network] Fix couple bugs in the handling of unaligned checkpoints and cancellations.

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 181d2e3246c40cb0344726d4e4eb3d4f1dd80353 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-20654][FLINK-21104][network] Fix couple bugs in the handling of unaligned checkpoints and cancellations.

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 181d2e3246c40cb0344726d4e4eb3d4f1dd80353 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[GitHub] [flink] flinkbot edited a comment on pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-20654][FLINK-21104][network] Fix couple bugs in the handling of unaligned checkpoints and cancellations.

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 6410a58539ad960900653721fff977c2566f4d8f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[GitHub] [flink] AHeise closed pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
AHeise closed pull request #14807: URL: https://github.com/apache/flink/pull/14807 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 t

[GitHub] [flink] AHeise commented on pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
AHeise commented on pull request #14807: URL: https://github.com/apache/flink/pull/14807#issuecomment-770020842 Incorporated into #14797 . This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] flinkbot edited a comment on pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 6410a58539ad960900653721fff977c2566f4d8f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[GitHub] [flink] AHeise commented on a change in pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
AHeise commented on a change in pull request #14797: URL: https://github.com/apache/flink/pull/14797#discussion_r567060705 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java ## @@ -282,20 +281,39 @@ public void addSplit

[jira] [Comment Edited] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-29 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271508#comment-17271508 ] Jane Chan edited comment on FLINK-21045 at 1/29/21, 7:44 PM: -

[jira] [Comment Edited] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-29 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271508#comment-17271508 ] Jane Chan edited comment on FLINK-21045 at 1/29/21, 7:41 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #14812: [hotfix][javadoc] fix grammar error for PlannerContext.java: from "be overwrite" to "be overwritten"

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14812: URL: https://github.com/apache/flink/pull/14812#issuecomment-769855928 ## CI report: * 878183c7ec59129e62b269e1958e1945f3ddb9aa Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14807: URL: https://github.com/apache/flink/pull/14807#issuecomment-769784165 ## CI report: * fb5b2ecf70c62048073ba8677fe27baa02a63e7c UNKNOWN * f5901e6ca1e67fd29980bac95986ff5640a8976c UNKNOWN * 3a9e5890fe04ff480f5623bd752ed363a573

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 6410a58539ad960900653721fff977c2566f4d8f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14810: [FLINK-9844][client] PackagedProgram#close() closes ClassLoader

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-29 Thread GitBox
rkhachatryan commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r567014439 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,306 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #14815: [WIP] [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #14810: [FLINK-9844][client] PackagedProgram#close() closes ClassLoader

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

[GitHub] [flink] flinkbot edited a comment on pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14807: URL: https://github.com/apache/flink/pull/14807#issuecomment-769784165 ## CI report: * fb5b2ecf70c62048073ba8677fe27baa02a63e7c UNKNOWN * f5901e6ca1e67fd29980bac95986ff5640a8976c UNKNOWN * 3a9e5890fe04ff480f5623bd752ed363a573

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

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

[jira] [Updated] (FLINK-21210) ApplicationClusterEntryPoints should explicitly close PackagedProgram

2021-01-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-21210: - Labels: starter (was: ) > ApplicationClusterEntryPoints should explicitly close Package

[jira] [Created] (FLINK-21210) ApplicationClusterEntryPoints should explicitly close PackagedProgram

2021-01-29 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21210: Summary: ApplicationClusterEntryPoints should explicitly close PackagedProgram Key: FLINK-21210 URL: https://issues.apache.org/jira/browse/FLINK-21210 Project

[GitHub] [flink] rkhachatryan commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-29 Thread GitBox
rkhachatryan commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r566996438 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,306 @@ +/* + * Licensed to

[jira] [Created] (FLINK-21209) Update stackbrew maintainer field

2021-01-29 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21209: Summary: Update stackbrew maintainer field Key: FLINK-21209 URL: https://issues.apache.org/jira/browse/FLINK-21209 Project: Flink Issue Type: Improve

[GitHub] [flink-docker] zentol commented on a change in pull request #63: Adjust dev-1.12 branch for building 1.12.0

2021-01-29 Thread GitBox
zentol commented on a change in pull request #63: URL: https://github.com/apache/flink-docker/pull/63#discussion_r567015505 ## File path: add-version.sh ## @@ -112,9 +112,9 @@ for source_variant in "${SOURCE_VARIANTS[@]}"; do flink_url_file_path=flink/flink-${fl

[jira] [Commented] (FLINK-21164) Jar handlers don't cleanup temporarily extracted jars

2021-01-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275242#comment-17275242 ] Chesnay Schepler commented on FLINK-21164: -- master: 30f6964a9b72c79925c62f952a4

[GitHub] [flink] flinkbot edited a comment on pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #14808: [FLINK-21204][coordination] Remove LogicalSlot#getSlotSharingGroupId

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14808: URL: https://github.com/apache/flink/pull/14808#issuecomment-769820261 ## CI report: * 232c04267560ca5716a027237ba5f803a036f1cc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zentol merged pull request #14777: [FLINK-21164][rest] Delete temporary jars

2021-01-29 Thread GitBox
zentol merged pull request #14777: URL: https://github.com/apache/flink/pull/14777 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 3885663038156d52aec21062a9743009fb875cc3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-01-29 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275234#comment-17275234 ] Kezhu Wang commented on FLINK-21132: [~aljoscha] [~pnowojski]  [~roman_khachatryan] 

[GitHub] [flink] flinkbot edited a comment on pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #14815: [WIP] [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14815: URL: https://github.com/apache/flink/pull/14815#issuecomment-769949393 ## CI report: * 5edf84e272426dcaae4e9d114d5ce9ea5d766346 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14777: [FLINK-21164][rest] Delete temporary jars

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14777: URL: https://github.com/apache/flink/pull/14777#issuecomment-768256830 ## CI report: * ce3c983720499212e587319cd6fdef3ccc6b97b5 UNKNOWN * c833d995b48a47ca6a8af7ae7c5eae5fd9d2c7ba Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-21208) pyarrow exception when using window with pandas udaf

2021-01-29 Thread YufeiLiu (Jira)
YufeiLiu created FLINK-21208: Summary: pyarrow exception when using window with pandas udaf Key: FLINK-21208 URL: https://issues.apache.org/jira/browse/FLINK-21208 Project: Flink Issue Type: Impr

[GitHub] [flink] flinkbot commented on pull request #14815: [WIP] [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
flinkbot commented on pull request #14815: URL: https://github.com/apache/flink/pull/14815#issuecomment-769949393 ## CI report: * 5edf84e272426dcaae4e9d114d5ce9ea5d766346 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
flinkbot commented on pull request #14814: URL: https://github.com/apache/flink/pull/14814#issuecomment-769949284 ## CI report: * cad0310547eafdfd2eee8dddb14813ce940d3abd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14807: URL: https://github.com/apache/flink/pull/14807#issuecomment-769784165 ## CI report: * fb5b2ecf70c62048073ba8677fe27baa02a63e7c UNKNOWN * f5901e6ca1e67fd29980bac95986ff5640a8976c UNKNOWN * 3a9e5890fe04ff480f5623bd752ed363a573

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-29 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275216#comment-17275216 ] Jane Chan commented on FLINK-21045: --- Hi everyone, thanks for the discussion and the op

[GitHub] [flink] tillrohrmann commented on a change in pull request #14777: [FLINK-21164][rest] Delete temporary jars

2021-01-29 Thread GitBox
tillrohrmann commented on a change in pull request #14777: URL: https://github.com/apache/flink/pull/14777#discussion_r566981325 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java ## @@ -103,6 +103,11 @@ public JarRunH

[GitHub] [flink] flinkbot commented on pull request #14815: [WIP] [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
flinkbot commented on pull request #14815: URL: https://github.com/apache/flink/pull/14815#issuecomment-769942605 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 #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
flinkbot commented on pull request #14814: URL: https://github.com/apache/flink/pull/14814#issuecomment-769941674 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] rkhachatryan opened a new pull request #14815: [WIP] [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
rkhachatryan opened a new pull request #14815: URL: https://github.com/apache/flink/pull/14815 ## What is the purpose of the change ``` EndOfInput was used to handle any stopping of the job. When stopping with savepoint the input is not actually ended. This causes issues with

[jira] [Updated] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-01-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21132: --- Labels: pull-request-available (was: ) > BoundedOneInput.endInput is called when taking syn

[GitHub] [flink] rkhachatryan opened a new pull request #14814: [WIP] (1.11) [FLINK-21132][runtime] Don't end input on stop with savepoint

2021-01-29 Thread GitBox
rkhachatryan opened a new pull request #14814: URL: https://github.com/apache/flink/pull/14814 ## What is the purpose of the change (1.11 backport) ``` EndOfInput was used to handle any stopping of the job. When stopping with savepoint the input is not actually ended.

[GitHub] [flink] pnowojski commented on a change in pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
pnowojski commented on a change in pull request #14797: URL: https://github.com/apache/flink/pull/14797#discussion_r566976700 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java ## @@ -221,15 +228,17 @@ public InputStatu

[GitHub] [flink] tillrohrmann commented on a change in pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-01-29 Thread GitBox
tillrohrmann commented on a change in pull request #14798: URL: https://github.com/apache/flink/pull/14798#discussion_r566976287 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -164,6 +168,8 @@ private final Map coordi

[GitHub] [flink] tillrohrmann commented on a change in pull request #14798: [FLINK-21187] Provide exception history for root causes

2021-01-29 Thread GitBox
tillrohrmann commented on a change in pull request #14798: URL: https://github.com/apache/flink/pull/14798#discussion_r566868391 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionVertex.java ## @@ -64,9 +64,10 @@ * Returns t

[GitHub] [flink] pnowojski commented on a change in pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
pnowojski commented on a change in pull request #14807: URL: https://github.com/apache/flink/pull/14807#discussion_r566975267 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/ChannelStatePersister.java ## @@ -67,16 +68,27 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 6410a58539ad960900653721fff977c2566f4d8f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * 3cdc18cdbe7166b7993c98787dc1ec2f27fad896 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] AHeise commented on a change in pull request #14807: [FLINK-20654][FLINK-21104][network] Fix two bugs in the handling of UnalignedCheckpoints

2021-01-29 Thread GitBox
AHeise commented on a change in pull request #14807: URL: https://github.com/apache/flink/pull/14807#discussion_r566953027 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/ChannelStatePersisterTest.java ## @@ -65,38 +83,58 @@ pub

[GitHub] [flink] flinkbot edited a comment on pull request #14806: [FLINK-10520][rest] Properly handle optional savepoint parameters

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14806: URL: https://github.com/apache/flink/pull/14806#issuecomment-769773030 ## CI report: * 80df70fdb86585fef239e1e323abdf2848f34d64 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 94ea4acd0878f020530fb04fa38502a4087f2f19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * 6179b4646f99bc39047ddc3820a14df8f41f1489 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #195: [FLINK-21171] Wire in TypedValue throughout the runtime as state values and message payloads

2021-01-29 Thread GitBox
igalshilman commented on a change in pull request #195: URL: https://github.com/apache/flink-statefun/pull/195#discussion_r566851179 ## File path: statefun-flink/statefun-flink-common/pom.xml ## @@ -84,10 +88,63 @@ under the License. +

[GitHub] [flink] flinkbot edited a comment on pull request #14797: [FLINK-21104][network] Various fixes for UC

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14797: URL: https://github.com/apache/flink/pull/14797#issuecomment-769223743 ## CI report: * 94ea4acd0878f020530fb04fa38502a4087f2f19 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14734: URL: https://github.com/apache/flink/pull/14734#issuecomment-766092219 ## CI report: * 0c94f50f2a8e9a5753479fce0cb18e02a1931c16 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239 ## CI report: * 35947579b06f3b4d67e151e2fc38565813076008 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-29 Thread Xiaoguang Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274547#comment-17274547 ] Xiaoguang Sun commented on FLINK-21108: --- Of cause all authentication methods work

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-01-29 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274538#comment-17274538 ] Roman Khachatryan commented on FLINK-21132: --- Thanks for your feedback [~aljosc

[GitHub] [flink] flinkbot edited a comment on pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14734: URL: https://github.com/apache/flink/pull/14734#issuecomment-766092219 ## CI report: * 0c94f50f2a8e9a5753479fce0cb18e02a1931c16 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-29 Thread GitBox
flinkbot edited a comment on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239 ## CI report: * 35947579b06f3b4d67e151e2fc38565813076008 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-29 Thread GitBox
gaoyunhaii commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r566910553 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java ## @@ -183,23 +166,27 @@ public CheckpointSt

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-29 Thread GitBox
gaoyunhaii commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r566909909 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -730,7 +715,8 @@ private PendingCheckpo

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-29 Thread GitBox
gaoyunhaii commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r566909909 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -730,7 +715,8 @@ private PendingCheckpo

[GitHub] [flink] flinkbot edited a comment on pull request #14813: [FLINK-21207] Fix 'csv.disable-quote-character' can not take effect during deserial…

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

[GitHub] [flink] blublinsky commented on pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-29 Thread GitBox
blublinsky commented on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-769877297 @xintongsong , done This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-01-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274517#comment-17274517 ] Piotr Nowojski commented on FLINK-21132: I agree with {{endOfInput}} should NOT

[GitHub] [flink] flinkbot commented on pull request #14813: [FLINK-21207] Fix 'csv.disable-quote-character' can not take effect during deserial…

2021-01-29 Thread GitBox
flinkbot commented on pull request #14813: URL: https://github.com/apache/flink/pull/14813#issuecomment-769867480 ## CI report: * ab61d899b8b08c6c4707ba65f922c4a838bdbb6e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

  1   2   3   4   >