Data Stream union error after upgrading from 0.9 to 0.10.1

[tambunanw]

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

--

[Aljoscha Krettek]

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 <[hidden email]> 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

[tambunanw]

Thanks a lot Aljoscha. 

When it will be released ? 

Cheers

On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]> 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 <[hidden email]> 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

--

[tambunanw]

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 <[hidden email]> wrote:

Thanks a lot Aljoscha. 

When it will be released ? 

Cheers

On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]> 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 <[hidden email]> 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

--

[rmetzger0]

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 <[hidden email]> 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 <[hidden email]> wrote:

Thanks a lot Aljoscha. 

When it will be released ? 

Cheers

On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]> 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 <[hidden email]> 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

[tambunanw]

Ok Robert, 

Thanks a lot. 

Looking forward to it. 

Cheers

On Wed, Dec 2, 2015 at 5:50 AM, Robert Metzger <[hidden email]> 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 <[hidden email]> 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 <[hidden email]> wrote:

Thanks a lot Aljoscha. 

When it will be released ? 

Cheers

On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]> 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 <[hidden email]> 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

--

[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 <[hidden email]> wrote:

> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]>
> 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 <[hidden email]> 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

[rmetzger0]

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 <[hidden email]> 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 <[hidden email]> wrote:
> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]>
> 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 <[hidden email]> 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

[tambunanw]

Hi Robert, 

Thanks for the update. 

We will update to this version.

Cheers

On Thu, Dec 3, 2015 at 3:49 PM, Robert Metzger <[hidden email]> 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 <[hidden email]> 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 <[hidden email]> wrote:
> Thanks a lot Aljoscha.
>
> When it will be released ?
>
> Cheers
>
> On Tue, Dec 1, 2015 at 5:48 PM, Aljoscha Krettek <[hidden email]>
> 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 <[hidden email]> 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

--