You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by amir bahmanyari <am...@yahoo.com> on 2016/08/16 00:52:57 UTC

Some Compilation errors

Hi Colleagues,I am re-building my work from the scratch for a final target delivery.I installed all the latest and the greatest, and upgraded my POM dependencies, but I get compilation errors when I build my current code.Following is my new <dependencies> tag and their corresponding compilation errors I get.Thanks for your feedback.
<dependencies><!-- this works as is. If I change it to 0.2.0-incubating, I get this error:cannot find symbol[ERROR] symbol:   method named(java.lang.String)[ERROR] location: class org.apache.beam.sdk.transforms.ParDo--><dependency>
   <groupId>org.apache.beam</groupId>   <artifactId>beam-runners-core-java</artifactId>   <version>0.1.0-incubating</version></dependency>



<!-- OK. Compiles with both 0.1.0 & 0.2.0. No issue here -->
<dependency>    <groupId>org.apache.beam</groupId>    <artifactId>beam-sdks-java-io-kafka</artifactId>    <version>0.2.0-incubating</version></dependency>


<!-- Compiles with 0.1.0-incubating as is below. It throws the following error at compile time if changed to 0.2.0-incubating:  
cannot find symbol[ERROR] symbol:   class FlinkPipelineRunner-->
<dependency>    <groupId>org.apache.beam</groupId>    <artifactId>beam-runners-flink_2.10</artifactId>    <version>0.1.0-incubating</version></dependency> 
</dependencies>

Re: Some Compilation errors

Posted by amir bahmanyari <am...@yahoo.com>.

Thanks Dan. Built perfect with 0.2.0....Cheers

      From: Dan Halperin <dh...@google.com>
 To: user@beam.incubator.apache.org; amir bahmanyari <am...@yahoo.com> 
 Sent: Monday, August 15, 2016 5:57 PM
 Subject: Re: Some Compilation errors

Hi Amir,
The ParDo.named(string) method has been dropped in 0.2.0-incubating. Instead, you should use p.apply("name", ParDo.of(DoFn)).
See https://issues.apache.org/jira/browse/BEAM-370
Sorry to be disrupting your work with backwards-incompatible changes, but we're trying to get them all in early (well before we declare our first major release).
Thanks,Dan
On Mon, Aug 15, 2016 at 5:52 PM, amir bahmanyari <am...@yahoo.com> wrote:

Hi Colleagues,I am re-building my work from the scratch for a final target delivery.I installed all the latest and the greatest, and upgraded my POM dependencies, but I get compilation errors when I build my current code.Following is my new <dependencies> tag and their corresponding compilation errors I get.Thanks for your feedback.
<dependencies><dependency>
   <groupId>org.apache.beam</ groupId>   <artifactId>beam-runners- core-java</artifactId>   <version>0.1.0-incubating</ version></dependency>

<dependency>    <groupId>org.apache.beam</ groupId>    <artifactId>beam-sdks-java-io- kafka</artifactId>    <version>0.2.0-incubating</ version></dependency>

<dependency>    <groupId>org.apache.beam</ groupId>    <artifactId>beam-runners- flink_2.10</artifactId>    <version>0.1.0-incubating</ version></dependency> 
</dependencies>

Re: Some Compilation errors

Posted by Dan Halperin <dh...@google.com>.

Hi Amir,

The *ParDo.named(string)* method has been dropped in 0.2.0-incubating.
Instead, you should use p.apply("name", ParDo.of(DoFn)).

See https://issues.apache.org/jira/browse/BEAM-370

Sorry to be disrupting your work with backwards-incompatible changes, but
we're trying to get them all in early (well before we declare our first
major release).

Thanks,
Dan

On Mon, Aug 15, 2016 at 5:52 PM, amir bahmanyari <am...@yahoo.com>
wrote:

> Hi Colleagues,
> I am re-building my work from the scratch for a final target delivery.
> I installed all the latest and the greatest, and upgraded my POM
> dependencies, but I get compilation errors when I build my current code.
> Following is my new <dependencies> tag and their corresponding compilation
> errors I get.
> Thanks for your feedback.
>
> <dependencies>
> <!-- this works as is. If I change it to 0.*2*.0-incubating, I get this
> error:
> cannot find symbol
> [ERROR] symbol:   method named(java.lang.String)
> [*ERROR] location: class org.apache.beam.sdk.transforms.ParDo*
> -->
> <dependency>
>    <groupId>org.apache.beam</groupId>
>    <artifactId>beam-runners-core-java</artifactId>
>    <version>0.1.0-incubating</version>
> </dependency>
>
>
>
>
> <!-- OK. Compiles with both 0.1.0 & 0.2.0. No issue here -->
> <dependency>
>     <groupId>org.apache.beam</groupId>
>     <artifactId>beam-sdks-java-io-kafka</artifactId>
>     <version>0.2.0-incubating</version>
> </dependency>
>
>
>
> <!-- Compiles with 0.1.0-incubating as is below. It throws the following
> error at compile time if changed to 0.*2*.0-incubating:
>
> cannot find symbol
> *[ERROR] symbol:   class FlinkPipelineRunner*
> -->
> <dependency>
>     <groupId>org.apache.beam</groupId>
>     <artifactId>beam-runners-flink_2.10</artifactId>
>     <version>0.1.0-incubating</version>
> </dependency>
>
> </dependencies>
>
>

Re: Some Compilation errors

Posted by Emanuele Cesena <em...@shopkick.com>.

Hi Amir,

FlinkPipelineRunner has been renamed FlinkRunner, you have to change your source code.

Something similar for the ParDo, it should be documented somewhere in the release notes (sorry, can't check, I'm on the go).

Best,
-- 
Emanuele Cesena
<em...@gmail.com>

Il corpo non ha ideali

> On Aug 15, 2016, at 17:52, amir bahmanyari <am...@yahoo.com> wrote:
> 
> Hi Colleagues,
> I am re-building my work from the scratch for a final target delivery.
> I installed all the latest and the greatest, and upgraded my POM dependencies, but I get compilation errors when I build my current code.
> Following is my new <dependencies> tag and their corresponding compilation errors I get.
> Thanks for your feedback.
> 
> <dependencies>
> <!-- this works as is. If I change it to 0.2.0-incubating, I get this error:
> cannot find symbol
> [ERROR] symbol:   method named(java.lang.String)
> [ERROR] location: class org.apache.beam.sdk.transforms.ParDo
> -->
> <dependency>
>    <groupId>org.apache.beam</groupId>
>    <artifactId>beam-runners-core-java</artifactId>
>    <version>0.1.0-incubating</version>
> </dependency>
> 
> 
> 
> 
> <!-- OK. Compiles with both 0.1.0 & 0.2.0. No issue here -->
> <dependency>
>     <groupId>org.apache.beam</groupId>
>     <artifactId>beam-sdks-java-io-kafka</artifactId>
>     <version>0.2.0-incubating</version>
> </dependency>
> 
> 
> 
> <!-- Compiles with 0.1.0-incubating as is below. It throws the following error at compile time if changed to 0.2.0-incubating:  
> 
> cannot find symbol
> [ERROR] symbol:   class FlinkPipelineRunner
> -->
> <dependency>
>     <groupId>org.apache.beam</groupId>
>     <artifactId>beam-runners-flink_2.10</artifactId>
>     <version>0.1.0-incubating</version>
> </dependency>
>  
> </dependencies>
>