Re: Flink 1.0.0 Release Candidate 0: Please help testing

So far, I found the following issues: - https://issues.apache.org/jira/browse/FLINK-3400 - https://issues.apache.org/jira/browse/FLINK-3446 - https://issues.apache.org/jira/browse/FLINK-3439 - https://issues.apache.org/jira/browse/FLINK-3439 - https://issues.apache.org/jira/browse/FLINK-3418 -

[jira] [Created] (FLINK-3447) Package Gelly algorithms by framework

Greg Hogan created FLINK-3447: - Summary: Package Gelly algorithms by framework Key: FLINK-3447 URL: https://issues.apache.org/jira/browse/FLINK-3447 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3446) Back pressure tracker throws NPE for archived jobs

Ufuk Celebi created FLINK-3446: -- Summary: Back pressure tracker throws NPE for archived jobs Key: FLINK-3446 URL: https://issues.apache.org/jira/browse/FLINK-3446 Project: Flink Issue Type:

[jira] [Created] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type

Vasia Kalavri created FLINK-3444: Summary: env.fromElements relies on the first input element for determining the DataSet/DataStream type Key: FLINK-3444 URL: https://issues.apache.org/jira/browse/FLINK-3444

Re: Dense matricies in FlinkML

Hi guys, They are at least already registered for serialization [1], so there should be no intentional conflict as Theo has suggested. [1] https://github.com/apache/flink/blob/master/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/common/FlinkMLTools.scala#L67-L73 Best, Marton On

Re: Dense matricies in FlinkML

Hello Trevor, IIRC it was mostly that they weren't needed at the time. Feel free to add, along with BLAS ops. Cheers, Theo On Thu, Feb 18, 2016 at 5:14 PM, Trevor Grant wrote: > Is there a specific reason vectors are imported from Breeze and matrices > aren't? > >

Re: Guarantees for object reuse modes and documentation

Hi Fabian, I would only add to your citations Stephan's comment [1] concerning the design, implementation, and use of object reuse. I see two separate concerns addressed in code. First, as Stephan noted, for certain classes deserialization is sufficiently expensive relative to object creation

[jira] [Created] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling

Ufuk Celebi created FLINK-3443: -- Summary: JobManager cancel and clear everything fails jobs instead of cancelling Key: FLINK-3443 URL: https://issues.apache.org/jira/browse/FLINK-3443 Project: Flink

[jira] [Created] (FLINK-3442) Expose savepoint button on web ui

Gyula Fora created FLINK-3442: - Summary: Expose savepoint button on web ui Key: FLINK-3442 URL: https://issues.apache.org/jira/browse/FLINK-3442 Project: Flink Issue Type: Improvement

Re: Extending and improving our "How to contribute" page

Hi Martin, Sounds like a good idea to me to create a checklist like this. It would be a nice reminder for people who didn't read the how-to-contribute section of the README :) Cheers, Max On Thu, Feb 18, 2016 at 9:31 AM, Martin Liesenberg wrote: > Hi, > > GitHub

Dense matricies in FlinkML

Is there a specific reason vectors are imported from Breeze and matrices aren't? Specifically I need to take the dot product of a matrix and a vector and a matrix and a matrix. Was wondering if there is a theoretical reason or it just wasn't needed at the time. Looks like some of this got lifted

[jira] [Created] (FLINK-3441) Revisit quickstarts exclusion policy

Till Rohrmann created FLINK-3441: Summary: Revisit quickstarts exclusion policy Key: FLINK-3441 URL: https://issues.apache.org/jira/browse/FLINK-3441 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved

Stephan Ewen created FLINK-3440: --- Summary: Kafka should also checkpoint partitions where no initial offset was retrieved Key: FLINK-3440 URL: https://issues.apache.org/jira/browse/FLINK-3440 Project:

[jira] [Created] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource

Aljoscha Krettek created FLINK-3439: --- Summary: Remove final Long.MAX_VALUE Watermark in StreamSource Key: FLINK-3439 URL: https://issues.apache.org/jira/browse/FLINK-3439 Project: Flink

Re: Guarantees for object reuse modes and documentation

Judging from our chaining condition ds.getPushChainDriverClass() != null && !(pred instanceof NAryUnionPlanNode) &&// first op after union is stand-alone, because union is merged !(pred instanceof BulkPartialSolutionPlanNode) &&// partial solution merges anyways !(pred instanceof

Re: Guarantees for object reuse modes and documentation

Thanks Matthias. Maybe I should clarify, that I do not want to change the guarantees for the enableObjectReuse mode, but for the disableObjectReuse mode. The rules for the enableObjectReuse mode should remain the same. 2016-02-18 9:37 GMT+01:00 Matthias J. Sax : > Hi, > > I

Re: Extending and improving our "How to contribute" page

Hi, GitHub just introduced a way to supply PR templates. [1] To support the changes discussed here, we could add a simple template with check boxes like: [ ] did you add tests [ ] did you check against the coding guidelines [ ] is there a jira supporting the PR Let me know what you think. The

Re: Hi all

Welcome to the Flink community, Josep! While reading the documentation, if anything catches your eye, feel free to correct or make an addition via a pull request. That's a great way to contribute. Cheers, Max On Wed, Feb 17, 2016 at 8:29 PM, Jamie Grier wrote: >