@Stephan: Yes you are correct. Both omitting the "returns(...)"
statement, or changing it to "returns(Centroid25.class)" would help.
The returns(TypeInformation) and returns(String) methods do absolutely
no type extraction, the user has to know what he is doing. If you read
the methods descrip
Yes sure, we need to figure that out. I investigated 2 hours in that
issue, but I couldn't find a reason. At the moment, I think it seems
that the IDE does not read its configuration files correctly.
Unfortunately, I have not much time resources this week. But I will try
to solve that problem.
Hi,
I can certainly see some ideas we have for Gelly making nice GSoC projects,
but I'm not sure I will have enough time to devote as a mentor.
@Fabian and others who were mentors last year: can you share a bit about
your experience and specifically about your workload during GSoC? What were
your
We still need to figure out a way to actually activate the lambda support
in Eclipse. I have not managed to do that so far ;-)
On Wed, Feb 11, 2015 at 9:41 PM, Timo Walther wrote:
> I will investigate that until the compiler is officially released (not
> just an RC).
>
> I think we should change
But in this case, there are no type parameters, correct? Centroid25 is not
a generic class...
On Wed, Feb 11, 2015 at 9:40 PM, Robert Metzger wrote:
> I think the issue is that the returns("eu.euranova.flink.Centroid25")
> variant only passes a string and the system does not know the
> typeparam
I think the issue is that the returns("eu.euranova.flink.Centroid25")
variant only passes a string and the system does not know the
typeparameters.
So we have to put GenericTypeInfo there, because we basically see Object's.
On Wed, Feb 11, 2015 at 9:37 PM, Stephan Ewen wrote:
> @Timo If I unders
I will investigate that until the compiler is officially released (not
just an RC).
I think we should change the documentation to the current situation of
Lambda Expressions where only a specific minor release version of
Eclipse JDT compiler is officially supported. I will do this tomorrow...
@Timo If I understand it correctly, both omitting the "returns(...)"
statement, or changing it to "returns(Centroid25.class)" would help?
I think that the behavior between "returns(Centroid25.class)" and "
returns("eu.euranova.flink.Centroid25")" should be consistent in that they
both handle the t
I haven't seen conflicts in terms of who is merging a specific PR, yet.
I add a short comment in the PR before starting to merge, if I fear that
somebody else might pick up the same one.
What can happen though is that the master changed while preparing a merge.
In that case you simply need to reba
Hey Nam-Luc,
I think your problem lies in the following line:
.returns("eu.euranova.flink.Centroid25")
If you do not specify the fields of the class in the String by using
"", the underlying parser will create an
"GenericTypeInfo" type information which then uses Kryo for serialization.
In
I see. Thanks for the replies guys!
I was just wondering how you manage not to get in conflicts or how you
decide who's responsible for what.
It seems that what you're doing works fine so far, so I'll try to do the
same.
If in doubt, I will ask again ;)
Cheers,
-V.
On 11 February 2015 at 17:52,
I have pushed a fix for that problem to the master (0.9) and have
cherry-picked it onto 0.8. Tests pending, should be green soon...
On Wed, Feb 11, 2015 at 11:29 AM, Ufuk Celebi wrote:
> -1
>
> The problem I've mentioned occurs for every shutdown of the
> job/taskmanagers using the scripts (bin/
Stephan Ewen created FLINK-1530:
---
Summary: Cache ExecutionConfig in AbstractInvokable
Key: FLINK-1530
URL: https://issues.apache.org/jira/browse/FLINK-1530
Project: Flink
Issue Type: Improvemen
Same here...
On Wed, Feb 11, 2015 at 5:13 PM, Stephan Ewen wrote:
> I think there are not yet any guidelines, other than what is here (
> https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+development+guidelines
> )
>
> I do it pretty much the same way as Fabian...
>
> On Wed, Feb 11,
Stephan Ewen created FLINK-1529:
---
Summary: Improve JobManager startup robustness
Key: FLINK-1529
URL: https://issues.apache.org/jira/browse/FLINK-1529
Project: Flink
Issue Type: Improvement
Hello Stephan,
Thank you for your help.
I ensured all the POJO classes used comply to what you previously said
and the same exception occurs. Here is the listing of classes
Centroid25 and Point25:
public class Centroid25 extends Point25 {
public int id;
public Centroid25() {}
public Centroid
Great news ! Congrats
On Wednesday, February 11, 2015, Stephan Ewen wrote:
> Hi everyone!
>
> I am happy to say that the graph library "Gelly" is finally in the code :-)
>
> Thanks Vasia, Daniel, Andra, and Carsten for the great work!
>
> Greetings,
> Stephan
>
I think there are not yet any guidelines, other than what is here (
https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+development+guidelines
)
I do it pretty much the same way as Fabian...
On Wed, Feb 11, 2015 at 5:06 PM, Fabian Hueske wrote:
> Hi Vasia,
>
> AFAIK, there is no merg
Hi Vasia,
AFAIK, there is no merging guide for committers.
I am doing this as follows:
- I am merging only code for components that I know well or where I am sure
to know the implications.
- If in doubt, I wait until another committer gives a +1
- I am merging my own code only if another committe
Awesome :-)
On Wed, Feb 11, 2015 at 4:27 PM, Paris Carbone wrote:
> Congratulations! Very exciting!
>
> Paris
>
> > On 11 Feb 2015, at 15:24, Ufuk Celebi wrote:
> >
> > Superb. :-)
> >
> > On 11 Feb 2015, at 15:00, Kostas Tzoumas wrote:
> >
> >> Nice!!! Welcome Gelly!
> >>
> >> On Wed, Feb 11,
Hello beautiful Flink people,
now that Gelly is in and I have moved to JIRA all our work-in-progress
issues, I feel I need to clarify some doubts I have :)
Basically, I was wondering whether there are guidelines or any kind of
policy regarding merging changes. Something similar to this maybe
http
Congratulations! Very exciting!
Paris
> On 11 Feb 2015, at 15:24, Ufuk Celebi wrote:
>
> Superb. :-)
>
> On 11 Feb 2015, at 15:00, Kostas Tzoumas wrote:
>
>> Nice!!! Welcome Gelly!
>>
>> On Wed, Feb 11, 2015 at 1:05 PM, Hermann Gábor wrote:
>>
>>> Cool! Congrats! :)
>>>
>>> On Wed Feb 11
Vasia Kalavri created FLINK-1528:
Summary: Add local clustering coefficient library method and
example
Key: FLINK-1528
URL: https://issues.apache.org/jira/browse/FLINK-1528
Project: Flink
Is
Robert Metzger created FLINK-1527:
-
Summary: Incomplete Accumulator documentation (no mention of the
shorthand methods)
Key: FLINK-1527
URL: https://issues.apache.org/jira/browse/FLINK-1527
Project: F
Vasia Kalavri created FLINK-1526:
Summary: Add Minimum Spanning Tree library method and example
Key: FLINK-1526
URL: https://issues.apache.org/jira/browse/FLINK-1526
Project: Flink
Issue Type
Robert Metzger created FLINK-1525:
-
Summary: Provide utils to pass -D parameters to UDFs
Key: FLINK-1525
URL: https://issues.apache.org/jira/browse/FLINK-1525
Project: Flink
Issue Type: Impr
Hi Tran Nam-Luc!
That is a problem we will look into.
In the meantime, can you try to modify your object such that it is a "Flink
POJO"? Then we will serialize it ourselves, without involving Kryo. To do
that, make sure that
- The class is public
- It has a public null-argument constructor
- A
Sergey Dudoladov created FLINK-1524:
---
Summary: Job Manager does not handle the RequestArchivedJobs
message
Key: FLINK-1524
URL: https://issues.apache.org/jira/browse/FLINK-1524
Project: Flink
Vasia Kalavri created FLINK-1523:
Summary: Vertex-centric iteration extensions
Key: FLINK-1523
URL: https://issues.apache.org/jira/browse/FLINK-1523
Project: Flink
Issue Type: Improvement
Vasia Kalavri created FLINK-1522:
Summary: Add tests for the library methods and examples
Key: FLINK-1522
URL: https://issues.apache.org/jira/browse/FLINK-1522
Project: Flink
Issue Type: New
Superb. :-)
On 11 Feb 2015, at 15:00, Kostas Tzoumas wrote:
> Nice!!! Welcome Gelly!
>
> On Wed, Feb 11, 2015 at 1:05 PM, Hermann Gábor wrote:
>
>> Cool! Congrats! :)
>>
>> On Wed Feb 11 2015 at 12:45:17 Max Michels wrote:
>>
>>> Great contribution! Thanks to everyone who made it possible.
Aljoscha Krettek created FLINK-1521:
---
Summary: Some Chained Drivers do not respect
object-reuse/non-reuse flag
Key: FLINK-1521
URL: https://issues.apache.org/jira/browse/FLINK-1521
Project: Flink
Vasia Kalavri created FLINK-1520:
Summary: Read edges and vertices from CSV files
Key: FLINK-1520
URL: https://issues.apache.org/jira/browse/FLINK-1520
Project: Flink
Issue Type: New Feature
I wrote them some time ago (like 12+ months) about the question whether we
can include TPCH sample data for our programs. They replied they were just
revising their license to allow that.
Should be possible now. Good idea to ping them again to make sure that it
is approved now and that it holds fo
Hello,
I came accross an error for which I am unable to retrace the exact cause.
Starting from flink-java-examples module, I have extended the KMeans example
to a case where points have 25 coordinates. It follows the exact same
structure and transformations as the original example, only with point
Ufuk Celebi created FLINK-1519:
--
Summary: Web frontend task state mismatch when cancelling
Key: FLINK-1519
URL: https://issues.apache.org/jira/browse/FLINK-1519
Project: Flink
Issue Type: Improv
Nice!!! Welcome Gelly!
On Wed, Feb 11, 2015 at 1:05 PM, Hermann Gábor wrote:
> Cool! Congrats! :)
>
> On Wed Feb 11 2015 at 12:45:17 Max Michels wrote:
>
> > Great contribution! Thanks to everyone who made it possible.
> >
> > On Wed, Feb 11, 2015 at 12:21 PM, Gyula Fóra wrote:
> > > Great!
>
Ufuk Celebi created FLINK-1518:
--
Summary: Laggy task cancelling on task managers
Key: FLINK-1518
URL: https://issues.apache.org/jira/browse/FLINK-1518
Project: Flink
Issue Type: Improvement
Okay, thank you. I'll write a mail to tpc.org and ask which rules we have
to respect.
On Wed, Feb 11, 2015 at 2:16 PM, Fabian Hueske wrote:
> +1 for reaching out to the TPC.
>
> It might also be that it is OK to add the code but not under the name
> TPC-H.
>
> 2015-02-11 13:55 GMT+01:00 Ufuk Cel
+1 for reaching out to the TPC.
It might also be that it is OK to add the code but not under the name TPC-H.
2015-02-11 13:55 GMT+01:00 Ufuk Celebi :
> Nice, this is a great tool. :)
>
> On 09 Feb 2015, at 17:05, Robert Metzger wrote:
>
> > However, the website is not really helpful:
> http://w
Gyula Fora created FLINK-1517:
-
Summary: Modify inputiterator for streaming so the channel index
of the last record is accessible
Key: FLINK-1517
URL: https://issues.apache.org/jira/browse/FLINK-1517
Proj
Nice, this is a great tool. :)
On 09 Feb 2015, at 17:05, Robert Metzger wrote:
> However, the website is not really helpful: http://www.tpc.org/trademarks/
>
> As one data point, the Apache Calcite (incubating) project also depends on
> the mentioned airlift/tpch repository:
> https://github.co
Great to hear.
On Wed, Feb 11, 2015 at 12:29 PM, Chesnay Schepler
wrote:
> Works now :) Thank you for your help.
>
>
> On 11.02.2015 11:39, Till Rohrmann wrote:
>
>> I found the error. Due to some refactoring, a wrong message was sent to
>> the
>> JobManager in the JobManagerInfoServlet.java. I
Works now :) Thank you for your help.
On 11.02.2015 11:39, Till Rohrmann wrote:
I found the error. Due to some refactoring, a wrong message was sent to the
JobManager in the JobManagerInfoServlet.java. I pushed a fix. Could you try
it out again?
On Wed, Feb 11, 2015 at 11:34 AM, Till Rohrmann
Robert Metzger created FLINK-1516:
-
Summary: JobManagerFailsITCase:
akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique!
Key: FLINK-1516
URL: https://issues.apache.org/jira/browse/FLINK-151
Cool! Congrats! :)
On Wed Feb 11 2015 at 12:45:17 Max Michels wrote:
> Great contribution! Thanks to everyone who made it possible.
>
> On Wed, Feb 11, 2015 at 12:21 PM, Gyula Fóra wrote:
> > Great!
> > Thank you guys :)
> >
> > On Wed, Feb 11, 2015 at 12:17 PM, Vasiliki Kalavri <
> > vasilikik
Wow! Great contribution!
Thanks you guys.
Regards.
Chiwan Park (Sent with iPhone)
> On Feb 11, 2015, at 8:44 PM, Max Michels wrote:
>
> Great contribution! Thanks to everyone who made it possible.
>
> On Wed, Feb 11, 2015 at 12:21 PM, Gyula Fóra wrote:
>> Great!
>> Thank you guys :)
>>
>> On
Vasia Kalavri created FLINK-1515:
Summary: [Gelly] Enable access to aggregators and broadcast sets
in vertex-centric iteration
Key: FLINK-1515
URL: https://issues.apache.org/jira/browse/FLINK-1515
Pro
Great contribution! Thanks to everyone who made it possible.
On Wed, Feb 11, 2015 at 12:21 PM, Gyula Fóra wrote:
> Great!
> Thank you guys :)
>
> On Wed, Feb 11, 2015 at 12:17 PM, Vasiliki Kalavri <
> vasilikikala...@gmail.com> wrote:
>
>> Hello everyone,
>>
>> I'm very happy ^^
>> Thank you for
Vasia Kalavri created FLINK-1514:
Summary: [Gelly] Add a Gather-Sum-Apply iteration method
Key: FLINK-1514
URL: https://issues.apache.org/jira/browse/FLINK-1514
Project: Flink
Issue Type: New
Great!
Thank you guys :)
On Wed, Feb 11, 2015 at 12:17 PM, Vasiliki Kalavri <
vasilikikala...@gmail.com> wrote:
> Hello everyone,
>
> I'm very happy ^^
> Thank you for reviewing and merging!
> And to everyone that was at the hackathon in Stockholm :)
>
> There's a lot more exciting stuff coming i
Hello everyone,
I'm very happy ^^
Thank you for reviewing and merging!
And to everyone that was at the hackathon in Stockholm :)
There's a lot more exciting stuff coming in Gelly soon!
Cheers,
V.
On 11 February 2015 at 12:11, Márton Balassi
wrote:
> Woot! :)
>
> On Wed, Feb 11, 2015 at 11:53
Woot! :)
On Wed, Feb 11, 2015 at 11:53 AM, Stephan Ewen wrote:
> Hi everyone!
>
> I am happy to say that the graph library "Gelly" is finally in the code :-)
>
> Thanks Vasia, Daniel, Andra, and Carsten for the great work!
>
> Greetings,
> Stephan
>
Indeed! Thanks for this fantastic contribution!
Cheers, Fabian
2015-02-11 11:53 GMT+01:00 Stephan Ewen :
> Hi everyone!
>
> I am happy to say that the graph library "Gelly" is finally in the code :-)
>
> Thanks Vasia, Daniel, Andra, and Carsten for the great work!
>
> Greetings,
> Stephan
>
Hi everyone!
I am happy to say that the graph library "Gelly" is finally in the code :-)
Thanks Vasia, Daniel, Andra, and Carsten for the great work!
Greetings,
Stephan
I found the error. Due to some refactoring, a wrong message was sent to the
JobManager in the JobManagerInfoServlet.java. I pushed a fix. Could you try
it out again?
On Wed, Feb 11, 2015 at 11:34 AM, Till Rohrmann
wrote:
> Could you check the rebasing because it seems as if the web server is now
Could you check the rebasing because it seems as if the web server is now
sending RequestArchivedJobs messages to the JobManager which should not
happen. These messages should go directly to the MemoryArchivist. The
corresponding file is JobManagerInfoServlet.java, I think.
On Wed, Feb 11, 2015 at
-1
The problem I've mentioned occurs for every shutdown of the job/taskmanagers
using the scripts (bin/stop-cluster.sh) and results in an exception at the end
of the log files.
On 11 Feb 2015, at 10:59, Ufuk Celebi wrote:
> There is a problem with a change added yesterday to master and relea
In our case we are actually waiting for some kind of acknowledgement events,
so it is easily verifiable if there are any further events. We check
whether everything
has been acknowledged.
On Tue Feb 10 2015 at 9:42:14 AM Ufuk Celebi wrote:
>
> On 10 Feb 2015, at 02:13, Hermann Gábor wrote:
>
>
I just tried Till's fix, rebased to the latest master and got a whole
lot of these exceptions right away:
java.lang.Exception: The slot in which the task was scheduled has been
killed (probably loss of TaskManager).
at
org.apache.flink.runtime.instance.SimpleSlot.cancel(SimpleSlot.java:98)
Stephan Ewen created FLINK-1513:
---
Summary: Remove GlobalConfiguration Singleton
Key: FLINK-1513
URL: https://issues.apache.org/jira/browse/FLINK-1513
Project: Flink
Issue Type: Improvement
There is a problem with a change added yesterday to master and release-0.8. See
here: https://github.com/apache/flink/pull/376
On 11 Feb 2015, at 01:10, Felix Neutatz wrote:
> +1
>
> + Built from source
> + tested some Protobuf examples
> + tested some Parquet examples
>
> Best regards,
> Fel
Robert Metzger created FLINK-1512:
-
Summary: Add CsvReader for reading into POJOs.
Key: FLINK-1512
URL: https://issues.apache.org/jira/browse/FLINK-1512
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-1511:
Summary: Scala classes not identified as Pojos
Key: FLINK-1511
URL: https://issues.apache.org/jira/browse/FLINK-1511
Project: Flink
Issue Type: Bug
Chesnay, could you try this again with Till's fix:
https://github.com/apache/flink/pull/378
The changes look good and I would like to merge it asap, but it would be nice
to double check with your problem. I will also run some tests.
– Ufuk
On 05 Feb 2015, at 10:42, Stephan Ewen wrote:
> I su
Robert Metzger created FLINK-1510:
-
Summary: Make AvroInputFormat splittable
Key: FLINK-1510
URL: https://issues.apache.org/jira/browse/FLINK-1510
Project: Flink
Issue Type: Improvement
66 matches
Mail list logo
