在Flink中動態創建新的數據流

我試圖根據數據庫中的某些可用規則從一個原始數據流中創建新的數據流。一旦我開始Flink作業，並且在一些之後，如果我需要根據數據庫中更新的條目創建新的數據流，我該如何實現這一點。所以在這裏，我不想重新啓動Flink作業，而是在運行時動態創建新的數據流並將其添加到執行DAG。在Flink中動態創建新的數據流

來源

2016-06-27 Anand Shaw

簡答：這在運行時不可行。

您需要停止工作並提交新工作。

來源

2016-06-28 10:19:03

你能解釋爲什麼這是不可能的嗎？是否允許在運行時更改作業的架構決策？ –

這是一個設計決定。考慮到這個功能是相當複雜的。如果您想擁有此功能，您可能需要在Flink郵件列表上開始討論。但即使社區決定採用這一功能，我預計它需要幾個月才能提供。 –

在Flink中動態創建新的數據流

回答

相關問題