[jira] [Commented] (FLINK-8492) [FLINK-8492][table] Fix calc cost bug

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339126#comment-16339126 ] ASF GitHub Bot commented on FLINK-8492: --- Github user hequn8128 commented on the issu

[GitHub] flink issue #5347: [FLINK-8492][table] Fix calc cost bug

2018-01-25 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/5347 hi @fhueske @twalthr , the pr has been updated. It would be great if you can take a look at it. Changes mainly include: 1. Adapt estimateRowCount to be more accurate. The original impl

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-01-25 Thread Antoine Philippot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339101#comment-16339101 ] Antoine Philippot commented on FLINK-6756: -- Hi [~aljoscha] and [~spi-x-i] I have

[jira] [Commented] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339096#comment-16339096 ] ASF GitHub Bot commented on FLINK-8146: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5349: [FLINK-8146][py] Properly close ZipInputStream

2018-01-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5349 ---

[jira] [Closed] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8146. --- Resolution: Fixed master: 9f54f6b5f2ab85397ba6dd720baa2ddf69cc7024 > Potential resource leak

[jira] [Reopened] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8352: - > Flink UI Reports No Error on Job Submission Failures > -

[jira] [Closed] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8352. --- Resolution: Fixed > Flink UI Reports No Error on Job Submission Failures > ---

[jira] [Updated] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8352: Affects Version/s: 1.5.0 > Flink UI Reports No Error on Job Submission Failures > --

[jira] [Updated] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8352: Component/s: (was: Web Client) Webfrontend > Flink UI Reports No Error

[jira] [Closed] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8352. --- Resolution: Fixed 1.4: 38278ebefe0fcc88448e6770de9c345f16b0d482 > Flink UI Reports No Error o

[jira] [Updated] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8146: Fix Version/s: (was: 1.4.1) > Potential resource leak in PythonPlanBinder#unzipPythonLib

[jira] [Updated] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8146: Affects Version/s: (was: 1.4.0) > Potential resource leak in PythonPlanBinder#unzipPytho

[jira] [Closed] (FLINK-7719) Send checkpoint id to task as part of deployment descriptor when resuming

2018-01-25 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7719. - Resolution: Fixed Fix Version/s: 1.5.0 Merged in 402a2e30c750e1bcb753643ed66c6df0dd861112.

[jira] [Closed] (FLINK-7720) Centralize creation of backends and state related resources

2018-01-25 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7720. - Resolution: Fixed Fix Version/s: 1.5.0 Merged in 517b3f87214168a445b5751cda210ecf3a292fd6.

[jira] [Updated] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8352: Fix Version/s: 1.4.1 1.5.0 > Flink UI Reports No Error on Job Submission

[jira] [Commented] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339083#comment-16339083 ] Chesnay Schepler commented on FLINK-8352: - master: 40ba6261b9b151459b3402087d20bb9

[jira] [Assigned] (FLINK-8504) TaskExecutor does not properly deregisters JobManager from JobLeaderService

2018-01-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8504: Assignee: Till Rohrmann > TaskExecutor does not properly deregisters JobManager from JobLea

[jira] [Commented] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339069#comment-16339069 ] ASF GitHub Bot commented on FLINK-8485: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5360: [backport-1.4] [FLINK-8485] [client] Unblock JobSu...

2018-01-25 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5360 [backport-1.4] [FLINK-8485] [client] Unblock JobSubmissionClientActor#tryToSubmitJob This is a backport of #5359. Additionally it also includes a backport of #4924. You can merge this pull re

[jira] [Commented] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339064#comment-16339064 ] ASF GitHub Bot commented on FLINK-8485: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5359: [FLINK-8485] [client] Unblock JobSubmissionClientA...

2018-01-25 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5359 [FLINK-8485] [client] Unblock JobSubmissionClientActor#tryToSubmitJob ## What is the purpose of the change The JobSubmissionClientActor blocked a ActorSystem's dispatcher thread when r

[jira] [Commented] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0

2018-01-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339031#comment-16339031 ] Till Rohrmann commented on FLINK-8485: -- The problem seems to be that there is blockin

[jira] [Updated] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0

2018-01-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8485: - Fix Version/s: 1.4.1 1.5.0 > Running Flink inside Intellij no longer works afte

[jira] [Assigned] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0

2018-01-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-8485: Assignee: Till Rohrmann > Running Flink inside Intellij no longer works after upgrading fro

[jira] [Updated] (FLINK-8485) Running Flink inside Intellij no longer works after upgrading from 1.3.2 to 1.4.0

2018-01-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8485: - Affects Version/s: 1.5.0 > Running Flink inside Intellij no longer works after upgrading from 1.3.

[jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339014#comment-16339014 ] ASF GitHub Bot commented on FLINK-8384: --- Github user dyanarose commented on a diff i

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-25 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r163796598 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0 +1,101 @@

[jira] [Comment Edited] (FLINK-8448) [flink-mesos] The flink-job jars uploaded in directory 'web.upload.dir' are deleted on flink-scheduler restart

2018-01-25 Thread Bhumika Bayani (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339000#comment-16339000 ] Bhumika Bayani edited comment on FLINK-8448 at 1/25/18 9:47 AM:

[jira] [Commented] (FLINK-8448) [flink-mesos] The flink-job jars uploaded in directory 'web.upload.dir' are deleted on flink-scheduler restart

2018-01-25 Thread Bhumika Bayani (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339000#comment-16339000 ] Bhumika Bayani commented on FLINK-8448: --- Anyone > [flink-mesos] The flink-job jars

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338969#comment-16338969 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338973#comment-16338973 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163783813 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java --- @@ -0,0 +1,102 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338972#comment-16338972 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163778106 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java --- @@ -41,4 +41,34 @@ public static final ConfigOption REST_

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338970#comment-16338970 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338968#comment-16338968 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163776982 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientConfigurationTest.java --- @@ -0,0 +1,51 @@ +/* + *

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163776913 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClientConfiguration.java --- @@ -19,60 +19,73 @@ package org

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338974#comment-16338974 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163776886 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClientConfiguration.java --- @@ -19,60 +19,73 @@ package org

[jira] [Commented] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338971#comment-16338971 ] ASF GitHub Bot commented on FLINK-8344: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163775574 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -258,89 +312,96 @@ public String cancelWithSav

[GitHub] flink pull request #5312: [FLINK-8344][flip6] Add support for HA to RestClus...

2018-01-25 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5312#discussion_r163775424 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -258,89 +312,96 @@ public String cancelWithSav

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-01-25 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338958#comment-16338958 ] yanxiaobin commented on FLINK-8500: --- I mean that I want to use Kafka message timestamp a

[GitHub] flink pull request #5358: [hotfix][StreamingJobGraphGenerator] modify the cl...

2018-01-25 Thread maqingxiang
GitHub user maqingxiang opened a pull request: https://github.com/apache/flink/pull/5358 [hotfix][StreamingJobGraphGenerator] modify the classification of partitioner in connect I think that it is better to divide the partitioner into two categories according to DistributionPattern

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338913#comment-16338913 ] ASF GitHub Bot commented on FLINK-8484: --- Github user pluppens commented on the issue

[GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co...

2018-01-25 Thread pluppens
Github user pluppens commented on the issue: https://github.com/apache/flink/pull/5337 @bowenli86 Makes sense - I've updated the description to contain the initial email/issue. HTH. ---

<    1   2   3