[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14313163#comment-14313163 ] Fabian Hueske commented on FLINK-703: - I propose wildcard field expressions ( {{"*"}} a

[jira] [Commented] (FLINK-1444) Add data properties for data sources

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312977#comment-14312977 ] ASF GitHub Bot commented on FLINK-1444: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request: [FLINK-1444][api-extending] Add support for sp...

2015-02-09 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/379 [FLINK-1444][api-extending] Add support for split data properties on data sources This pull request adds support for declaring global and local properties for input splits. You can merge this pull

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2015-02-09 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312849#comment-14312849 ] Henry Saputra commented on FLINK-1502: -- Should this be subtask for FLINK-1501 ? > Ex

[jira] [Created] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode

2015-02-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1504: - Summary: Add support for accessing secured HDFS clusters in standalone mode Key: FLINK-1504 URL: https://issues.apache.org/jira/browse/FLINK-1504 Project: Flink

[jira] [Created] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API

2015-02-09 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1503: - Summary: GSoC project: Batch and Streaming integration through new operators and unified API Key: FLINK-1503 URL: https://issues.apache.org/jira/browse/FLINK-1503 Project:

[GitHub] flink pull request: Remove unused enum values from Aggregations en...

2015-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/373 --- 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 enabl

[GitHub] flink pull request: Remove unused enum values from Aggregations en...

2015-02-09 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/373#issuecomment-73560969 Thanks for the review, will merge it soon. --- 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

[jira] [Created] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2015-02-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1502: - Summary: Expose metrics to graphite, ganglia and JMX. Key: FLINK-1502 URL: https://issues.apache.org/jira/browse/FLINK-1502 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface

2015-02-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1501: - Summary: Integrate metrics library and report basic metrics to JobManager web interface Key: FLINK-1501 URL: https://issues.apache.org/jira/browse/FLINK-1501 Projec

[jira] [Updated] (FLINK-456) Integrate runtime metrics / statistics

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-456: - Summary: Integrate runtime metrics / statistics (was: Optional runtime statistics / metrics collec

[jira] [Resolved] (FLINK-1495) Make Akka timeout configurable in YARN client.

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1495. --- Resolution: Fixed Fix Version/s: 0.9 Resolved in http://git-wip-us.apache.org/repos/asf

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

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

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/377 --- 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 enabl

[jira] [Resolved] (FLINK-1498) Spurious failures on Travis for I/O heavy tasks

2015-02-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1498. - Resolution: Fixed Fixed in 52d9806baaff1689f21962febb7dc73d68572289 > Spurious failures on Travis

[jira] [Created] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis

2015-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1500: Summary: exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis Key: FLINK-1500 URL: https://issues.apache.org/jira/browse/FLINK-1500 Project: Flink

[jira] [Commented] (FLINK-1201) Graph API for Flink

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312477#comment-14312477 ] ASF GitHub Bot commented on FLINK-1201: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons (...

2015-02-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-73547684 Simple renaming didn't seem to keep the history, so I did the filtering again :) Didn't you have the same problem when moving flink-addons to flink-staging? Let

[jira] [Created] (FLINK-1499) Make TaskManager to disconnect from TaskManager in case of a restart

2015-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1499: Summary: Make TaskManager to disconnect from TaskManager in case of a restart Key: FLINK-1499 URL: https://issues.apache.org/jira/browse/FLINK-1499 Project: Flink

[jira] [Closed] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-02-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1376. Resolution: Fixed Fixed with db1b8b993c12f2e74b6cc9a48414265666dc0e69 in 0.9 Fixed with 91382bb8c1

[jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers

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

[GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo...

2015-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/378 [FLINK-1489] Fixes blocking scheduleOrUpdateConsumers message calls Replaces the blocking calls with futures which in case of an exception let the respective task fail. Furthermore, the Partitio

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312368#comment-14312368 ] ASF GitHub Bot commented on FLINK-1495: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/377#issuecomment-73530921 Thank you. I'll merge it once the master is building again ;) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/377#issuecomment-73529074 LGTM. --- 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 enabl

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312361#comment-14312361 ] ASF GitHub Bot commented on FLINK-1495: --- Github user tillrohrmann commented on the p

[jira] [Created] (FLINK-1498) Spurious failures on Travis for I/O heavy tasks

2015-02-09 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1498: --- Summary: Spurious failures on Travis for I/O heavy tasks Key: FLINK-1498 URL: https://issues.apache.org/jira/browse/FLINK-1498 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1478) Add strictly local input split assignment

2015-02-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1478. - Resolution: Fixed Fixed in 4386620c06e94c9f4e3030ea7ae0f480845e2969 > Add strictly local input sp

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

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

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/375 --- 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 enabl

[jira] [Commented] (FLINK-1497) No documentation on MiniCluster

2015-02-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312308#comment-14312308 ] Stephan Ewen commented on FLINK-1497: - The mini cluster is so far an internal testing

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312271#comment-14312271 ] ASF GitHub Bot commented on FLINK-1478: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/375#discussion_r24330528 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -260,15 +260,49 @@ public void connectToPredeces

[jira] [Created] (FLINK-1497) No documentation on MiniCluster

2015-02-09 Thread Sergey Dudoladov (JIRA)
Sergey Dudoladov created FLINK-1497: --- Summary: No documentation on MiniCluster Key: FLINK-1497 URL: https://issues.apache.org/jira/browse/FLINK-1497 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1496) Events at unitialized input channels are lost

2015-02-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1496: -- Summary: Events at unitialized input channels are lost Key: FLINK-1496 URL: https://issues.apache.org/jira/browse/FLINK-1496 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312264#comment-14312264 ] ASF GitHub Bot commented on FLINK-1478: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/375#discussion_r24329907 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -260,15 +260,49 @@ public void connectToPred

[jira] [Updated] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1391: -- Fix Version/s: 0.8.1 > Kryo fails to properly serialize avro collection types >

[jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client.

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312246#comment-14312246 ] ASF GitHub Bot commented on FLINK-1495: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura...

2015-02-09 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/377 [FLINK-1495][yarn] Make Akka timeout configurable in YARN client. You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink yarn_timeouts

[jira] [Commented] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312241#comment-14312241 ] ASF GitHub Bot commented on FLINK-1391: --- Github user rmetzger closed the pull reques

[jira] [Updated] (FLINK-1392) Serializing Protobuf - issue 1

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1392: -- Fix Version/s: 0.8.1 > Serializing Protobuf - issue 1 > -- > >

[jira] [Updated] (FLINK-1392) Serializing Protobuf - issue 1

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1392: -- Affects Version/s: 0.9 0.8 > Serializing Protobuf - issue 1 > ---

[jira] [Commented] (FLINK-1392) Serializing Protobuf - issue 1

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312242#comment-14312242 ] Robert Metzger commented on FLINK-1392: --- Pushed fix for "release-0.8" in http://git

[jira] [Commented] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312240#comment-14312240 ] ASF GitHub Bot commented on FLINK-1391: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: Port FLINK-1391 and FLINK-1392 to "release-0.8...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/364#issuecomment-73510972 Merged. --- 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

[jira] [Commented] (FLINK-1391) Kryo fails to properly serialize avro collection types

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312239#comment-14312239 ] Robert Metzger commented on FLINK-1391: --- Pushed fix into "release-0.8": 84c4998125b1

[GitHub] flink pull request: Port FLINK-1391 and FLINK-1392 to "release-0.8...

2015-02-09 Thread rmetzger
Github user rmetzger closed the pull request at: https://github.com/apache/flink/pull/364 --- 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 ena

[jira] [Created] (FLINK-1495) Make Akka timeout configurable in YARN client.

2015-02-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1495: - Summary: Make Akka timeout configurable in YARN client. Key: FLINK-1495 URL: https://issues.apache.org/jira/browse/FLINK-1495 Project: Flink Issue Type: Im

[jira] [Resolved] (FLINK-1396) Add hadoop input formats directly to the user API.

2015-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1396. - Resolution: Fixed Fix Version/s: 0.8.1 0.9 Resolved in https://

[jira] [Resolved] (FLINK-1303) HadoopInputFormat does not work with Scala API

2015-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1303. - Resolution: Fixed Fix Version/s: 0.8.1 Resolved in https://github.com/apache/flink

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

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

[GitHub] flink pull request: [FLINK-1396][FLINK-1303] Hadoop Input/Output d...

2015-02-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/363 --- 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 enabl

[jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312231#comment-14312231 ] ASF GitHub Bot commented on FLINK-1179: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte...

2015-02-09 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/374#issuecomment-73509674 @StephanEwen Thanks for your advice! I fixed it. --- 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-1478) Add strictly local input split assignment

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312214#comment-14312214 ] ASF GitHub Bot commented on FLINK-1478: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/375#discussion_r24327047 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -260,15 +260,49 @@ public void connectToPredeces

[jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312203#comment-14312203 ] ASF GitHub Bot commented on FLINK-1376: --- Github user tillrohrmann closed the pull re

[GitHub] flink pull request: [FLINK-1376] [runtime] Add proper shared slot ...

2015-02-09 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/318 --- 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-377) Create a general purpose framework for language bindings

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312202#comment-14312202 ] ASF GitHub Bot commented on FLINK-377: -- Github user zentol commented on the pull reque

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-02-09 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-73505531 @qmlmoon has provided TPCH Query 3 / 10 and WebLogAnalysis examples --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-1478) Add strictly local input split assignment

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312200#comment-14312200 ] ASF GitHub Bot commented on FLINK-1478: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-1478] Add support for strictly local in...

2015-02-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/375#issuecomment-73505358 Only minor remarks. Looks good otherwise. --- 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 proj

[jira] [Commented] (FLINK-1486) Add a string to the print method to identify output

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312194#comment-14312194 ] ASF GitHub Bot commented on FLINK-1486: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ...

2015-02-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/372#issuecomment-73504724 To make it a bit more explicit what is sink identifier and what is the task identifier (especially when just one of the two are printed), I prefixed the sink identifier with "

[jira] [Updated] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1376: -- Affects Version/s: 0.9 0.8 > SubSlots are not properly released in case t

[GitHub] flink pull request: [FLINK-1376] [runtime] Add proper shared slot ...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/318#issuecomment-73504622 I've merged it to the 0.8 branch. I forgot to close the PR, could you do it manually? Thank you. --- If your project is set up for it, you can reply to this email an

[jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312191#comment-14312191 ] Robert Metzger commented on FLINK-1376: --- Resolved for "release-0.8" with target 0.8.

[jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312192#comment-14312192 ] ASF GitHub Bot commented on FLINK-1376: --- Github user rmetzger commented on the pull

[jira] [Updated] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1376: -- Fix Version/s: 0.8.1 > SubSlots are not properly released in case that a TaskManager fatally fai

[jira] [Commented] (FLINK-1479) The spawned threads in the sorter have no context class loader

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312188#comment-14312188 ] Robert Metzger commented on FLINK-1479: --- Fixed in "release-0.8" by [~StephanEwen] in

[jira] [Updated] (FLINK-1479) The spawned threads in the sorter have no context class loader

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1479: -- Fix Version/s: 0.8.1 > The spawned threads in the sorter have no context class loader >

[jira] [Resolved] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

2015-02-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-1463. - Resolution: Fixed Resolved in https://github.com/apache/flink/commit/7bc78cbf97d341ebfed3

[jira] [Closed] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1494. Resolution: Not a Problem The build failure was caused by not cleaned up artefacts, i.e., not callin

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

2015-02-09 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312182#comment-14312182 ] Gyula Fora commented on FLINK-1493: --- Hey, This is actually quite tricky to make it robu

[jira] [Commented] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312177#comment-14312177 ] Ufuk Celebi commented on FLINK-1494: Repeatedly as in "sometimes" or "always"? ;) The

[jira] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312176#comment-14312176 ] ASF GitHub Bot commented on FLINK-1463: --- Github user aljoscha closed the pull reques

[jira] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312175#comment-14312175 ] ASF GitHub Bot commented on FLINK-1463: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/353#issuecomment-73501310 Manually merged. --- 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 featur

[GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer...

2015-02-09 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/353 --- 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 ena

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312173#comment-14312173 ] ASF GitHub Bot commented on FLINK-1492: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-09 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73500986 Yes, if it is finally OK. --- 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 fe

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312172#comment-14312172 ] ASF GitHub Bot commented on FLINK-1492: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/376#issuecomment-73500870 This change is also in 0.8 so do we need to apply the fix there as well for the upcoming 0.8.1 release? --- If your project is set up for it, you can reply to this email

[jira] [Updated] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1342: -- Priority: Critical (was: Major) > Quickstart's assembly can possibly filter out user's code > -

[jira] [Commented] (FLINK-1201) Graph API for Flink

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312158#comment-14312158 ] ASF GitHub Bot commented on FLINK-1201: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons (...

2015-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/335#issuecomment-73499086 @vasia: You don't need to open a new pull request, force pushing to the branch this PR is based on will update it. I don't know if you need to do the history filtering

[jira] [Commented] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312156#comment-14312156 ] Robert Metzger commented on FLINK-1487: --- I had another instance of this issue, in th

[jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312094#comment-14312094 ] ASF GitHub Bot commented on FLINK-1492: --- GitHub user uce opened a pull request:

[GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut...

2015-02-09 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/376 [FLINK-1492] Fix exceptions on blob store shutdown You can merge this pull request into a Git repository by running: $ git pull https://github.com/uce/incubator-flink flink-1492-proper_shutdown_ho

[jira] [Commented] (FLINK-1475) Minimize log output of yarn test cases

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14312093#comment-14312093 ] Robert Metzger commented on FLINK-1475: --- Resolved in http://git-wip-us.apache.org/re

[jira] [Resolved] (FLINK-1475) Minimize log output of yarn test cases

2015-02-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1475. --- Resolution: Fixed Fix Version/s: 0.9 > Minimize log output of yarn test cases > ---

[jira] [Created] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1494: Summary: Build fails on BlobCacheTest Key: FLINK-1494 URL: https://issues.apache.org/jira/browse/FLINK-1494 Project: Flink Issue Type: Bug Componen

[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311988#comment-14311988 ] ASF GitHub Bot commented on FLINK-1484: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/368#issuecomment-73479833 Yes, I'll do it. On Mon, Feb 9, 2015 at 10:23 AM, Stephan Ewen wrote: > My bad, there is a ticket already. Can you squash the commits then and ad

[GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ...

2015-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/368#issuecomment-73478622 My bad, there is a ticket already. Can you squash the commits then and add the ticket tag? Otherwise, good to merge! --- If your project is set up for it, yo

[jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311970#comment-14311970 ] ASF GitHub Bot commented on FLINK-1484: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

2015-02-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311962#comment-14311962 ] Márton Balassi commented on FLINK-1493: --- Hey Matthias, Thanks for looking into this

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311965#comment-14311965 ] ASF GitHub Bot commented on FLINK-1396: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager

2015-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311967#comment-14311967 ] ASF GitHub Bot commented on FLINK-1179: --- Github user rmetzger commented on the pull

  1   2   >