Hi Miki,
Thanks for your reply. ParameterTool will only help in making the value
accessible through ParameterTool.get(). However, I need a way of accessing
the value using "System.getenv" since the underlying library uses it so.

On Sat, 24 Aug 2019 at 23:04, miki haiat <miko5...@gmail.com> wrote:

> Did you register your system environment parameter ?
>
> You can find here several ways to use configuration data [1]
>
> 1.
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/best_practices.html
>
>
> On Sat, Aug 24, 2019, 20:26 Abhishek Jain <abhijai...@gmail.com> wrote:
>
>> Hi!
>>
>> I am using a library that depends on a certain environment variable set
>> (mandatorily). Now, I've exported this variable in my environment but
>> somehow it's not being read by the task manager. Following is the exception
>> I get when I try to run the job:
>>
>> Caused by: com.example.MyCustomException: Env token is null
>> at com.example.AerospikeSink.open(AerospikeSink.java:47)
>> at
>> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
>> at
>> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
>> at
>> org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
>> at
>> org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424)
>> at
>> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290)
>> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
>> at java.lang.Thread.run(Thread.java:745)
>>
>> Here's the code that throws this exception:
>>
>> @Override
>> public void open(Configuration config) throws Exception {
>>     if (System.getenv("API_TOKEN") == null) {
>>         throw new MyCustomException("Env token is null");
>>     }
>> }
>>
>> My question: Is there an alternative to System.getenv() that I can use to
>> access environment variables inside of flink task?
>>
>> ( P.S. I've only copied relevant code snippet to avoid confusion. I do
>> intend to use API_TOKEN later on. )
>>
>> --
>> Warm Regards,
>> Abhishek Jain
>>
>

-- 
Warm Regards,
Abhishek Jain

Reply via email to