2016-12-05 14:50 GMT+04:00 Maximilian Michels <m...@apache.org
<mailto:m...@apache.org>>:
>>
>> Hi Wayne,
>>
>> That seems like you ran that from the IDE. I'm interested how
the output
>> would look like on the cluster where y
Maximilian Michels wrote:
Hi Wayne,
That seems like you ran that from the IDE. I'm interested how the
output would look like on the cluster where you experienced your problems.
Thanks,
Max
On Fri, Dec 2, 2016 at 7:27 PM, Wayne Collins <wayn...@dades.ca
<mailto:wayn...@dades.ca>&g
ould give us a hint from where the Guava library is bootstrapped.
Thanks,
Max
On Thu, Dec 1, 2016 at 7:54 PM, Wayne Collins <wayn...@dades.ca> wrote:
Hi Max,
Here is the result from the "flink run" launcher node (devbox):
---
root@devbox:~# echo
${HADOOP
following on the nodes? I have a suspision
that something sneaks in from one of the classpath variables that
Flink picks up:
echo ${HADOOP_CLASSPATH}:${HADOOP_CONF_DIR}:${YARN_CONF_DIR}:${HBASE_CONF_DIR}
On Tue, Nov 29, 2016 at 9:17 PM, Wayne Collins <wayn...@dades.ca> wrote:
Hi Max,
I re
Hi Stephen,
Thanks for the suggestions!
I had come to the same conclusion but haven't been able to shade or set
"provides" to work around it.
The "mvn dependency:tree" looks good to me...
Can anyone share a pom dependencies/exclusions fragment that is working
for them with KafkaIO on a
Hi,
I have run into an issue with launching Beam applications that use
KafkaIO on a flink cluster:
"java.lang.IllegalAccessError: tried to access method
com.google.common.base.Optional.()V from class
com.google.common.base.Absent"
(full output, and pom.xml below)
Other Beam applications
