[GitHub] [flink] rmetzger commented on a change in pull request #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-13 Thread GitBox
rmetzger commented on a change in pull request #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#discussion_r379291684 ## File path: tools/azure-pipelines/jobs-template.yml ## @@

[GitHub] [flink] flinkbot commented on issue #11089: [FLINK-16053][python] Remove redundant metrics in PyFlink

2020-02-13 Thread GitBox
flinkbot commented on issue #11089: [FLINK-16053][python] Remove redundant metrics in PyFlink URL: https://github.com/apache/flink/pull/11089#issuecomment-586139901 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-16053) Remove redundant metrics in PyFlink

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16053: --- Labels: pull-request-available (was: ) > Remove redundant metrics in PyFlink >

[GitHub] [flink] dianfu opened a new pull request #11089: [FLINK-16053][python] Remove redundant metrics in PyFlink

2020-02-13 Thread GitBox
dianfu opened a new pull request #11089: [FLINK-16053][python] Remove redundant metrics in PyFlink URL: https://github.com/apache/flink/pull/11089 ## What is the purpose of the change *We have recorded the metrics about how many elements it has processed in Python UDF. This kind of

[jira] [Created] (FLINK-16053) Remove redundant metrics in PyFlink

2020-02-13 Thread Dian Fu (Jira)
Dian Fu created FLINK-16053: --- Summary: Remove redundant metrics in PyFlink Key: FLINK-16053 URL: https://issues.apache.org/jira/browse/FLINK-16053 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-13 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036747#comment-17036747 ] Yu Li commented on FLINK-16052: --- cc [~karmagyz] [~xintongsong] > Homebrew test failed with 1.10.0 dist

[jira] [Commented] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-13 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036744#comment-17036744 ] Yu Li commented on FLINK-16052: --- Some background: This issue is found during the follow up of the 1.10.0

[jira] [Updated] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-13 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16052: -- Description: After updating the Homebrew formula to 1.10.0 (in {{$(brew --repository homebrew/core)}}

[jira] [Created] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-13 Thread Yu Li (Jira)
Yu Li created FLINK-16052: - Summary: Homebrew test failed with 1.10.0 dist package Key: FLINK-16052 URL: https://issues.apache.org/jira/browse/FLINK-16052 Project: Flink Issue Type: Bug

[GitHub] [flink] hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379278971 ## File path: flink-ml-parent/flink-ml-lib/pom.xml ## @@ -57,4 +57,30 @@ under the

[jira] [Commented] (FLINK-16047) Blink planner produces wrong aggregate results with state clean up

2020-02-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036729#comment-17036729 ] Jark Wu commented on FLINK-16047: - [~twalthr] you are right. We didn't spot this problem before. Let's

[jira] [Updated] (FLINK-16047) Blink planner produces wrong aggregate results with state clean up

2020-02-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16047: Fix Version/s: 1.10.1 1.9.3 > Blink planner produces wrong aggregate results with

[jira] [Commented] (FLINK-15707) Update state migration tests for Flink 1.10

2020-02-13 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036726#comment-17036726 ] vinoyang commented on FLINK-15707: -- [~aljoscha] and [~trohrmann] Since Flink 1.10 has been released

[GitHub] [flink] pnowojski merged pull request #11083: [hotfix][docs] Add note SSL not enabled by default

2020-02-13 Thread GitBox
pnowojski merged pull request #11083: [hotfix][docs] Add note SSL not enabled by default URL: https://github.com/apache/flink/pull/11083 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036715#comment-17036715 ] Yingjie Cao commented on FLINK-16012: - [~wind_ljy] I have updated the results and the previous

[jira] [Commented] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036714#comment-17036714 ] Yingjie Cao commented on FLINK-16012: - Theoretically, reducing the number of buffers may break the

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Attachment: (was: image-2020-02-14-09-13-07-967.png) > Reduce the default number of exclusive

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Attachment: (was: image-2020-02-14-07-23-16-171.png) > Reduce the default number of exclusive

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Attachment: (was: image-2020-02-13-21-54-05-026.png) > Reduce the default number of exclusive

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Attachment: (was: image-2020-02-13-23-30-17-951.png) > Reduce the default number of exclusive

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

2020-02-13 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036692#comment-17036692 ] Zhijiang commented on FLINK-16030: -- I agree with [~pnowojski]'s concern. I forgot the previous issue

[jira] [Updated] (FLINK-16051) Subtask id in Checkpoint UI not consistent with Subtask UI

2020-02-13 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-16051: --- Issue Type: Bug (was: Improvement) > Subtask id in Checkpoint UI not consistent with Subtask UI >

[jira] [Updated] (FLINK-16051) Subtask id in Checkpoint UI not consistent with Subtask UI

2020-02-13 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-16051: --- Summary: Subtask id in Checkpoint UI not consistent with Subtask UI (was: Subtask id in Checkpoint

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379242650 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379240935 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379234575 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379235239 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379227379 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r378822971 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379244169 ## File path:

[jira] [Updated] (FLINK-16051) Subtask id in Checkpoint UI not consistent with TaskUI

2020-02-13 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-16051: --- Summary: Subtask id in Checkpoint UI not consistent with TaskUI (was: subtask id in Checkpoint UI

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379241683 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379228490 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379228560 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379228461 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379230207 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379244079 ## File path:

[jira] [Created] (FLINK-16051) subtask id in Checkpoint UI not consistent with TaskUI

2020-02-13 Thread Jiayi Liao (Jira)
Jiayi Liao created FLINK-16051: -- Summary: subtask id in Checkpoint UI not consistent with TaskUI Key: FLINK-16051 URL: https://issues.apache.org/jira/browse/FLINK-16051 Project: Flink Issue

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r378836618 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379234158 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379235017 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379229634 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r378832786 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r378836753 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379235507 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r378830458 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r378823281 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379234497 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python

2020-02-13 Thread GitBox
hequn8128 commented on a change in pull request #11051: [FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction URL: https://github.com/apache/flink/pull/11051#discussion_r379243229 ## File path:

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

2020-02-13 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036679#comment-17036679 ] Zhijiang commented on FLINK-15981: -- > One option to try out would be to not use any memory at all, but

[jira] [Commented] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

2020-02-13 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036678#comment-17036678 ] Zhijiang commented on FLINK-15981: -- Thanks for the confirmation and in general we are on the same page.

[jira] [Updated] (FLINK-14138) Show Pending Slots in Job Detail

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14138: --- Component/s: Runtime / REST > Show Pending Slots in Job Detail > > >

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16048: --- Description: I found SQL Kafka connector can not consume avro data that was serialized by

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036670#comment-17036670 ] Leonard Xu commented on FLINK-16048: Compare to AvroRowSerializationSchema[1],

[jira] [Updated] (FLINK-14730) Add pending slots for job

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14730: --- Parent: FLINK-14138 Issue Type: Sub-task (was: Improvement) > Add pending slots for job >

[jira] [Updated] (FLINK-14730) Add pending slots for job

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14730: --- Component/s: (was: Runtime / Web Frontend) > Add pending slots for job > - > >

[jira] [Updated] (FLINK-13510) Show fail attempt for subtask in timelime

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13510: --- Component/s: (was: Runtime / Web Frontend) > Show fail attempt for subtask in timelime >

[jira] [Updated] (FLINK-13510) Show fail attempt for subtask in timelime In Rest API

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13510: --- Summary: Show fail attempt for subtask in timelime In Rest API (was: Show fail attempt for subtask in

[jira] [Updated] (FLINK-14137) Show Attempt History in Vertex SubTask In WebUI

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14137: --- Summary: Show Attempt History in Vertex SubTask In WebUI (was: Show Attempt History in Vertex SubTask) >

[jira] [Updated] (FLINK-14713) Show Attempt History in Vertex SubTask In Rest Api

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14713: --- Component/s: (was: Runtime / Web Frontend) > Show Attempt History in Vertex SubTask In Rest Api >

[jira] [Updated] (FLINK-14713) Show Attempt History in Vertex SubTask In Rest Api

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14713: --- Summary: Show Attempt History in Vertex SubTask In Rest Api (was: Show Attempt History in Vertex SubTask)

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-02-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036662#comment-17036662 ] Jingsong Lee commented on FLINK-16048: -- More accurate, should be confluent avro schema support.

[jira] [Updated] (FLINK-13510) Show fail attempt for subtask in timelime

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13510: --- Parent: FLINK-16050 Issue Type: Sub-task (was: Improvement) > Show fail attempt for subtask in

[jira] [Updated] (FLINK-14143) Failed Attempt does not display in the timeline

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14143: --- Parent: FLINK-16050 Issue Type: Sub-task (was: Improvement) > Failed Attempt does not display in

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

2020-02-13 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036661#comment-17036661 ] Yu Li commented on FLINK-10918: --- cc [~klion26] [~yunta] > incremental Keyed state with RocksDB throws

[jira] [Updated] (FLINK-14713) Show Attempt History in Vertex SubTask

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14713: --- Parent: FLINK-16050 Issue Type: Sub-task (was: Improvement) > Show Attempt History in Vertex

[jira] [Updated] (FLINK-14137) Show Attempt History in Vertex SubTask

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14137: --- Parent: (was: FLINK-14713) Issue Type: Task (was: Sub-task) > Show Attempt History in Vertex

[jira] [Updated] (FLINK-14137) Show Attempt History in Vertex SubTask

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14137: --- Parent: FLINK-16050 Issue Type: Sub-task (was: Task) > Show Attempt History in Vertex SubTask >

[jira] [Commented] (FLINK-15966) Capture the call stack of RPC ask() calls.

2020-02-13 Thread guoqiang.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036658#comment-17036658 ] guoqiang.zhang commented on FLINK-15966: look forward for it > Capture the call stack of RPC

[jira] [Comment Edited] (FLINK-16026) Travis failed due to python setup

2020-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656 ] Dian Fu edited comment on FLINK-16026 at 2/14/20 2:53 AM: -- [~chesnay] Thanks a

[jira] [Comment Edited] (FLINK-16026) Travis failed due to python setup

2020-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656 ] Dian Fu edited comment on FLINK-16026 at 2/14/20 2:52 AM: -- [~chesnay] Thanks a

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16048: --- Summary: Support read/write confluent schema registry avro data from Kafka (was: Support read

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16048: --- Description: KafkaAvroSerializer and AvroRowSerializationSchema I found SQL Kafka connector can not

[jira] [Comment Edited] (FLINK-16026) Travis failed due to python setup

2020-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656 ] Dian Fu edited comment on FLINK-16026 at 2/14/20 2:51 AM: -- [~chesnay] Thanks a

[jira] [Updated] (FLINK-16048) Support read confluent schema registry avro data from Kafka

2020-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16048: --- Summary: Support read confluent schema registry avro data from Kafka (was: Support read avro data

[jira] [Commented] (FLINK-16026) Travis failed due to python setup

2020-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656 ] Dian Fu commented on FLINK-16026: - [~chesnay] Thanks a lot for your suggestions. Appreciated! We have

[jira] [Created] (FLINK-16050) Add Attempt Information

2020-02-13 Thread lining (Jira)
lining created FLINK-16050: -- Summary: Add Attempt Information Key: FLINK-16050 URL: https://issues.apache.org/jira/browse/FLINK-16050 Project: Flink Issue Type: Improvement Components:

[jira] [Updated] (FLINK-14127) Better BackPressure Detection in WebUI

2020-02-13 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14127: --- Parent: FLINK-14712 Issue Type: Sub-task (was: Improvement) > Better BackPressure Detection in

[jira] [Commented] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036647#comment-17036647 ] Jiayi Liao commented on FLINK-16012: [~kevin.cyj] Which result is tested before the change? And

[jira] [Assigned] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-13 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15913: --- Assignee: Huang Xingbo > Add Python Table Function Runner And Operator >

[jira] [Closed] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-13 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15913. --- Resolution: Resolved > Add Python Table Function Runner And Operator >

[jira] [Comment Edited] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-13 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036638#comment-17036638 ] Hequn Cheng edited comment on FLINK-15913 at 2/14/20 2:10 AM: -- Resolved in

[jira] [Commented] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-13 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036638#comment-17036638 ] Hequn Cheng commented on FLINK-15913: - Resolved in #11044: d36d97c84a365d1aee8101dbb1db61374348d024

[GitHub] [flink] hequn8128 closed pull request #11044: [FLINK-15913][python] Add Python TableFunction Runner and Operator in Blink planner

2020-02-13 Thread GitBox
hequn8128 closed pull request #11044: [FLINK-15913][python] Add Python TableFunction Runner and Operator in Blink planner URL: https://github.com/apache/flink/pull/11044 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-16048) Support read avro data that serialized by KafkaAvroSerializer from Kafka in Table

2020-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036628#comment-17036628 ] Leonard Xu commented on FLINK-16048: Hi , [~dwysakowicz]  you're right, I think we should support

[GitHub] [flink] dianfu edited a comment on issue #11084: [FLINK-16040][python] Change local import to global import

2020-02-13 Thread GitBox
dianfu edited a comment on issue #11084: [FLINK-16040][python] Change local import to global import URL: https://github.com/apache/flink/pull/11084#issuecomment-586051943 @HuangXingBo Thanks for the PR and sharing the performance data. The performance gain is impressive. LGTM. Merging...

[jira] [Closed] (FLINK-16040) Change local import to global import

2020-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-16040. --- Resolution: Resolved Merged to master via 3cc8e1ae3a941410111e228d0beef4058fd3ed7e > Change local import

[GitHub] [flink] dianfu merged pull request #11084: [FLINK-16040][python] Change local import to global import

2020-02-13 Thread GitBox
dianfu merged pull request #11084: [FLINK-16040][python] Change local import to global import URL: https://github.com/apache/flink/pull/11084 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dianfu commented on issue #11084: [FLINK-16040][python] Change local import to global import

2020-02-13 Thread GitBox
dianfu commented on issue #11084: [FLINK-16040][python] Change local import to global import URL: https://github.com/apache/flink/pull/11084#issuecomment-586051943 LGTM. Merging... This is an automated message from the

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Attachment: image-2020-02-14-09-13-07-967.png > Reduce the default number of exclusive buffers

[GitHub] [flink] flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#issuecomment-562912876 ## CI report: * f7d3793fc60c8700f99adf52ed760e9665f42a90 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11086: [FLINK-16046][es] Drop Elasticsearch 2 connector

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #11086: [FLINK-16046][es] Drop Elasticsearch 2 connector URL: https://github.com/apache/flink/pull/11086#issuecomment-585812010 ## CI report: * b80c63e29a93076852da00f58a8554b0d35cfa98 Travis:

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

2020-02-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Attachment: image-2020-02-14-07-23-16-171.png > Reduce the default number of exclusive buffers

[GitHub] [flink] flinkbot edited a comment on issue #11086: [FLINK-16046][es] Drop Elasticsearch 2 connector

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #11086: [FLINK-16046][es] Drop Elasticsearch 2 connector URL: https://github.com/apache/flink/pull/11086#issuecomment-585812010 ## CI report: * b80c63e29a93076852da00f58a8554b0d35cfa98 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#issuecomment-562912876 ## CI report: * f7d3793fc60c8700f99adf52ed760e9665f42a90 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11086: [FLINK-16046][es] Drop Elasticsearch 2 connector

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #11086: [FLINK-16046][es] Drop Elasticsearch 2 connector URL: https://github.com/apache/flink/pull/11086#issuecomment-585812010 ## CI report: * b80c63e29a93076852da00f58a8554b0d35cfa98 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#issuecomment-562912876 ## CI report: * f7d3793fc60c8700f99adf52ed760e9665f42a90 Travis:

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

2020-02-13 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036536#comment-17036536 ] Stephan Ewen commented on FLINK-10918: -- Here is an implementation of using {{java.nio.file.Path}}

[GitHub] [flink] StephanEwen commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

2020-02-13 Thread GitBox
StephanEwen commented on a change in pull request #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#discussion_r379143892 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events

2020-02-13 Thread GitBox
flinkbot edited a comment on issue #10483: [FLINK-15099][runtime] (FLIP-27) Add Operator Coordinators and Events URL: https://github.com/apache/flink/pull/10483#issuecomment-562912876 ## CI report: * f7d3793fc60c8700f99adf52ed760e9665f42a90 Travis:

  1   2   3   4   >