Re: How to run in IDE?
We will need more of the logs contents to help you (preferably the whole thing. On 25/01/2022 23:55, John Smith wrote: I'm using: final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); But no go. On Mon, 24 Jan 2022 at 16:35, John Smith wrote: Hi using Flink 1.14.3 with gradle. I explicitly added the flink client dependency and the job starts but it quits with... In Flink 1.10 the job worked as is. How do I set the number of slots and is there any other settings for the IDE? 16:29:50,633 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager - Received resource requirements from job 3a3e9c46da413071392bce161c39270f: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=2}] 16:29:50,633 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std. Out (14/16) (d7c4fbf5f23f3118e54998f2b35338c1) switched from CANCELING to CANCELED.
Re: How to run in IDE?
I'm using: final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); But no go. On Mon, 24 Jan 2022 at 16:35, John Smith wrote: > Hi using Flink 1.14.3 with gradle. I explicitly added the flink client > dependency and the job starts but it quits with... > > In Flink 1.10 the job worked as is. How do I set the number of slots and > is there any other settings for the IDE? > > 16:29:50,633 INFO > org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager > - Received resource requirements from job > 3a3e9c46da413071392bce161c39270f: > [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, > numberOfRequiredSlots=2}] > 16:29:50,633 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph >- Sink: Print to Std. Out (14/16) (d7c4fbf5f23f3118e54998f2b35338c1) > switched from CANCELING to CANCELED. >
How to run in IDE?
Hi using Flink 1.14.3 with gradle. I explicitly added the flink client dependency and the job starts but it quits with... In Flink 1.10 the job worked as is. How do I set the number of slots and is there any other settings for the IDE? 16:29:50,633 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager - Received resource requirements from job 3a3e9c46da413071392bce161c39270f: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=2}] 16:29:50,633 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Print to Std. Out (14/16) (d7c4fbf5f23f3118e54998f2b35338c1) switched from CANCELING to CANCELED.