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.
