zhangjun0x01 edited a comment on issue #1437:
URL: https://github.com/apache/iceberg/issues/1437#issuecomment-698708665


   hi,@openinx 
   
   For example, I have a flink jar program, which consumes data from Kafka and 
writes it to iecberg table. If the jar package contains the local configuration 
path of hive, I upload the jar to the hdfs directory, and my startup command is 
as follows:
   
   ```
   /home/work/software/flink/bin/flink run-application -p 5 -d -t 
yarn-application  \
   -yD yarn.provided.lib.dirs="hdfs://hadoopcluster/data/flink/libs/" \
   hdfs://hadoopcluster/data/flink/user-lib/flink-kafka-iceberg.jar  
   ```
   
   In this mode, the user jar is parsed on the jobmanager node of the flink 
cluster. I think it may not be possible to load the local configuration file.
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to