Hi Fred,
This is hard to debug without further information. Maybe a stack trace
would help. Are you sure the config is also located on the remote cluster?
Thanks,
Max
On 03.11.18 15:45, K Fred wrote:
Hi,
I am running into a very strange issue that
'Could not find a "KafkaClient" entry in the JAAS configuration. System
property "java.security.auth.login.config" is
/etc/kafka/kafka_sink_jaas.conf'
on a single node flink cluster when i consume record from kafka using
beam KafkaIO.
The JAAS file contains 'KafkaClient', but the flink cluster cannot find
the entry. Does anyone know the reason caused?
Thanks!
--
Fred
