新聞中心
可以,在提交 Flink Application 模式時(shí),可以通過設(shè)置 -D 參數(shù)來添加環(huán)境變量。在 Flink 應(yīng)用程序模式提交時(shí),可以加環(huán)境變量,以下是詳細(xì)說明:

十年的固鎮(zhèn)網(wǎng)站建設(shè)經(jīng)驗(yàn),針對(duì)設(shè)計(jì)、前端、開發(fā)、售后、文案、推廣等六對(duì)一服務(wù),響應(yīng)快,48小時(shí)及時(shí)工作處理。全網(wǎng)整合營銷推廣的優(yōu)勢是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同,自動(dòng)調(diào)整固鎮(zhèn)建站的顯示方式,使網(wǎng)站能夠適用不同顯示終端,在瀏覽器中調(diào)整網(wǎng)站的寬度,無論在任何一種瀏覽器上瀏覽網(wǎng)站,都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì),從而大程度地提升瀏覽體驗(yàn)。創(chuàng)新互聯(lián)建站從事“固鎮(zhèn)網(wǎng)站設(shè)計(jì)”,“固鎮(zhèn)網(wǎng)站推廣”以來,每個(gè)客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。
1、使用 D 參數(shù)設(shè)置環(huán)境變量
在提交 Flink 作業(yè)時(shí),可以使用 D 參數(shù)為作業(yè)設(shè)置環(huán)境變量。
./bin/flink run Dmy.env.var=value my_job.jar
這里,my.env.var 是環(huán)境變量的名稱,value 是環(huán)境變量的值,在作業(yè)中,可以通過 System.getenv() 方法獲取環(huán)境變量的值。
2、使用 conf 參數(shù)設(shè)置全局環(huán)境變量
除了為單個(gè)作業(yè)設(shè)置環(huán)境變量外,還可以使用 conf 參數(shù)為整個(gè) Flink 集群設(shè)置全局環(huán)境變量。
./bin/flink run conf 'my.env.var=value' my_job.jar
這里,my.env.var 是環(huán)境變量的名稱,value 是環(huán)境變量的值,在作業(yè)中,可以通過 System.getenv() 方法獲取環(huán)境變量的值,這個(gè)環(huán)境變量也會(huì)被應(yīng)用到整個(gè) Flink 集群的所有作業(yè)中。
3、使用 Dkey=value 設(shè)置 JVM 系統(tǒng)屬性
如果需要設(shè)置的是 JVM 系統(tǒng)屬性(而非 Flink 特定的環(huán)境變量),可以使用 D 參數(shù)。
./bin/flink run Djava.runtime.version=1.8 my_job.jar
這里,java.runtime.version 是 JVM 系統(tǒng)屬性的名稱,1.8 是系統(tǒng)屬性的值,在作業(yè)中,可以通過 System.getProperty() 方法獲取 JVM 系統(tǒng)屬性的值。
分享名稱:flinkapplication模式提交的時(shí)候,能加環(huán)境變量嗎?
分享地址:http://www.dlmjj.cn/article/djopiio.html


咨詢
建站咨詢
