[jira] [Resolved] (FLINK-2034) Add vision and roadmap for ML library to docs

[ https://issues.apache.org/jira/browse/FLINK-2034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2034. -- Resolution: Fixed Added via b602b2ee1c9d130e97e844572f9827b29fbd9cf8 Add vision and roadmap

[jira] [Closed] (FLINK-1992) Add convergence criterion to SGD optimizer

[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1992. Resolution: Fixed Added via b3b6a9da0532d884f7d633530c11cda15aa6bc1b Add convergence criterion to

[jira] [Closed] (FLINK-2050) Add pipelining mechanism for chainable transformers and estimators

[ https://issues.apache.org/jira/browse/FLINK-2050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2050. Resolution: Fixed Added via fde0341fe16c7258e42f77e289a557157995830c Add pipelining mechanism for

[jira] [Commented] (FLINK-1999) TF-IDF transformer

[ https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14558224#comment-14558224 ] Till Rohrmann commented on FLINK-1999: -- You can do it as you like and what's easier

[jira] [Resolved] (FLINK-2056) Add guide to create a chainable predictor in docs

[ https://issues.apache.org/jira/browse/FLINK-2056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2056. -- Resolution: Fixed Added with 48e2cb5e8be7c4f305b947fb25ea7d312844e032 Add guide to create a

[jira] [Created] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge

Till Rohrmann created FLINK-2090: Summary: toString of CollectionInputFormat takes long time when the collection is huge Key: FLINK-2090 URL: https://issues.apache.org/jira/browse/FLINK-2090 Project:

[jira] [Closed] (FLINK-2053) Preregister ML types for Kryo serialization

[ https://issues.apache.org/jira/browse/FLINK-2053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2053. Resolution: Fixed Added with ae446388b91ecc0f08887da19400395b96b32f6c Preregister ML types for

[jira] [Assigned] (FLINK-2073) Add contribution guide for FlinkML

[ https://issues.apache.org/jira/browse/FLINK-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2073: Assignee: Till Rohrmann Add contribution guide for FlinkML

[jira] [Created] (FLINK-2075) Shade akka and protobuf dependencies away

Till Rohrmann created FLINK-2075: Summary: Shade akka and protobuf dependencies away Key: FLINK-2075 URL: https://issues.apache.org/jira/browse/FLINK-2075 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-2035) Update 0.9 roadmap with ML issues

[ https://issues.apache.org/jira/browse/FLINK-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2035. -- Resolution: Fixed Marked corresponding jira issues and added them to the google doc. Update

[jira] [Resolved] (FLINK-2083) Ensure high quality docs for FlinkML in 0.9

[ https://issues.apache.org/jira/browse/FLINK-2083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2083. -- Resolution: Fixed Improved with b015a32f6126d759fc6dee90b78f90f7ff8dfbac Ensure high quality

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

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1745: - Assignee: (was: Till Rohrmann) Add exact k-nearest-neighbours algorithm to machine learning

[jira] [Closed] (FLINK-2521) Add automatic test name logging for tests

[ https://issues.apache.org/jira/browse/FLINK-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2521. Resolution: Fixed Added via 2f0412f163f4d37605188c8cc763111e0b51f0dc Add automatic test name

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14701225#comment-14701225 ] Till Rohrmann commented on FLINK-1994: -- Sounds great [~rawkintrevo]. When it's ready,

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14702892#comment-14702892 ] Till Rohrmann commented on FLINK-2366: -- Do you mind taking the lead for the

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703052#comment-14703052 ] Till Rohrmann commented on FLINK-2366: -- Great to hear [~sirinath19...@gmail.com] :-)

[jira] [Comment Edited] (FLINK-2549) Add topK operator for DataSet

[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704565#comment-14704565 ] Till Rohrmann edited comment on FLINK-2549 at 8/20/15 9:17 AM:

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704565#comment-14704565 ] Till Rohrmann commented on FLINK-2549: -- I agree with [~StephanEwen]. Sorting the

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706744#comment-14706744 ] Till Rohrmann commented on FLINK-2549: -- Is required to implement sample operator

[jira] [Resolved] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-1901. -- Resolution: Fixed Added via c9cfb17cb095def8b8ea0ed1b598fc78b890b874 A fixed size sample

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

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14706360#comment-14706360 ] Till Rohrmann commented on FLINK-1745: -- Sorry for the late reply, but I want to

[jira] [Created] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20

Till Rohrmann created FLINK-2544: Summary: Some test cases using PowerMock fail with Java 8u20 Key: FLINK-2544 URL: https://issues.apache.org/jira/browse/FLINK-2544 Project: Flink Issue

[jira] [Updated] (FLINK-2564) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2564: - Labels: test-stability (was: ) Failing Test: RandomSamplerTest ---

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704520#comment-14704520 ] Till Rohrmann commented on FLINK-2366: -- I'll let you know when this happened :-) HA

[jira] [Updated] (FLINK-2066) Make delay between execution retries configurable

[ https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2066: - Assignee: Nuno Miguel Marques dos Santos Make delay between execution retries configurable

[jira] [Created] (FLINK-2289) Make JobManager highly available

Till Rohrmann created FLINK-2289: Summary: Make JobManager highly available Key: FLINK-2289 URL: https://issues.apache.org/jira/browse/FLINK-2289 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size

[ https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2278: Assignee: Till Rohrmann SparseVector created from Breeze Sparsevector has wrong size

[jira] [Resolved] (FLINK-2278) SparseVector created from Breeze Sparsevector has wrong size

[ https://issues.apache.org/jira/browse/FLINK-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2278. -- Resolution: Fixed Fixed via bc3684e69aff1a73f7fb3a62b097e9fbb311cd71 SparseVector created

[jira] [Updated] (FLINK-1994) Add different gain calculation schemes to SGD

[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1994: - Assignee: Trevor Grant Add different gain calculation schemes to SGD

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649172#comment-14649172 ] Till Rohrmann commented on FLINK-1994: -- Great to hear [~rawkintrevo]. I assigned the

[jira] [Commented] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link

[ https://issues.apache.org/jira/browse/FLINK-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653209#comment-14653209 ] Till Rohrmann commented on FLINK-2478: -- Thanks for reporting the broken link Slim.

[jira] [Assigned] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link

[ https://issues.apache.org/jira/browse/FLINK-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2478: Assignee: Till Rohrmann The page “FlinkML - Machine Learning for Flink“

[jira] [Resolved] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link

[ https://issues.apache.org/jira/browse/FLINK-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2478. -- Resolution: Fixed Fixed via 77b7471580ce9cada86e32c2b6919086ed2eb730 The page “FlinkML -

[jira] [Closed] (FLINK-2469) JobManager crashes on Cancel

[ https://issues.apache.org/jira/browse/FLINK-2469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2469. Resolution: Duplicate FLINK-2409 already covers the issue. JobManager crashes on Cancel

[jira] [Closed] (FLINK-2401) Replace ActorRefs with ActorGateway in web server

[ https://issues.apache.org/jira/browse/FLINK-2401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2401. Resolution: Duplicate See FLINK-2409 Replace ActorRefs with ActorGateway in web server

[jira] [Closed] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID

[ https://issues.apache.org/jira/browse/FLINK-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2409. Resolution: Fixed Fixed via fab61a1954ff1554448e826e1d273689ed520fc3 Old JM web interface is

[jira] [Created] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive

Till Rohrmann created FLINK-2472: Summary: Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive Key: FLINK-2472 URL:

[jira] [Updated] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive

[ https://issues.apache.org/jira/browse/FLINK-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2472: - Issue Type: Improvement (was: Bug) Make the JobClientActor check periodically if the submitted

[jira] [Commented] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681475#comment-14681475 ] Till Rohrmann commented on FLINK-2504: -- [~StephanEwen] the output of travis is all I

[jira] [Created] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

Till Rohrmann created FLINK-2504: Summary: ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously Key: FLINK-2504 URL: https://issues.apache.org/jira/browse/FLINK-2504

[jira] [Created] (FLINK-2521) Add automatic test name logging for tests

Till Rohrmann created FLINK-2521: Summary: Add automatic test name logging for tests Key: FLINK-2521 URL: https://issues.apache.org/jira/browse/FLINK-2521 Project: Flink Issue Type:

[jira] [Created] (FLINK-2518) Avoid predetermination of ports for network services

Till Rohrmann created FLINK-2518: Summary: Avoid predetermination of ports for network services Key: FLINK-2518 URL: https://issues.apache.org/jira/browse/FLINK-2518 Project: Flink Issue

[jira] [Assigned] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID

[ https://issues.apache.org/jira/browse/FLINK-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2409: Assignee: Till Rohrmann Old JM web interface is sending cancel messages w/o leader ID

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636451#comment-14636451 ] Till Rohrmann commented on FLINK-1901: -- If you use the sampling operator this way, it

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635206#comment-14635206 ] Till Rohrmann commented on FLINK-1901: -- I think this solution is indeed a little bit

[jira] [Closed] (FLINK-2332) Assign session IDs to JobManager and TaskManager messages

[ https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2332. Resolution: Fixed Added via 45428518d0e1b843947a6184b4a803a78ad5 Assign session IDs to

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638985#comment-14638985 ] Till Rohrmann commented on FLINK-2392: -- The same happened to me:

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638429#comment-14638429 ] Till Rohrmann commented on FLINK-1901: -- That's a good idea to break down the task. Do

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638448#comment-14638448 ] Till Rohrmann commented on FLINK-1901: -- Currently, whats happening to decide whether

[jira] [Created] (FLINK-2395) Check Scala catch blocks for Throwable

Till Rohrmann created FLINK-2395: Summary: Check Scala catch blocks for Throwable Key: FLINK-2395 URL: https://issues.apache.org/jira/browse/FLINK-2395 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14624402#comment-14624402 ] Till Rohrmann commented on FLINK-1737: -- Great to hear [~Daniel Pape]. I assigned the

[jira] [Updated] (FLINK-1737) Add statistical whitening transformation to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1737: - Assignee: Daniel Pape Add statistical whitening transformation to machine learning library

[jira] [Updated] (FLINK-1748) Integrate PageRank implementation into machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1748: - Priority: Minor (was: Major) Integrate PageRank implementation into machine learning library

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629505#comment-14629505 ] Till Rohrmann commented on FLINK-2366: -- But why can you not do the same with ZK? If

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629507#comment-14629507 ] Till Rohrmann commented on FLINK-2366: -- But in the end, you will execute your jobs on

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14629565#comment-14629565 ] Till Rohrmann commented on FLINK-2366: -- What do you mean exactly with embedded and

[jira] [Closed] (FLINK-1748) Integrate PageRank implementation into machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1748. Resolution: Done As part of Gelly. Integrate PageRank implementation into machine learning

[jira] [Updated] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2366: - Priority: Minor (was: Blocker) HA Without ZooKeeper

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634664#comment-14634664 ] Till Rohrmann commented on FLINK-1901: -- Hi Chengxiang, good to hear that you want to

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634800#comment-14634800 ] Till Rohrmann commented on FLINK-1901: -- Oh I forgot. Sorry. What about the iteration

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634826#comment-14634826 ] Till Rohrmann commented on FLINK-1901: -- To be honest, I doubt that the sampling is

[jira] [Updated] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1901: - Assignee: Chengxiang Li Create sample operator for Dataset --

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635096#comment-14635096 ] Till Rohrmann commented on FLINK-1901: -- The problem is that a sampling operator

[jira] [Commented] (FLINK-2189) NullPointerException in MutableHashTable

[ https://issues.apache.org/jira/browse/FLINK-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711620#comment-14711620 ] Till Rohrmann commented on FLINK-2189: -- [~JonathanH5] encountered this problem

[jira] [Commented] (FLINK-1195) Improvement of benchmarking infrastructure

[ https://issues.apache.org/jira/browse/FLINK-1195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14711604#comment-14711604 ] Till Rohrmann commented on FLINK-1195: -- I cannot really tell to what extent this PR

[jira] [Resolved] (FLINK-2878) JobManager warns: Unexpected leader address pattern

[ https://issues.apache.org/jira/browse/FLINK-2878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2878. -- Resolution: Fixed Fixed via 3cad56d28d55025281873f53a28ec27ce1027992 > JobManager warns:

[jira] [Created] (FLINK-2921) Add online documentation of sample methods

Till Rohrmann created FLINK-2921: Summary: Add online documentation of sample methods Key: FLINK-2921 URL: https://issues.apache.org/jira/browse/FLINK-2921 Project: Flink Issue Type:

[jira] [Created] (FLINK-2894) Flink does not allow to specify default serializer for Kryo

Till Rohrmann created FLINK-2894: Summary: Flink does not allow to specify default serializer for Kryo Key: FLINK-2894 URL: https://issues.apache.org/jira/browse/FLINK-2894 Project: Flink

[jira] [Closed] (FLINK-2894) Flink does not allow to specify default serializer for Kryo

[ https://issues.apache.org/jira/browse/FLINK-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2894. Resolution: Not A Problem > Flink does not allow to specify default serializer for Kryo >

[jira] [Assigned] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2800: Assignee: Till Rohrmann > kryo serialization problem > -- > >

[jira] [Created] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph

Till Rohrmann created FLINK-3036: Summary: Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph Key: FLINK-3036 URL: https://issues.apache.org/jira/browse/FLINK-3036 Project: Flink

[jira] [Assigned] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph

[ https://issues.apache.org/jira/browse/FLINK-3036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3036: Assignee: Till Rohrmann > Gelly's Graph.fromCsvReader method returns wrongly parameterized

[jira] [Comment Edited] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

[ https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14991725#comment-14991725 ] Till Rohrmann edited comment on FLINK-2979 at 11/5/15 2:29 PM: --- The failure

[jira] [Commented] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1

[ https://issues.apache.org/jira/browse/FLINK-2979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14991725#comment-14991725 ] Till Rohrmann commented on FLINK-2979: -- The failure might be caused by {code} java.lang.Exception:

[jira] [Created] (FLINK-2964) MutableHashTable fails when spilling partitions without overflow segments

Till Rohrmann created FLINK-2964: Summary: MutableHashTable fails when spilling partitions without overflow segments Key: FLINK-2964 URL: https://issues.apache.org/jira/browse/FLINK-2964 Project:

[jira] [Commented] (FLINK-2929) Recovery of jobs on cluster restarts

[ https://issues.apache.org/jira/browse/FLINK-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985022#comment-14985022 ] Till Rohrmann commented on FLINK-2929: -- Sure, but for me it would make more sense to add the option

[jira] [Commented] (FLINK-2959) Remove number of execution retries configuration from Environment

[ https://issues.apache.org/jira/browse/FLINK-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989289#comment-14989289 ] Till Rohrmann commented on FLINK-2959: -- I agree that we have to come up with a consistent way of

[jira] [Resolved] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2763. -- Resolution: Fixed I think the problem was solved by FLINK-2964. [~f.pompermaier] could you

[jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989297#comment-14989297 ] Till Rohrmann edited comment on FLINK-2763 at 11/4/15 10:43 AM: I think

[jira] [Commented] (FLINK-2929) Recovery of jobs on cluster restarts

[ https://issues.apache.org/jira/browse/FLINK-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14987374#comment-14987374 ] Till Rohrmann commented on FLINK-2929: -- We could auto generate a random ZNode path for each cluster

[jira] [Created] (FLINK-2852) Fix flaky ScalaShellITSuite

Till Rohrmann created FLINK-2852: Summary: Fix flaky ScalaShellITSuite Key: FLINK-2852 URL: https://issues.apache.org/jira/browse/FLINK-2852 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails

[ https://issues.apache.org/jira/browse/FLINK-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14958775#comment-14958775 ] Till Rohrmann commented on FLINK-2735: -- Here is another instance of the problem:

[jira] [Closed] (FLINK-2770) KafkaITCase.testConcurrentProducerConsumerTopology fails

[ https://issues.apache.org/jira/browse/FLINK-2770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2770. Resolution: Duplicate > KafkaITCase.testConcurrentProducerConsumerTopology fails >

[jira] [Created] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis

Till Rohrmann created FLINK-2854: Summary: KafkaITCase.testOneSourceMultiplePartitions failed on Travis Key: FLINK-2854 URL: https://issues.apache.org/jira/browse/FLINK-2854 Project: Flink

[jira] [Created] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ

Till Rohrmann created FLINK-2858: Summary: Cannot build Flink Scala 2.11 with IntelliJ Key: FLINK-2858 URL: https://issues.apache.org/jira/browse/FLINK-2858 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2852) Fix flaky ScalaShellITSuite

[ https://issues.apache.org/jira/browse/FLINK-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14964757#comment-14964757 ] Till Rohrmann commented on FLINK-2852: -- Hi [~sachingoel0101], you're right that the test is not

[jira] [Closed] (FLINK-2852) Fix flaky ScalaShellITSuite

[ https://issues.apache.org/jira/browse/FLINK-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2852. Resolution: Fixed Fixed in 630798d > Fix flaky ScalaShellITSuite > --- > >

[jira] [Resolved] (FLINK-2652) Failing PartitionRequestClientFactoryTest

[ https://issues.apache.org/jira/browse/FLINK-2652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2652. -- Resolution: Fixed Fixed in b2339464 > Failing PartitionRequestClientFactoryTest >

[jira] [Closed] (FLINK-2804) Support blocking job submission with Job Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2804. Resolution: Fixed Added in d18f580 > Support blocking job submission with Job Manager recovery >

[jira] [Resolved] (FLINK-2792) Set log level of actor messages to TRACE

[ https://issues.apache.org/jira/browse/FLINK-2792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2792. -- Resolution: Fixed Fixed in 3aaee1e > Set log level of actor messages to TRACE >

[jira] [Resolved] (FLINK-2354) Recover running jobs on JobManager failure

[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2354. -- Resolution: Fixed Added in a6890b2 > Recover running jobs on JobManager failure >

[jira] [Commented] (FLINK-2883) Combinable reduce produces wrong result

[ https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14966537#comment-14966537 ] Till Rohrmann commented on FLINK-2883: -- Yes, documenting it sounds like a reasonable solution. This

[jira] [Commented] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-2858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14965087#comment-14965087 ] Till Rohrmann commented on FLINK-2858: -- Thanks for your help [~aalexandrov] :-) I did not know how to

[jira] [Assigned] (FLINK-2804) Support blocking job submission with Job Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2804: Assignee: Till Rohrmann (was: Ufuk Celebi) > Support blocking job submission with Job

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944631#comment-14944631 ] Till Rohrmann commented on FLINK-2800: -- Hi [~stefano.bortoli], do you have small code example to

[jira] [Commented] (FLINK-2800) kryo serialization problem

[ https://issues.apache.org/jira/browse/FLINK-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944659#comment-14944659 ] Till Rohrmann commented on FLINK-2800: -- If I'm not mistaken, then this code example is not complete.

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

[ https://issues.apache.org/jira/browse/FLINK-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944675#comment-14944675 ] Till Rohrmann commented on FLINK-2790: -- What did the logs say? I try to reproduce it. On Mon, Oct

[jira] [Created] (FLINK-2329) Refactor RPCs from within the ExecutionGraph

Till Rohrmann created FLINK-2329: Summary: Refactor RPCs from within the ExecutionGraph Key: FLINK-2329 URL: https://issues.apache.org/jira/browse/FLINK-2329 Project: Flink Issue Type:

[jira] [Created] (FLINK-2332) Assign session IDs to JobManager and TaskManager messages

Till Rohrmann created FLINK-2332: Summary: Assign session IDs to JobManager and TaskManager messages Key: FLINK-2332 URL: https://issues.apache.org/jira/browse/FLINK-2332 Project: Flink

[jira] [Updated] (FLINK-2162) Implement adaptive learning rate strategies for SGD

[ https://issues.apache.org/jira/browse/FLINK-2162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2162: - Assignee: Ventura Del Monte Implement adaptive learning rate strategies for SGD

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