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();
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
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