You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Welly Tambunan <if...@gmail.com> on 2015/12/01 11:23:48 UTC
Data Stream union error after upgrading from 0.9 to 0.10.1
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 <http://www.triplelands.com/blog/>
Re: Data Stream union error after upgrading from 0.9 to 0.10.1
Posted by Welly Tambunan <if...@gmail.com>.
Hi Robert,
Thanks for the update.
We will update to this version.
Cheers
On Thu, Dec 3, 2015 at 3:49 PM, Robert Metzger <rm...@apache.org> wrote:
> 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 <mx...@apache.org>
> 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 <if...@gmail.com>
>> wrote:
>> > Thanks a lot Aljoscha.
>> >
>> > When it will be released ?
>> >
>> > Cheers
>> >
>> > On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
>> > 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 <if...@gmail.com> 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 <http://www.triplelands.com/blog/>
Re: Data Stream union error after upgrading from 0.9 to 0.10.1
Posted by Robert Metzger <rm...@apache.org>.
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 <mx...@apache.org> 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 <if...@gmail.com> wrote:
> > Thanks a lot Aljoscha.
> >
> > When it will be released ?
> >
> > Cheers
> >
> > On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
> > 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 <if...@gmail.com> 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
Posted by Maximilian Michels <mx...@apache.org>.
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 <if...@gmail.com> wrote:
> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
> 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 <if...@gmail.com> 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
Posted by Welly Tambunan <if...@gmail.com>.
Ok Robert,
Thanks a lot.
Looking forward to it.
Cheers
On Wed, Dec 2, 2015 at 5:50 AM, Robert Metzger <rm...@apache.org> 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 <if...@gmail.com> 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 <if...@gmail.com> wrote:
>>
>>> Thanks a lot Aljoscha.
>>>
>>> When it will be released ?
>>>
>>> Cheers
>>>
>>> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
>>> 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 <if...@gmail.com> 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 <http://www.triplelands.com/blog/>
>>>
>>
>>
>>
>> --
>> Welly Tambunan
>> Triplelands
>>
>> http://weltam.wordpress.com
>> http://www.triplelands.com <http://www.triplelands.com/blog/>
>>
>
>
--
Welly Tambunan
Triplelands
http://weltam.wordpress.com
http://www.triplelands.com <http://www.triplelands.com/blog/>
Re: Data Stream union error after upgrading from 0.9 to 0.10.1
Posted by Robert Metzger <rm...@apache.org>.
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 <if...@gmail.com> 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 <if...@gmail.com> wrote:
>
>> Thanks a lot Aljoscha.
>>
>> When it will be released ?
>>
>> Cheers
>>
>> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
>> 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 <if...@gmail.com> 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 <http://www.triplelands.com/blog/>
>>
>
>
>
> --
> Welly Tambunan
> Triplelands
>
> http://weltam.wordpress.com
> http://www.triplelands.com <http://www.triplelands.com/blog/>
>
Re: Data Stream union error after upgrading from 0.9 to 0.10.1
Posted by Welly Tambunan <if...@gmail.com>.
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 <if...@gmail.com> wrote:
> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
> 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 <if...@gmail.com> 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 <http://www.triplelands.com/blog/>
>
--
Welly Tambunan
Triplelands
http://weltam.wordpress.com
http://www.triplelands.com <http://www.triplelands.com/blog/>
Re: Data Stream union error after upgrading from 0.9 to 0.10.1
Posted by Welly Tambunan <if...@gmail.com>.
Thanks a lot Aljoscha.
When it will be released ?
Cheers
On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <al...@apache.org>
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 <if...@gmail.com> 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 <http://www.triplelands.com/blog/>
Re: Data Stream union error after upgrading from 0.9 to 0.10.1
Posted by Aljoscha Krettek <al...@apache.org>.
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 <if...@gmail.com> 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