[jira] [Created] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-03-15 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-3617: -- Summary: NPE from CaseClassSerializer when dealing with null Option field Key: FLINK-3617 URL: https://issues.apache.org/jira/browse/FLINK-3617 Project: Flink

[GitHub] flink pull request: [FLINK-3612] Fix/adjust Table API examples

2016-03-15 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1793#issuecomment-197065239 Can be merged once the name for the type converter map is added. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-3612) Fix/adjust Table API examples

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196454#comment-15196454 ] ASF GitHub Bot commented on FLINK-3612: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-3612) Fix/adjust Table API examples

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196435#comment-15196435 ] ASF GitHub Bot commented on FLINK-3612: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3612] Fix/adjust Table API examples

2016-03-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1793#discussion_r56256616 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetAggregate.scala --- @@ -96,24 +93,32 @@ class

[jira] [Commented] (FLINK-2997) Support range partition with user customized data distribution.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196412#comment-15196412 ] ASF GitHub Bot commented on FLINK-2997: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-2997] Support range partition with user...

2016-03-15 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1776#issuecomment-197057859 Sorry @gallenvara, I was busy the last days. I will look into this PR tomorrow. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Resolved] (FLINK-3506) ReduceExpressionsRule does not remove duplicate expression in Filter

2016-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-3506. -- Resolution: Fixed Fix Version/s: 1.1.0 Validated that the issue is resolved. >

[GitHub] flink pull request: [hotFix] [tableAPI] Improve naming of DataSetR...

2016-03-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1799 [hotFix] [tableAPI] Improve naming of DataSetRelNodes You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink tableNames Alternatively

[jira] [Commented] (FLINK-3503) ProjectJoinTransposeRule fails to push down project.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196355#comment-15196355 ] ASF GitHub Bot commented on FLINK-3503: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request: [FLINK-3503] [tableAPI] Add cost model for Dat...

2016-03-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1798 [FLINK-3503] [tableAPI] Add cost model for DataSet RelNodes to improve plan selection Calcite's default cost model does not take IO and CPU into account. As a consequence, projections are not

[jira] [Commented] (FLINK-3609) Revisit selection of Calcite rules

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196350#comment-15196350 ] ASF GitHub Bot commented on FLINK-3609: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request: [FLINK-3609] [tableAPI] Reorganize selection o...

2016-03-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1797 [FLINK-3609] [tableAPI] Reorganize selection of optimization rules - Remove the join reordering rules to keep the user specified join order (rules can be added if enough statistics are available).

[jira] [Created] (FLINK-3616) Python API version inconsistencies

2016-03-15 Thread Omar Alvarez (JIRA)
Omar Alvarez created FLINK-3616: --- Summary: Python API version inconsistencies Key: FLINK-3616 URL: https://issues.apache.org/jira/browse/FLINK-3616 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195955#comment-15195955 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-196970622 First batch of comments addressed, the following are still missing: * test cases * re-implement as something that is not a SimpleChannelInboundHandler *

[jira] [Resolved] (FLINK-3489) Refactor Table API before merging into master

2016-03-15 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3489. -- Resolution: Fixed Fix Version/s: 1.1.0 > Refactor Table API before merging into master >

[GitHub] flink pull request: [FLINK-3489] TableAPI refactoring and cleanup

2016-03-15 Thread vasia
Github user vasia closed the pull request at: https://github.com/apache/flink/pull/1789 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3489) Refactor Table API before merging into master

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195848#comment-15195848 ] ASF GitHub Bot commented on FLINK-3489: --- Github user vasia closed the pull request at:

[jira] [Commented] (FLINK-1964) Rework TwitterSource to use a Properties object instead of a file path

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195840#comment-15195840 ] ASF GitHub Bot commented on FLINK-1964: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1964] Reimplement TwitterSource

2016-03-15 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1796 [FLINK-1964] Reimplement TwitterSource The TwitterSource was not really usable before because it expected the user to pass the path to a properties file, which is accessible on all worker nodes.

[jira] [Assigned] (FLINK-3407) Extend TwitterSource with interface StoppableFunction

2016-03-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3407: - Assignee: Robert Metzger > Extend TwitterSource with interface StoppableFunction >

[jira] [Commented] (FLINK-3489) Refactor Table API before merging into master

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195744#comment-15195744 ] ASF GitHub Bot commented on FLINK-3489: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3489] TableAPI refactoring and cleanup

2016-03-15 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1789#issuecomment-196939443 Please go ahead :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56205336 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,801 @@ +/* + *

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195733#comment-15195733 ] ASF GitHub Bot commented on FLINK-3544: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195714#comment-15195714 ] ASF GitHub Bot commented on FLINK-3544: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56204407 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java --- @@ -0,0 +1,343 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195710#comment-15195710 ] ASF GitHub Bot commented on FLINK-3544: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56204117 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java --- @@ -0,0 +1,182 @@ +/* + *

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195705#comment-15195705 ] ASF GitHub Bot commented on FLINK-3544: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56203861 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java --- @@ -0,0 +1,182 @@ +/* + *

[jira] [Commented] (FLINK-3489) Refactor Table API before merging into master

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195684#comment-15195684 ] ASF GitHub Bot commented on FLINK-3489: --- Github user vasia commented on the pull request:

[GitHub] flink pull request: [FLINK-3489] TableAPI refactoring and cleanup

2016-03-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1789#issuecomment-196927263 I would like to merge this if no objections :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195641#comment-15195641 ] ASF GitHub Bot commented on FLINK-3544: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56199223 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java --- @@ -0,0 +1,801 @@ +/* + *

[jira] [Commented] (FLINK-3612) Fix/adjust Table API examples

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195636#comment-15195636 ] ASF GitHub Bot commented on FLINK-3612: --- Github user vasia commented on the pull request:

[GitHub] flink pull request: [FLINK-3612] Fix/adjust Table API examples

2016-03-15 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1793#issuecomment-196920792 I've updated the PR with a change in the `DataSetAggregate` to inject a type conversion mapper if the expected type is not a `Row`. The `WordCountTable` and

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195615#comment-15195615 ] ASF GitHub Bot commented on FLINK-3544: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56197090 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java --- @@ -0,0 +1,182 @@ +/*

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195611#comment-15195611 ] ASF GitHub Bot commented on FLINK-3544: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56196742 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java --- @@ -0,0 +1,343 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3544) ResourceManager runtime components

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195610#comment-15195610 ] ASF GitHub Bot commented on FLINK-3544: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone...

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1741#discussion_r56196565 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java --- @@ -0,0 +1,182 @@ +/*

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195541#comment-15195541 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56188957 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -781,6 +787,32 @@ class TaskManager( } }

[GitHub] flink pull request: Kafka-3375: Allows Watermark Generation in the...

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1795#discussion_r56187319 --- Diff:

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195524#comment-15195524 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56186817 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195494#comment-15195494 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56184730 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195488#comment-15195488 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56184137 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195487#comment-15195487 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56183974 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195486#comment-15195486 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on the pull request:

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2016-03-15 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-196879970 @chiwanpark for the docs, it looks like you use an auto-generated markdown file from the source code? i.e. looks like something analogous to `scaladoc

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195475#comment-15195475 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56181881 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56181072 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195470#comment-15195470 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56180847 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -781,6 +787,32 @@ class TaskManager( }

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195468#comment-15195468 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195461#comment-15195461 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56180171 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195460#comment-15195460 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56180094 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195442#comment-15195442 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56178145 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195437#comment-15195437 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56177903 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195425#comment-15195425 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56176643 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -310,6 +310,12 @@ class TaskManager(

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56176392 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195420#comment-15195420 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195403#comment-15195403 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1790#issuecomment-196850069 I think the PR goes in the right direction @zentol. I had some comments concerning the concurrent implementation of the `TaskManagerLogHandler` and on the side of

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195400#comment-15195400 ] ASF GitHub Bot commented on FLINK-2732: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195399#comment-15195399 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56174087 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56173858 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskManagerMessages.scala --- @@ -114,6 +114,16 @@ object TaskManagerMessages

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56173641 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -234,7 +235,9 @@ public WebRuntimeMonitor(

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195397#comment-15195397 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195395#comment-15195395 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56173268 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195390#comment-15195390 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56172532 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56172503 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195388#comment-15195388 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-3608) ImmutableSettings error in ElasticsearchSink

2016-03-15 Thread Carlos Gonzalez de Zarate (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195380#comment-15195380 ] Carlos Gonzalez de Zarate commented on FLINK-3608: -- Hi Robert, Thanks for your quick

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195376#comment-15195376 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195378#comment-15195378 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195379#comment-15195379 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56172226 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195375#comment-15195375 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56172245 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56172080 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[GitHub] flink pull request: [FLINK-2732] Display TM logs in Dashboard

2016-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1790#discussion_r56172183 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195372#comment-15195372 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2016-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15195374#comment-15195374 ] ASF GitHub Bot commented on FLINK-2732: --- Github user tillrohrmann commented on a diff in the pull

  1   2   3   >