2
데이터베이스에서 사용할 수있는 특정 규칙에 따라 하나의 원시 데이터 스트림에서 새 데이터 스트림을 만들려고합니다. 일단 플린 크 작업을 시작한 후에 데이터베이스의 업데이트 된 항목에 따라 새로운 데이터 스트림을 작성해야한다면 어떻게 할 수 있습니까? 그래서 여기서는 Flink 작업을 다시 시작하지 않고 런타임에 동적으로 새로운 데이터 스트림을 만들고이를 실행 DAG에 추가하려고합니다.Flink에서 동적으로 새 데이터 스트림 만들기
왜 이것이 가능하지 않은지 설명 할 수 있습니까? 런타임시 작업 변경을 허용하지 않는 것이 아키텍처상의 결정입니까? –
디자인 결정입니다. 이 기능을 허용하는 것은 꽤 복잡합니다. 이 기능을 사용하려면 Flink 메일 링리스트에서 토론을 시작하십시오. 그러나 공동체가이 기능을 결정한다고해도 사용할 수있을 때까지 수개월이 걸릴 것으로 예상됩니다. –