python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - apache-flink

Do I need a JAR file to run a Flink application?

I am working through the book Stream Processing with Apache Flink by Fabian Hueske and Vasiliki Kalavri. The book includes an example Flink application and I want to figure out how to run the file. It...
test-img

Cauder

scala

apache-flink

Votes: 0

Answers: 1

Latest Answer

Except for SQL queries submitted with Flink‘s SQL client, a user needs to package a JAR file. Usually, a Flink program file can be packaged using a Maven or Gradle project: https://nightlies.apache.or...
test-img

twalthr

How can I tell which port Apache Flink runs on?

I installed apache flink, went to the flink-1.14.3 folder and ran .bin/start-cluster.sh. It appears to have started the cluster successfully because it output this- Starting cluster. Starting standalo...
test-img

Cauder

apache-flink

Votes: 0

Answers: 2

Latest Answer

Per https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/try-flink/local_installation/ you should be able to access it on http://localhost:8081/
test-img

Martijn Visser

What version of Scala does Apache Flink use?

I'm getting started with Apache Flink. I noticed on the Apache Flink download page, it says "Apache Flink 1.14.3 for Scala 2.11 (asc, sha512)" as the name of the installation file. Can you c...
test-img

Cauder

scala

apache-flink

Votes: 0

Answers: 1

Latest Answer

Flink up to 1.14 is available in both a Scala 2.11 and Scala 2.12 binary, which can be downloaded from https://flink.apache.org/downloads.html. This means that you can use Flink's Scala API with eithe...
test-img

Martijn Visser

What's the correct way to pass environment variables to a keyed function and how could it be used with the KeyedOneInputStreamOperatorTestHarness

I need to pass some configuration to a custom KeyedProcessFunction and I would like to test it with KeyedOneInputStreamOperatorTestHarness. What's the proper way to handle this? I've looked to the doc...
test-img

Carlos Miguel Santos

apache-flink

flink-streaming

Votes: 0

Answers: 1

Latest Answer

You can pass the configuration to the KeyedProcessFunction's constructor. Something like this: DataStream<Event> stream = events .keyBy(event -> event.key) .process(new Example(config...
test-img

David Anderson

Posts

Questions

Blogs

Jobs