[jira] [Commented] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14330438#comment-14330438 ] Robert Metzger commented on FLINK-1596: --- I've added that the issue also affects

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

2015-02-21 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: -- Fix Version/s: (was: 0.8.1) 0.8.2 Quickstart's assembly can possibly

[jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name

2015-02-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1596: -- Affects Version/s: 0.8 FileIOChannel introduces space in temp file name

[jira] [Resolved] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1650. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/c9d29f26

[jira] [Created] (FLINK-1753) Add more tests for Kafka Connectors

2015-03-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1753: - Summary: Add more tests for Kafka Connectors Key: FLINK-1753 URL: https://issues.apache.org/jira/browse/FLINK-1753 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-03-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14382015#comment-14382015 ] Robert Metzger commented on FLINK-1789: --- You can just add the path to the regular

[jira] [Updated] (FLINK-1433) Add HADOOP_CLASSPATH to start scripts

2015-01-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1433: -- Fix Version/s: 0.8.1 Add HADOOP_CLASSPATH to start scripts

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

2015-01-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14298498#comment-14298498 ] Robert Metzger commented on FLINK-1452: --- Okay, so we rename {{flink-addons}} to

[jira] [Created] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

2015-03-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1769: - Summary: Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile) Key: FLINK-1769 URL: https://issues.apache.org/jira/browse/FLINK-1769

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375573#comment-14375573 ] Robert Metzger commented on FLINK-1765: --- Can we add a test for this fix? Reducer

[jira] [Reopened] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-1757: --- java.lang.ClassCastException is thrown while summing Short values on window

[jira] [Resolved] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1757. --- Resolution: Fixed Fix Version/s: 0.9 java.lang.ClassCastException is thrown while

[jira] [Updated] (FLINK-1769) Maven deploy is broken (build artifacts are cleaned in docs-and-sources profile)

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1769: -- Component/s: Build System Maven deploy is broken (build artifacts are cleaned in

[jira] [Updated] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1720: -- Component/s: Build System Integrate ScalaDoc in Scala sources into overall JavaDoc

[jira] [Commented] (FLINK-1650) Suppress Akka's Netty Shutdown Errors through the log config

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375668#comment-14375668 ] Robert Metzger commented on FLINK-1650: --- I got a response from the Akka mailing

[jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1725: -- Assignee: Anis Nasir New Partitioner for better load balancing for skewed data

[jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375621#comment-14375621 ] Robert Metzger commented on FLINK-1744: --- I'm not sure if I'm understanding why you

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375664#comment-14375664 ] Robert Metzger commented on FLINK-1765: --- Ah, great. Thank you! Reducer grouping is

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375611#comment-14375611 ] Robert Metzger commented on FLINK-1725: --- Great! I gave you Contributor permissions

[jira] [Commented] (FLINK-1774) Remove the redundant code in try{} block

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14376407#comment-14376407 ] Robert Metzger commented on FLINK-1774: --- Hi [~matadorhong], I gave you Contributor

[jira] [Updated] (FLINK-1774) Remove the redundant code in try{} block

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1774: -- Assignee: Sibao Hong Remove the redundant code in try{} block

[jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1773: -- Assignee: Gyula Fora Add interface for grouped policies to broadcast information to other

[jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1773: -- Affects Version/s: 0.9 Add interface for grouped policies to broadcast information to other

[jira] [Updated] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

2015-03-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1773: -- Component/s: Streaming Add interface for grouped policies to broadcast information to other

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Resolved] (FLINK-1589) Add option to pass Configuration to LocalExecutor

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

[jira] [Updated] (FLINK-1589) Add option to pass Configuration to LocalExecutor

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1589: -- Component/s: Scala API Java API Add option to pass Configuration to

[jira] [Commented] (FLINK-1753) Add more tests for Kafka Connectors

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392357#comment-14392357 ] Robert Metzger commented on FLINK-1753: --- First tests merged in

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Assignee: Gábor Hermann Add more tests for Kafka Connectors

[jira] [Resolved] (FLINK-1777) Update Java 8 Lambdas with Eclipse documentation

2015-04-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1777. --- Resolution: Fixed Fix Version/s: 0.9 Merged in

[jira] [Updated] (FLINK-1822) Update Community page on website with a Getting Help section

2015-04-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1822: -- Attachment: update_community.patch Update Community page on website with a Getting Help

[jira] [Updated] (FLINK-1821) simplify coding

2015-04-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1821: -- Assignee: Liu Jiongzhou simplify coding Key: FLINK-1821

[jira] [Created] (FLINK-1822) Update Community page on website with a Getting Help section

2015-04-03 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1822: - Summary: Update Community page on website with a Getting Help section Key: FLINK-1822 URL: https://issues.apache.org/jira/browse/FLINK-1822 Project: Flink

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492927#comment-14492927 ] Robert Metzger commented on FLINK-1829: --- The dependency tree doesn't contain any

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492926#comment-14492926 ] Robert Metzger commented on FLINK-1829: --- The dependency tree doesn't contain any

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

2015-04-13 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: -- Affects Version/s: 0.8.1 Quickstart's assembly can possibly filter out user's code

[jira] [Assigned] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1829: - Assignee: Robert Metzger Conflicting Jackson version in the Flink POMs

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492842#comment-14492842 ] Robert Metzger commented on FLINK-1829: --- I'm looking into this. Conflicting

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492949#comment-14492949 ] Robert Metzger commented on FLINK-1829: --- But these jacksons are in different maven

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

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492783#comment-14492783 ] Robert Metzger commented on FLINK-1342: --- I'll backport the fix to release-0.8

[jira] [Issue Comment Deleted] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1829: -- Comment: was deleted (was: The dependency tree doesn't contain any HBase dependencies. I

[jira] [Commented] (FLINK-1886) how can handles left join ,right join , FULL OUTER JOIN in flink

2015-04-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493830#comment-14493830 ] Robert Metzger commented on FLINK-1886: --- Hi, please use the u...@flink.apache.org

[jira] [Commented] (FLINK-1861) Rename doc deployment directories

2015-04-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493733#comment-14493733 ] Robert Metzger commented on FLINK-1861: --- docs/latest/ and docs/stable/ are still not

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493737#comment-14493737 ] Robert Metzger commented on FLINK-1829: --- Cool. I'm happy its not an issue with Flink

[jira] [Closed] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1829. - Resolution: Invalid Conflicting Jackson version in the Flink POMs

[jira] [Closed] (FLINK-1886) how can handles left join ,right join , FULL OUTER JOIN in flink

2015-04-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1886. - Resolution: Invalid how can handles left join ,right join , FULL OUTER JOIN in flink

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492897#comment-14492897 ] Robert Metzger commented on FLINK-1829: --- I was not able to reproduce the issue.

[jira] [Comment Edited] (FLINK-1877) Stalled Flink on Tez build

2015-04-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492345#comment-14492345 ] Robert Metzger edited comment on FLINK-1877 at 4/13/15 5:19 PM:

[jira] [Created] (FLINK-1913) Document how to access data in HCatalog

2015-04-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1913: - Summary: Document how to access data in HCatalog Key: FLINK-1913 URL: https://issues.apache.org/jira/browse/FLINK-1913 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-04-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502580#comment-14502580 ] Robert Metzger commented on FLINK-1746: --- Hi, I gave you Contributor permissions in

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2015-04-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502901#comment-14502901 ] Robert Metzger commented on FLINK-1914: --- Hi, thank you for the feedback. The Yarn

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2015-04-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502939#comment-14502939 ] Robert Metzger commented on FLINK-1914: --- I have to admit its not very prominent, but

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

2015-04-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507058#comment-14507058 ] Robert Metzger commented on FLINK-1865: --- The issue still persists (this is a build

[jira] [Commented] (FLINK-1865) Unstable test KafkaITCase

2015-04-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507069#comment-14507069 ] Robert Metzger commented on FLINK-1865: --- I have written to the Kafka Mailing list to

[jira] [Created] (FLINK-1929) Add code to cleanly stop a running streaming topology

2015-04-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1929: - Summary: Add code to cleanly stop a running streaming topology Key: FLINK-1929 URL: https://issues.apache.org/jira/browse/FLINK-1929 Project: Flink Issue

[jira] [Commented] (FLINK-1930) NullPointerException in vertex-centric iteration

2015-04-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507179#comment-14507179 ] Robert Metzger commented on FLINK-1930: --- I've seen this issue also recently in a

[jira] [Assigned] (FLINK-1865) Unstable test KafkaITCase

2015-04-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1865: - Assignee: Robert Metzger (was: Márton Balassi) Unstable test KafkaITCase

[jira] [Assigned] (FLINK-1921) Rework parallelism/slots handling for per-job YARN sessions

2015-04-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1921: - Assignee: Robert Metzger Rework parallelism/slots handling for per-job YARN sessions

[jira] [Assigned] (FLINK-1920) Passing -D akka.ask.timeout=5 min to yarn client does not work

2015-04-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1920: - Assignee: Robert Metzger Passing -D akka.ask.timeout=5 min to yarn client does not work

[jira] [Resolved] (FLINK-1875) Add figure to documentation describing slots and parallelism

2015-04-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1875. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/db608332

[jira] [Created] (FLINK-1935) Reimplement PersistentKafkaSource using high level Kafka API

2015-04-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1935: - Summary: Reimplement PersistentKafkaSource using high level Kafka API Key: FLINK-1935 URL: https://issues.apache.org/jira/browse/FLINK-1935 Project: Flink

[jira] [Created] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging

2015-04-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1923: - Summary: Replace asynchronous logging in JobManager with regular slf4j logging Key: FLINK-1923 URL: https://issues.apache.org/jira/browse/FLINK-1923 Project: Flink

[jira] [Created] (FLINK-1922) Failed task deployment causes NPE on input split assignment

2015-04-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1922: - Summary: Failed task deployment causes NPE on input split assignment Key: FLINK-1922 URL: https://issues.apache.org/jira/browse/FLINK-1922 Project: Flink

[jira] [Commented] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis

2015-04-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506691#comment-14506691 ] Robert Metzger commented on FLINK-1804: --- I didn't see them lately. I'll close the

[jira] [Resolved] (FLINK-1804) flink-quickstart-scala tests fail on scala-2.11 build profile on travis

2015-04-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1804. --- Resolution: Invalid flink-quickstart-scala tests fail on scala-2.11 build profile on travis

[jira] [Created] (FLINK-1920) Passing -D akka.ask.timeout=5 min to yarn client does not work

2015-04-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1920: - Summary: Passing -D akka.ask.timeout=5 min to yarn client does not work Key: FLINK-1920 URL: https://issues.apache.org/jira/browse/FLINK-1920 Project: Flink

[jira] [Created] (FLINK-1921) Rework parallelism/slots handling for per-job YARN sessions

2015-04-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1921: - Summary: Rework parallelism/slots handling for per-job YARN sessions Key: FLINK-1921 URL: https://issues.apache.org/jira/browse/FLINK-1921 Project: Flink

[jira] [Closed] (FLINK-1961) DataSet.partitionCustom not documented

2015-04-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1961. - Resolution: Duplicate DataSet.partitionCustom not documented

[jira] [Updated] (FLINK-1946) Make yarn tests logging less verbose

2015-04-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1946: -- Component/s: YARN Client Make yarn tests logging less verbose

[jira] [Created] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes

2015-04-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1949: - Summary: YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes Key: FLINK-1949 URL: https://issues.apache.org/jira/browse/FLINK-1949

[jira] [Created] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1950: - Summary: Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants Key: FLINK-1950 URL: https://issues.apache.org/jira/browse/FLINK-1950

[jira] [Commented] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514232#comment-14514232 ] Robert Metzger commented on FLINK-1950: --- Spark is removing 10%, but at least 384 mb.

[jira] [Created] (FLINK-1961) DataSet.partitionCustom not documented

2015-04-29 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1961: - Summary: DataSet.partitionCustom not documented Key: FLINK-1961 URL: https://issues.apache.org/jira/browse/FLINK-1961 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance

2015-04-28 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1952: - Summary: Cannot run ConnectedComponents example: Could not allocate a slot on instance Key: FLINK-1952 URL: https://issues.apache.org/jira/browse/FLINK-1952

[jira] [Resolved] (FLINK-1924) [Py] Refactor a few minor things

2015-04-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1924. --- Resolution: Fixed Merged [Py] Refactor a few minor things

[jira] [Assigned] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1950: - Assignee: Robert Metzger Increase default heap cutoff ratio from 20% to 30% and move

[jira] [Resolved] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants

2015-04-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1950. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/f2daa108

[jira] [Commented] (FLINK-1690) ProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure spuriously fails on Travis

2015-04-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521669#comment-14521669 ] Robert Metzger commented on FLINK-1690: --- Another instance

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

2015-05-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528421#comment-14528421 ] Robert Metzger commented on FLINK-1962: --- I think [~aljoscha] can give the best

[jira] [Commented] (FLINK-1675) Rework Accumulators

2015-05-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14530555#comment-14530555 ] Robert Metzger commented on FLINK-1675: --- (3) will also resolve the issue that

[jira] [Commented] (FLINK-964) Integrate profiling code with web interface

2015-05-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532175#comment-14532175 ] Robert Metzger commented on FLINK-964: -- Yes, we can close this issue. One of the

[jira] [Resolved] (FLINK-964) Integrate profiling code with web interface

2015-05-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-964. -- Resolution: Won't Fix Integrate profiling code with web interface

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1985: -- Affects Version/s: 0.9 Streaming does not correctly forward ExecutionConfig to runtime

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1985: -- Priority: Blocker (was: Major) Streaming does not correctly forward ExecutionConfig to

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1985: -- Component/s: Streaming Streaming does not correctly forward ExecutionConfig to runtime

[jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs

2015-05-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14533358#comment-14533358 ] Robert Metzger commented on FLINK-1525: --- I drafted some more code for this feature

[jira] [Resolved] (FLINK-1995) The Flink project is categorized under Incubator in the Apache JIRA tracker

2015-05-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1995. --- Resolution: Fixed Resolved. The Flink project is categorized under Incubator in the Apache

[jira] [Updated] (FLINK-1537) GSoC project: Machine learning with Apache Flink

2015-05-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1537: -- Component/s: Machine Learning Library GSoC project: Machine learning with Apache Flink

[jira] [Commented] (FLINK-1103) Update Streaming examples to become self-contained

2015-05-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537896#comment-14537896 ] Robert Metzger commented on FLINK-1103: --- The data has been replaced by something we

[jira] [Updated] (FLINK-1874) Break up streaming connectors into submodules

2015-05-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1874: -- Component/s: Streaming Break up streaming connectors into submodules

[jira] [Updated] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1711: -- Assignee: (was: Mathusuthan Kannan) Replace all usages off commons.Validate with

[jira] [Updated] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1711: -- Assignee: Lokesh Rajaram Replace all usages off commons.Validate with guava.check

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537109#comment-14537109 ] Robert Metzger commented on FLINK-1711: --- Hey, no problem ;) I assigned

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-05-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14536359#comment-14536359 ] Robert Metzger commented on FLINK-1711: --- Hey [~mathnkann], are you still working on

[jira] [Resolved] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

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

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

2015-05-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14536360#comment-14536360 ] Robert Metzger commented on FLINK-1874: --- Hi, thanks for your interest in

[jira] [Updated] (FLINK-1995) The Flink project is categorized under Incubator in the Apache JIRA tracker

2015-05-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1995: -- Issue Type: Task (was: Bug) The Flink project is categorized under Incubator in the Apache

[jira] [Commented] (FLINK-1995) The Flink project is categorized under Incubator in the Apache JIRA tracker

2015-05-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534383#comment-14534383 ] Robert Metzger commented on FLINK-1995: --- Will do The Flink project is categorized

[jira] [Assigned] (FLINK-1995) The Flink project is categorized under Incubator in the Apache JIRA tracker

2015-05-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1995: - Assignee: Robert Metzger The Flink project is categorized under Incubator in the Apache

<    1   2   3   4   5   6   7   8   9   10   >