[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493113#comment-16493113 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-28 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191306509 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79

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

2018-05-28 Thread Fred Teunissen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493109#comment-16493109 ] Fred Teunissen commented on FLINK-8500: --- @[~aljoscha], [~tzulitai], If you like, I can make the PR

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

2018-05-28 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493096#comment-16493096 ] Hequn Cheng commented on FLINK-8545: Hi [~pnowojski], plan to work on it and probably will finish the

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2018-05-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 5/29/18 4:13 AM: error-prone has JDK 8

[jira] [Updated] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-28 Thread zhengcanbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengcanbin updated FLINK-9460: --- Description: The output seems incorrect in my table & upsert example, here's the code: {code:java}

[jira] [Created] (FLINK-9460) Redundant output in table & upsert semantics

2018-05-28 Thread zhengcanbin (JIRA)
zhengcanbin created FLINK-9460: -- Summary: Redundant output in table & upsert semantics Key: FLINK-9460 URL: https://issues.apache.org/jira/browse/FLINK-9460 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493059#comment-16493059 ] ASF GitHub Bot commented on FLINK-9187: --- Github user lamber-ken commented on a diff in the pull

[GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r...

2018-05-28 Thread lamber-ken
Github user lamber-ken commented on a diff in the pull request: https://github.com/apache/flink/pull/5857#discussion_r191297773 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,79

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493057#comment-16493057 ] ASF GitHub Bot commented on FLINK-9325: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp...

2018-05-28 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5982 Yes, @StephanEwen thanks for the continuous suggestions, will follow your suggestion. ---

[jira] [Commented] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2018-05-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493031#comment-16493031 ] Ted Yu commented on FLINK-9459: --- Related to FLINK-9091 ? > Maven enforcer plugin prevents compilation with

[jira] [Updated] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2018-05-28 Thread Truong Duc Kien (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Truong Duc Kien updated FLINK-9459: --- Description: Compiling Flink with Hortonwork HDP's version of Hadoop is currently

[jira] [Created] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2018-05-28 Thread Truong Duc Kien (JIRA)
Truong Duc Kien created FLINK-9459: -- Summary: Maven enforcer plugin prevents compilation with HDP's Hadoop Key: FLINK-9459 URL: https://issues.apache.org/jira/browse/FLINK-9459 Project: Flink

[jira] [Assigned] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9458: --- Assignee: vinoyang > Unable to recover from job failure on YARN with NPE >

[jira] [Updated] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread Truong Duc Kien (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Truong Duc Kien updated FLINK-9458: --- Description: After upgrading our job to Flink 1.5, they are unable to recover from failure

[jira] [Updated] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread Truong Duc Kien (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Truong Duc Kien updated FLINK-9458: --- Description: After upgrading our job to Flink 1.5, they are unable to recover from failure

[jira] [Created] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread Truong Duc Kien (JIRA)
Truong Duc Kien created FLINK-9458: -- Summary: Unable to recover from job failure on YARN with NPE Key: FLINK-9458 URL: https://issues.apache.org/jira/browse/FLINK-9458 Project: Flink Issue

[jira] [Assigned] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9453: --- Assignee: yuqi > Flink 1.5 incorrectly shows statistics in web UI >

[jira] [Commented] (FLINK-9394) Let externalized checkpoint resume e2e also test rescaling

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492999#comment-16492999 ] ASF GitHub Bot commented on FLINK-9394: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #6038: [FLINK-9394] [e2e] Test rescaling when resuming from exte...

2018-05-28 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/6038 @StefanRRichter thanks for the review, will merge this. ---

[jira] [Commented] (FLINK-8205) Multi key get

2018-05-28 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492903#comment-16492903 ] Kostas Kloudas commented on FLINK-8205: --- Hi [~sihuazhou] . Sorry but I was a bit busy with the 1.5

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492857#comment-16492857 ] ASF GitHub Bot commented on FLINK-8863: --- GitHub user xccui opened a pull request:

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-05-28 Thread xccui
GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/6090 [FLINK-8863] [SQL] Add user-defined function support in SQL Client ## What is the purpose of the change This PR aims to add user-defined function (ScalarFunction, TableFunction and

[GitHub] flink issue #6076: [hotfix][docs] Specify operators behaviour on processing ...

2018-05-28 Thread eliaslevy
Github user eliaslevy commented on the issue: https://github.com/apache/flink/pull/6076 Thanks, that helps. Regarding debugging watermarks, at least in 1.4.2 sources did not display their emitted watermarks, although this may have been fixed in 1.5.0. In turn, that makes

[jira] [Commented] (FLINK-9450) Job hangs if S3 access it denied during checkpoints

2018-05-28 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492837#comment-16492837 ] Elias Levy commented on FLINK-9450: --- The logs show no errors.  Alas, we are using the JRE, so these

[GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp...

2018-05-28 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5982 I think we need to have a special output stream type (`AtomicCreatingFsDataOutputStream` or similar) as the return type of `FileSystem.createAtomic()`. Otherwise, how can a user actually create

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492828#comment-16492828 ] ASF GitHub Bot commented on FLINK-9325: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-9451) End-to-end test: Scala Quickstarts

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492813#comment-16492813 ] ASF GitHub Bot commented on FLINK-9451: --- GitHub user medcv opened a pull request:

[GitHub] flink pull request #6089: [FLINK-9451]End-to-end test: Scala Quickstarts

2018-05-28 Thread medcv
GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/6089 [FLINK-9451]End-to-end test: Scala Quickstarts ## What is the purpose of the change Added an end-to-end test which verifies Flink's quickstarts scala. It does the following: -

[jira] [Assigned] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

2018-05-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9455: - Assignee: Sihua Zhou > Make SlotManager aware of multi slot TaskManagers >

[jira] [Assigned] (FLINK-9456) Let ResourceManager notify JobManager about failed/killed TaskManagers

2018-05-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9456: - Assignee: Sihua Zhou > Let ResourceManager notify JobManager about failed/killed TaskManagers >

[jira] [Assigned] (FLINK-9440) Allow cancelation and reset of timers

2018-05-28 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-9440: - Assignee: Stefan Richter > Allow cancelation and reset of timers >

[jira] [Created] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

2018-05-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9457: Summary: Cancel container requests when cancelling pending slot allocations Key: FLINK-9457 URL: https://issues.apache.org/jira/browse/FLINK-9457 Project: Flink

[jira] [Commented] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492788#comment-16492788 ] ASF GitHub Bot commented on FLINK-7449: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4543: [FLINK-7449] [docs] Additional documentation for incremen...

2018-05-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4543 Ping @StefanRRichter. Can we get this documentation merged? The community would definitely appreciate it. ---

[jira] [Created] (FLINK-9456) Let ResourceManager notify JobManager about failed/killed TaskManagers

2018-05-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9456: Summary: Let ResourceManager notify JobManager about failed/killed TaskManagers Key: FLINK-9456 URL: https://issues.apache.org/jira/browse/FLINK-9456 Project: Flink

[jira] [Created] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

2018-05-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9455: Summary: Make SlotManager aware of multi slot TaskManagers Key: FLINK-9455 URL: https://issues.apache.org/jira/browse/FLINK-9455 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8899: - Fix Version/s: 1.5.1 1.6.0 > Submitting YARN job with FLIP-6 may lead to >

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9010: - Priority: Major (was: Critical) > NoResourceAvailableException with FLIP-6 >

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9010: - Fix Version/s: 1.6.0 > NoResourceAvailableException with FLIP-6 >

[jira] [Commented] (FLINK-5505) Harmonize ZooKeeper configuration parameters

2018-05-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492775#comment-16492775 ] vinoyang commented on FLINK-5505: - [~till.rohrmann] if you have no opinion, I will start this issue. >

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492772#comment-16492772 ] vinoyang commented on FLINK-9352: - [~till.rohrmann] OK, I will accept your opinion. Although, I think

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492766#comment-16492766 ] Till Rohrmann commented on FLINK-9352: -- I would prefer [~StephanEwen]'s proposal to make it random

[jira] [Commented] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492764#comment-16492764 ] Andrei Shumanski commented on FLINK-9454: - Just double checked - these files exist in 

[jira] [Comment Edited] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492753#comment-16492753 ] Andrei Shumanski edited comment on FLINK-9454 at 5/28/18 2:58 PM: -- I

[jira] [Commented] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492761#comment-16492761 ] Andrei Shumanski commented on FLINK-9454: - As all incorrect files are in /test/ and I run with

[jira] [Updated] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9352: - Affects Version/s: 1.6.0 1.5.0 1.4.2 > In

[jira] [Updated] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9352: - Issue Type: Improvement (was: Bug) > In Standalone checkpoint recover mode many jobs with same

[jira] [Updated] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9352: - Priority: Major (was: Critical) > In Standalone checkpoint recover mode many jobs with same

[jira] [Comment Edited] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492753#comment-16492753 ] Andrei Shumanski edited comment on FLINK-9454 at 5/28/18 2:55 PM: -- I

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-05-28 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492760#comment-16492760 ] Andrey Zagrebin commented on FLINK-9231: [~yuzhih...@gmail.com] just wondering could you please

[jira] [Commented] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492753#comment-16492753 ] Andrei Shumanski commented on FLINK-9454: - I downloaded the source code from the official page:

[jira] [Comment Edited] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492751#comment-16492751 ] Dawid Wysakowicz edited comment on FLINK-9454 at 5/28/18 2:48 PM: -- Did

[jira] [Commented] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492751#comment-16492751 ] Dawid Wysakowicz commented on FLINK-9454: - Did you run it on a cleanly checked out repository? You

[jira] [Updated] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrei Shumanski updated FLINK-9454: Environment: {{$ java -version}} {{java version }}{{"1.8.0_172"}} {{Java(TM) SE Runtime

[jira] [Created] (FLINK-9454) Build instructions for MapR do not work

2018-05-28 Thread Andrei Shumanski (JIRA)
Andrei Shumanski created FLINK-9454: --- Summary: Build instructions for MapR do not work Key: FLINK-9454 URL: https://issues.apache.org/jira/browse/FLINK-9454 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrei Shumanski updated FLINK-9453: Description: Flink 1.5.0 incorrectly shows execution statistics and differently from Flink

[jira] [Updated] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrei Shumanski updated FLINK-9453: Description: Flink 1.5.0 incorrectly shows execution statistics and differently from Flink

[jira] [Updated] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrei Shumanski updated FLINK-9453: Description: Flink 1.5.0 incorrectly shows execution statistics and differently from Flink

[jira] [Updated] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread Andrei Shumanski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrei Shumanski updated FLINK-9453: Description: Flink 1.5.0 incorrectly shows execution statistics and differently from Flink

[jira] [Commented] (FLINK-9436) Remove generic parameter namespace from InternalTimeServiceManager

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492735#comment-16492735 ] ASF GitHub Bot commented on FLINK-9436: --- Github user sihuazhou commented on the issue:

[jira] [Created] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread Andrei Shumanski (JIRA)
Andrei Shumanski created FLINK-9453: --- Summary: Flink 1.5 incorrectly shows statistics in web UI Key: FLINK-9453 URL: https://issues.apache.org/jira/browse/FLINK-9453 Project: Flink Issue

[GitHub] flink issue #6077: [FLINK-9436][state] Remove generic parameter namespace fr...

2018-05-28 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/6077 +1 ---

[jira] [Commented] (FLINK-8790) Improve performance for recovery from incremental checkpoint

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492732#comment-16492732 ] ASF GitHub Bot commented on FLINK-8790: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5582: [FLINK-8790][State] Improve performance for recovery from...

2018-05-28 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5582 Hi @StefanRRichter could you please have a look at this? ---

[jira] [Commented] (FLINK-8205) Multi key get

2018-05-28 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492731#comment-16492731 ] Sihua Zhou commented on FLINK-8205: --- Hi [~kkl0u] are you still willing to help with the design and the

[jira] [Commented] (FLINK-9417) Send heartbeat requests from RPC endpoint's main thread

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492729#comment-16492729 ] ASF GitHub Bot commented on FLINK-9417: --- GitHub user sihuazhou opened a pull request:

[GitHub] flink pull request #6088: [FLINK-9417][ Distributed Coordination] Send heart...

2018-05-28 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/6088 [FLINK-9417][ Distributed Coordination] Send heartbeat requests from RPC endpoint's main thread ## What is the purpose of the change This PR try to send heartbeat requests from RPC

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492721#comment-16492721 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5448 Hi @yanghua I think those changes look overall good. The biggest concern I had with handling `MANAGED_MEMORY_SIZE` as I think if used with old style configuration file, the resulting value

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492717#comment-16492717 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492713#comment-16492713 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191191358 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java --- @@ -72,10 +72,19 @@ " leader-election

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191197602 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -647,7 +649,16 @@ public static long

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492715#comment-16492715 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492709#comment-16492709 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492714#comment-16492714 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492710#comment-16492710 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191190916 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -176,19 +188,19 @@ /** * Size of memory

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492712#comment-16492712 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492711#comment-16492711 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191199370 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java --- @@ -223,9 +224,17 @@ public static

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492716#comment-16492716 ] ASF GitHub Bot commented on FLINK-6469: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191190775 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -176,19 +188,19 @@ /** * Size of memory

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191147488 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -32,10 +32,22 @@ // General TaskManager Options

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191147297 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java --- @@ -72,10 +72,19 @@ " leader-election

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191186380 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -176,19 +188,19 @@ /** * Size of memory

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-05-28 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/5448#discussion_r191198882 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java --- @@ -647,7 +649,16 @@ public static long

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

2018-05-28 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492699#comment-16492699 ] Piotr Nowojski commented on FLINK-8545: --- [~hequn8128], could say what's the status of your work

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492691#comment-16492691 ] ASF GitHub Bot commented on FLINK-9143: --- Github user yuqi1129 commented on a diff in the pull

[GitHub] flink pull request #5846: [FLINK-9143] [client] Restart strategy defined in ...

2018-05-28 Thread yuqi1129
Github user yuqi1129 commented on a diff in the pull request: https://github.com/apache/flink/pull/5846#discussion_r191211627 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java --- @@ -896,6 +898,10 @@ public static JobGraph

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-05-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492688#comment-16492688 ] ASF GitHub Bot commented on FLINK-8946: --- Github user yanghua commented on the issue:

[GitHub] flink issue #6060: [FLINK-8946] TaskManager stop sending metrics after JobMa...

2018-05-28 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6060 cc @zentol have a look at this? ---

[jira] [Closed] (FLINK-7901) Detecting whether an operator is restored doesn't work with chained state (Flink 1.3)

2018-05-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7901. --- Resolution: Won't Fix Fix Version/s: (was: 1.3.4) > Detecting whether an operator

[jira] [Reopened] (FLINK-8759) Bump Netty to 4.0.56

2018-05-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8759: - changing resolution... > Bump Netty to 4.0.56 > > >

[jira] [Closed] (FLINK-8759) Bump Netty to 4.0.56

2018-05-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8759. --- Resolution: Won't Fix > Bump Netty to 4.0.56 > > > Key:

[jira] [Updated] (FLINK-8759) Bump Netty to 4.0.56

2018-05-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8759: Fix Version/s: (was: 1.6.0) > Bump Netty to 4.0.56 > > >

[jira] [Closed] (FLINK-8759) Bump Netty to 4.0.56

2018-05-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8759. --- Resolution: Fixed > Bump Netty to 4.0.56 > > > Key:

[jira] [Updated] (FLINK-8874) rewrite Flink docs/dev/stream/operators/process_function.md to recommend using KeyedProcessFunction

2018-05-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8874: Fix Version/s: (was: 1.6.0) > rewrite Flink

  1   2   3   >