Could not start the JobMaster. org.apache.flink.api.common.ExecutionConfig not found

2023-12-04 Thread Matwey V. Kornilov
Hello, I am trying to run very simple job locally via maven exec plugin: public class DataStreamJob { public static void main(String[] args) throws Exception { final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

Re: Could not start the JobMaster. org.apache.flink.api.common.ExecutionConfig not found

2023-12-05 Thread Matwey V. Kornilov
Sorry for the noise. Reverting to version 1.17.2 fixed the issue. 04.12.2023 15:08, Matwey V. Kornilov пишет: Hello, I am trying to run very simple job locally via maven exec plugin: public class DataStreamJob {     public static void main(String[] args) throws Exception

S3 bucket as a source

2023-12-05 Thread Matwey V. Kornilov
Hello, I have an S3 bucket and I would like to process the objects metainfo (such as keys (filenames), metainfo, tags, etc.). I don't care about the objects content since it is irrelevant for my task. What I want is to construct a data stream where each instance is a metainfo attached to some