Re: Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-03 Thread Robert Metzger
Hi Welly,

the fix has been merged and should be available in 0.10-SNAPSHOT.

On Wed, Dec 2, 2015 at 10:12 AM, Maximilian Michels  wrote:

> Hi Welly,
>
> We still have to decide on the next release date but I would expect
> Flink 0.10.2 within the next weeks. If you can't work around the union
> limitation, you may build your own Flink either from the master or the
> release-0.10 branch which will eventually be Flink 0.10.2.
>
> Cheers,
> Max
>
> On Tue, Dec 1, 2015 at 12:04 PM, Welly Tambunan  wrote:
> > Thanks a lot Aljoscha.
> >
> > When it will be released ?
> >
> > Cheers
> >
> > On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek 
> > wrote:
> >>
> >> Hi,
> >> I relaxed the restrictions on union. This should make it into an
> upcoming
> >> 0.10.2 bugfix release.
> >>
> >> Cheers,
> >> Aljoscha
> >> > On 01 Dec 2015, at 11:23, Welly Tambunan  wrote:
> >> >
> >> > Hi All,
> >> >
> >> > After upgrading our system to the latest version from 0.9 to 0.10.1 we
> >> > have this following error.
> >> >
> >> > Exception in thread "main" java.lang.UnsupportedOperationException: A
> >> > DataStream cannot be unioned with itself
> >> >
> >> > Then i find the relevant JIRA for this one.
> >> > https://issues.apache.org/jira/browse/FLINK-3080
> >> >
> >> > Is there any plan which release this will be ?
> >> >
> >> >
> >> > Another issue i have after upgrading is can't union with different
> level
> >> > of parallelism.
> >> >
> >> > I think we will need to fall back to 0.9 again for the time being.
> >> >
> >> > Cheers
> >> >
> >> > --
> >> > Welly Tambunan
> >> > Triplelands
> >> >
> >> > http://weltam.wordpress.com
> >> > http://www.triplelands.com
> >>
> >
> >
> >
> > --
> > Welly Tambunan
> > Triplelands
> >
> > http://weltam.wordpress.com
> > http://www.triplelands.com
>


Re: Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-02 Thread Maximilian Michels
Hi Welly,

We still have to decide on the next release date but I would expect
Flink 0.10.2 within the next weeks. If you can't work around the union
limitation, you may build your own Flink either from the master or the
release-0.10 branch which will eventually be Flink 0.10.2.

Cheers,
Max

On Tue, Dec 1, 2015 at 12:04 PM, Welly Tambunan  wrote:
> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek 
> wrote:
>>
>> Hi,
>> I relaxed the restrictions on union. This should make it into an upcoming
>> 0.10.2 bugfix release.
>>
>> Cheers,
>> Aljoscha
>> > On 01 Dec 2015, at 11:23, Welly Tambunan  wrote:
>> >
>> > Hi All,
>> >
>> > After upgrading our system to the latest version from 0.9 to 0.10.1 we
>> > have this following error.
>> >
>> > Exception in thread "main" java.lang.UnsupportedOperationException: A
>> > DataStream cannot be unioned with itself
>> >
>> > Then i find the relevant JIRA for this one.
>> > https://issues.apache.org/jira/browse/FLINK-3080
>> >
>> > Is there any plan which release this will be ?
>> >
>> >
>> > Another issue i have after upgrading is can't union with different level
>> > of parallelism.
>> >
>> > I think we will need to fall back to 0.9 again for the time being.
>> >
>> > Cheers
>> >
>> > --
>> > Welly Tambunan
>> > Triplelands
>> >
>> > http://weltam.wordpress.com
>> > http://www.triplelands.com
>>
>
>
>
> --
> Welly Tambunan
> Triplelands
>
> http://weltam.wordpress.com
> http://www.triplelands.com


Re: Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-01 Thread Welly Tambunan
Hi Aljoscha,

Is this fix has already been available on 0.10-SNAPSHOT ?


Cheers

On Tue, Dec 1, 2015 at 6:04 PM, Welly Tambunan  wrote:

> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek 
> wrote:
>
>> Hi,
>> I relaxed the restrictions on union. This should make it into an upcoming
>> 0.10.2 bugfix release.
>>
>> Cheers,
>> Aljoscha
>> > On 01 Dec 2015, at 11:23, Welly Tambunan  wrote:
>> >
>> > Hi All,
>> >
>> > After upgrading our system to the latest version from 0.9 to 0.10.1 we
>> have this following error.
>> >
>> > Exception in thread "main" java.lang.UnsupportedOperationException: A
>> DataStream cannot be unioned with itself
>> >
>> > Then i find the relevant JIRA for this one.
>> > https://issues.apache.org/jira/browse/FLINK-3080
>> >
>> > Is there any plan which release this will be ?
>> >
>> >
>> > Another issue i have after upgrading is can't union with different
>> level of parallelism.
>> >
>> > I think we will need to fall back to 0.9 again for the time being.
>> >
>> > Cheers
>> >
>> > --
>> > Welly Tambunan
>> > Triplelands
>> >
>> > http://weltam.wordpress.com
>> > http://www.triplelands.com
>>
>>
>
>
> --
> Welly Tambunan
> Triplelands
>
> http://weltam.wordpress.com
> http://www.triplelands.com 
>



-- 
Welly Tambunan
Triplelands

http://weltam.wordpress.com
http://www.triplelands.com 


Re: Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-01 Thread Robert Metzger
No, its not yet merged into the source repo of Flink.

You can find the code here: https://github.com/apache/flink/pull/1425
You can also check out the code of the PR or download the PR contents as a
patch and apply it to the Flink source.

I think the change will be merged tomorrow and then you'll have it in
0.10-SNAPSHOT.


For the 0.10.2 release: There are no concrete plans yet, but I think it'll
happen in the next 2-3 weeks.


On Tue, Dec 1, 2015 at 11:48 PM, Welly Tambunan  wrote:

> Hi Aljoscha,
>
> Is this fix has already been available on 0.10-SNAPSHOT ?
>
>
> Cheers
>
> On Tue, Dec 1, 2015 at 6:04 PM, Welly Tambunan  wrote:
>
>> Thanks a lot Aljoscha.
>>
>> When it will be released ?
>>
>> Cheers
>>
>> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek 
>> wrote:
>>
>>> Hi,
>>> I relaxed the restrictions on union. This should make it into an
>>> upcoming 0.10.2 bugfix release.
>>>
>>> Cheers,
>>> Aljoscha
>>> > On 01 Dec 2015, at 11:23, Welly Tambunan  wrote:
>>> >
>>> > Hi All,
>>> >
>>> > After upgrading our system to the latest version from 0.9 to 0.10.1 we
>>> have this following error.
>>> >
>>> > Exception in thread "main" java.lang.UnsupportedOperationException: A
>>> DataStream cannot be unioned with itself
>>> >
>>> > Then i find the relevant JIRA for this one.
>>> > https://issues.apache.org/jira/browse/FLINK-3080
>>> >
>>> > Is there any plan which release this will be ?
>>> >
>>> >
>>> > Another issue i have after upgrading is can't union with different
>>> level of parallelism.
>>> >
>>> > I think we will need to fall back to 0.9 again for the time being.
>>> >
>>> > Cheers
>>> >
>>> > --
>>> > Welly Tambunan
>>> > Triplelands
>>> >
>>> > http://weltam.wordpress.com
>>> > http://www.triplelands.com
>>>
>>>
>>
>>
>> --
>> Welly Tambunan
>> Triplelands
>>
>> http://weltam.wordpress.com
>> http://www.triplelands.com 
>>
>
>
>
> --
> Welly Tambunan
> Triplelands
>
> http://weltam.wordpress.com
> http://www.triplelands.com 
>


Re: Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-01 Thread Welly Tambunan
Ok Robert,

Thanks a lot.

Looking forward to it.


Cheers

On Wed, Dec 2, 2015 at 5:50 AM, Robert Metzger  wrote:

> No, its not yet merged into the source repo of Flink.
>
> You can find the code here: https://github.com/apache/flink/pull/1425
> You can also check out the code of the PR or download the PR contents as a
> patch and apply it to the Flink source.
>
> I think the change will be merged tomorrow and then you'll have it in
> 0.10-SNAPSHOT.
>
>
> For the 0.10.2 release: There are no concrete plans yet, but I think it'll
> happen in the next 2-3 weeks.
>
>
> On Tue, Dec 1, 2015 at 11:48 PM, Welly Tambunan  wrote:
>
>> Hi Aljoscha,
>>
>> Is this fix has already been available on 0.10-SNAPSHOT ?
>>
>>
>> Cheers
>>
>> On Tue, Dec 1, 2015 at 6:04 PM, Welly Tambunan  wrote:
>>
>>> Thanks a lot Aljoscha.
>>>
>>> When it will be released ?
>>>
>>> Cheers
>>>
>>> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek 
>>> wrote:
>>>
 Hi,
 I relaxed the restrictions on union. This should make it into an
 upcoming 0.10.2 bugfix release.

 Cheers,
 Aljoscha
 > On 01 Dec 2015, at 11:23, Welly Tambunan  wrote:
 >
 > Hi All,
 >
 > After upgrading our system to the latest version from 0.9 to 0.10.1
 we have this following error.
 >
 > Exception in thread "main" java.lang.UnsupportedOperationException: A
 DataStream cannot be unioned with itself
 >
 > Then i find the relevant JIRA for this one.
 > https://issues.apache.org/jira/browse/FLINK-3080
 >
 > Is there any plan which release this will be ?
 >
 >
 > Another issue i have after upgrading is can't union with different
 level of parallelism.
 >
 > I think we will need to fall back to 0.9 again for the time being.
 >
 > Cheers
 >
 > --
 > Welly Tambunan
 > Triplelands
 >
 > http://weltam.wordpress.com
 > http://www.triplelands.com


>>>
>>>
>>> --
>>> Welly Tambunan
>>> Triplelands
>>>
>>> http://weltam.wordpress.com
>>> http://www.triplelands.com 
>>>
>>
>>
>>
>> --
>> Welly Tambunan
>> Triplelands
>>
>> http://weltam.wordpress.com
>> http://www.triplelands.com 
>>
>
>


-- 
Welly Tambunan
Triplelands

http://weltam.wordpress.com
http://www.triplelands.com 


Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-01 Thread Welly Tambunan
Hi All,

After upgrading our system to the latest version from 0.9 to 0.10.1 we have
this following error.

Exception in thread "main" java.lang.UnsupportedOperationException: A
DataStream cannot be unioned with itself

Then i find the relevant JIRA for this one.
https://issues.apache.org/jira/browse/FLINK-3080

Is there any plan which release this will be ?


Another issue i have after upgrading is can't union with different level of
parallelism.

I think we will need to fall back to 0.9 again for the time being.

Cheers

-- 
Welly Tambunan
Triplelands

http://weltam.wordpress.com
http://www.triplelands.com 


Re: Data Stream union error after upgrading from 0.9 to 0.10.1

2015-12-01 Thread Welly Tambunan
Thanks a lot Aljoscha.

When it will be released ?

Cheers

On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek 
wrote:

> Hi,
> I relaxed the restrictions on union. This should make it into an upcoming
> 0.10.2 bugfix release.
>
> Cheers,
> Aljoscha
> > On 01 Dec 2015, at 11:23, Welly Tambunan  wrote:
> >
> > Hi All,
> >
> > After upgrading our system to the latest version from 0.9 to 0.10.1 we
> have this following error.
> >
> > Exception in thread "main" java.lang.UnsupportedOperationException: A
> DataStream cannot be unioned with itself
> >
> > Then i find the relevant JIRA for this one.
> > https://issues.apache.org/jira/browse/FLINK-3080
> >
> > Is there any plan which release this will be ?
> >
> >
> > Another issue i have after upgrading is can't union with different level
> of parallelism.
> >
> > I think we will need to fall back to 0.9 again for the time being.
> >
> > Cheers
> >
> > --
> > Welly Tambunan
> > Triplelands
> >
> > http://weltam.wordpress.com
> > http://www.triplelands.com
>
>


-- 
Welly Tambunan
Triplelands

http://weltam.wordpress.com
http://www.triplelands.com