[ https://issues.apache.org/jira/browse/FLINK-9893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aleksandr Filichkin updated FLINK-9893: --------------------------------------- Description: The problem is I cannot run it in IDE when I have more than 1 taskslot in my job. {code:java} public class StreamingJob { public static void main(String[] args) throws Exception { // set up the streaming execution environment final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); Properties kafkaProperties = new Properties(); kafkaProperties.setProperty("bootstrap.servers", "localhost:9092"); kafkaProperties.setProperty("group.id", "test"); env.setParallelism(1); DataStream<String> kafkaSource = env.addSource(new FlinkKafkaConsumer010<>("flink-source", new SimpleStringSchema(),kafkaProperties)).name("Kafka-Source").slotSharingGroup("Kafka-Source"); kafkaSource.print().slotSharingGroup("Print"); env.execute("Flink Streaming Java API Skeleton"); } } {code} I know that job need 2 slot for this job and I can have two taskmanagers in Flink cluster, but how can I run it locally in IDE. Currently I have to specify the same slotSharingGroup name for all operator locally to have one slot. But it's not flexible. How do you handle it? was: The problem is I cannot run it in IDE when I have more than 1 taskslot in my job. public class StreamingJob { {quote}public static void main(String[] args) throws Exception { // set up the streaming execution environment final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); Properties kafkaProperties = new Properties(); kafkaProperties.setProperty("bootstrap.servers", "localhost:9092"); kafkaProperties.setProperty("group.id", "test"); env.setParallelism(1); DataStream<String> kafkaSource = env.addSource(new FlinkKafkaConsumer010<>("flink-source", new SimpleStringSchema(),kafkaProperties)).name("Kafka-Source").slotSharingGroup("Kafka-Source"); kafkaSource.print().slotSharingGroup("Print"); env.execute("Flink Streaming Java API Skeleton"); } }{quote} I know that job need 2 slot for this job and I can have two taskmanagers in Flink cluster, but how can I run it locally in IDE. Currently I have to specify the same slotSharingGroup name for all operator locally to have one slot. But it's not flexible. How do you handle it? > Cannot run Flink job in IDE when we have more than 1 taskslot > ------------------------------------------------------------- > > Key: FLINK-9893 > URL: https://issues.apache.org/jira/browse/FLINK-9893 > Project: Flink > Issue Type: Wish > Components: Streaming > Affects Versions: 1.5.1 > Reporter: Aleksandr Filichkin > Priority: Major > > The problem is I cannot run it in IDE when I have more than 1 taskslot in my > job. > {code:java} > public class StreamingJob { > public static void main(String[] args) throws Exception { > // set up the streaming execution environment > final StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > Properties kafkaProperties = new Properties(); > kafkaProperties.setProperty("bootstrap.servers", "localhost:9092"); > kafkaProperties.setProperty("group.id", "test"); > env.setParallelism(1); > DataStream<String> kafkaSource = env.addSource(new > FlinkKafkaConsumer010<>("flink-source", new > SimpleStringSchema(),kafkaProperties)).name("Kafka-Source").slotSharingGroup("Kafka-Source"); > kafkaSource.print().slotSharingGroup("Print"); > env.execute("Flink Streaming Java API Skeleton"); > } > } > {code} > I know that job need 2 slot for this job and I can have two taskmanagers in > Flink cluster, but how can I run it locally in IDE. > Currently I have to specify the same slotSharingGroup name for all operator > locally to have one slot. But it's not flexible. > How do you handle it? -- This message was sent by Atlassian JIRA (v7.6.3#76005)