unsubscribe

unsubscribe

Re: map can't return null

Hi Allan, Map does support null but tuple serializer does not. You might want to use pojo or row types if you need to deal with null values. Read more here . - Abhishek On Sun, 29

Re: Using shell environment variables

you register your system environment parameter ? > > You can find here several ways to use configuration data [1] > > 1. > https://ci.apache.org/projects/flink/flink-docs-stable/dev/best_practices.html > > > On Sat, Aug 24, 2019, 20:26 Abhishek Jain wrote: > >&g

Using shell environment variables

} } My question: Is there an alternative to System.getenv() that I can use to access environment variables inside of flink task? ( P.S. I've only copied relevant code snippet to avoid confusion. I do intend to use API_TOKEN later on. ) -- Warm Regards, Abhishek Jain

Re: Why available task slots are not leveraged for pipeline?

What you'se seeing is likely operator chaining. This is the default behaviour of grouping sub tasks to avoid transer overhead (from one slot to another). You can disable chaining if you need to. Please refer task and operator chains

Error while using session window

) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Thread.java:745) -- Warm Regards, Abhishek Jain

Re: ClassNotFoundException on remote cluster

Also, the `execute()` call happens inside `MyWikiAnalysis` spring managed bean on PostConstruct but I don't think that should cause any issue. Any idea? Let me know if you need more info on my environment. On Thu, 2 May 2019 at 17:32, Abhishek Jain wrote: > This is a spring boot app that I

Re: ClassNotFoundException on remote cluster

lasses are actually contained within? > > On 02/05/2019 13:38, Abhishek Jain wrote: > > Hi, > I'm running into ClassNotFoundException only when I run my application on > a standalone cluster (using flink cli). If i directly run the main class in > my IDE, it's working fine. > I

Re: configuration of standalone cluster

tore > > security.ssl.internal.truststore: > > /swissbib_index/apps/flink/conf/internal.keystore > > security.ssl.internal.keystore-password: verysecret > > security.ssl.internal.truststore-password: verysecret > > security.ssl.internal.key-password: verysecret > > > > but this doesn't solve the problem - still no connection between > > task-managers and job-managers. > > > > - another question: which ports have to be enabled in the firewall for > > a standalone cluster? > > > > Thanks for any hints! > > > > Günter > > > > > > -- Warm Regards, Abhishek Jain

ClassNotFoundException on remote cluster

n21/af769ff19d11b69417a3c389bf5e5fa7>. -- Warm Regards, Abhishek Jain