Hi guys, I am trying to write to hdfs from streaming file sink. Where should I provide the IP address of the name node ? Can I provide it as a part of the flink-config.yaml file or should I provide it like this :
final StreamingFileSink<GenericRecord> sink = StreamingFileSink
.forBulkFormat(hdfs://namenode:8020/flink/test,
ParquetAvroWriters.forGenericRecord(schema))
.build();
Best,
Nick
