Hi Team, I am getting the following error while running DataStream API in with batch mode with kafka source. I am using FlinkKafkaConsumer to consume the data.
Caused by: java.lang.IllegalStateException: Detected an UNBOUNDED source with the 'execution.runtime-mode' set to 'BATCH'. This combination is not allowed, please set the 'execution.runtime-mode' to STREAMING or AUTOMATIC at org.apache.flink.util.Preconditions.checkState(Preconditions.java:198) ~[flink-core-1.12.0.jar:1.12.0] In my batch program I wanted to work with four to five different stream in batch mode as data source is bounded I don't find any clear example of how to do it with kafka souce with Flink 1.12 I don't want to use JDBC source as underlying database table may change. please give me some example on how to achieve the above use case. Also for any large bounded source are there any alternatives to achieve this? -- ---Regards--- Sagar Bandal This is confidential mail ,All Rights are Reserved.If you are not intended receipiant please ignore this email.
