Thanks Stephan,what you said really solved the problem.
Previously I build Flink against a vendor specific Hadoop version and my
Maven version is 3.3.9.
Thanks,
Liu
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Fwd-Flink-application-and
Hi Liu!
Did you build Flink from the source yourself?
Maybe you run into the Maven shading problem described here:
https://github.com/apache/flink/blob/master/docs/setup/building.md#dependency-shading
Best,
Stephan
On Tue, Nov 22, 2016 at 8:03 PM, Fabian Hueske wrote:
> This looks rather lik
This looks rather like a version conflict. If Curator wasn't on the
classpath it should be a ClassNotFoundException.
Can you check if any of your jobs dependencies depends on a different
Curator version?
Best, Fabian
2016-11-22 12:06 GMT+01:00 Maximilian Michels :
> As far as I know we're shadi
As far as I know we're shading Curator so you shouldn't run into class
conflicts. Have you checked that Curator is included in your jar?
-Max
On Tue, Nov 22, 2016 at 9:30 AM, Liu Tongwei wrote:
> Hi all，
>
> I'm using flink 1.1.3. I need to use the curator inside the application to
> operate zo
