Thanks Dan. Built perfect with 0.2.0....Cheers
From: Dan Halperin <[email protected]>
To: [email protected]; amir bahmanyari <[email protected]>
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 <[email protected]> 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>
