[jira] [Created] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure

2015-08-01 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2460: -- Summary: ReduceOnNeighborsWithExceptionITCase failure Key: FLINK-2460 URL: https://issues.apache.org/jira/browse/FLINK-2460 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2459) Failure on recently added Client side logging test

2015-08-01 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2459: -- Summary: Failure on recently added Client side logging test Key: FLINK-2459 URL: https://issues.apache.org/jira/browse/FLINK-2459 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2458) Distributed Cache doesn't work with iterations.

2015-08-01 Thread Sachin Goel (JIRA)
Sachin Goel created FLINK-2458: -- Summary: Distributed Cache doesn't work with iterations. Key: FLINK-2458 URL: https://issues.apache.org/jira/browse/FLINK-2458 Project: Flink Issue Type: Bug

Re: Tuple

2015-08-01 Thread Stephan Ewen
I think a Tuple0 cannot be implemented like the current tuples, at least with respect to runtime serialization. The system makes the assumption that it makes progress in consuming bytes when deserializing values. If a Tuple= never consumes data from the byte stream, this assumption is broken. It w

Re: Tuple

2015-08-01 Thread Matthias J. Sax
I just double checked. Scala does not have type Tuple0. IMHO, it would be best to remove Tuple0 for consistency. Having Tuple types is for consistency reason with Scala in the first place, right? Please give feedback. -Matthias On 08/01/2015 01:04 PM, Matthias J. Sax wrote: > I see. > > I think

[jira] [Created] (FLINK-2457) Tuple.getTupleClass cannot generate Tuple0

2015-08-01 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2457: -- Summary: Tuple.getTupleClass cannot generate Tuple0 Key: FLINK-2457 URL: https://issues.apache.org/jira/browse/FLINK-2457 Project: Flink Issue Type: Impr

Re: Tuple

2015-08-01 Thread Chesnay Schepler
yes, if it is present in the core flink files it must work just as any tuple in flink. removing is not an option though; but moving is. The Python API uses it (that's the reason Tuple0 was added in the first place). On 01.08.2015 13:04, Matthias J. Sax wrote: I see. I think that it might be

Re: Tuple

2015-08-01 Thread Matthias J. Sax
I see. I think that it might be useful to have Tuple0, because in rare cases, you only want to "notify" a downstream operators (taking about streaming) that something happened but there is no actual data to be processed. Furthermore, if Flink cannot deal with Tuple0 it should be removed completely

[jira] [Created] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID

2015-08-01 Thread Huang Wei (JIRA)
Huang Wei created FLINK-2456: Summary: The flink-hbase module dependencies hadoop-2 specifies a repository ID Key: FLINK-2456 URL: https://issues.apache.org/jira/browse/FLINK-2456 Project: Flink