{"id":996,"date":"2016-08-13T04:50:37","date_gmt":"2016-08-13T04:50:37","guid":{"rendered":"http:\/\/data-flair.training\/blogs\/?p=996"},"modified":"2023-08-14T17:33:05","modified_gmt":"2023-08-14T12:03:05","slug":"apache-flink-application","status":"publish","type":"post","link":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/","title":{"rendered":"Apache Flink Application in Java Eclipse"},"content":{"rendered":"<p>This step by step tutorial will explain <strong>how to create an Apache Flink project in Eclipse<\/strong> and how to submit the application after the creation of jar.<\/p>\n<p>Learn how to configure a development environment for developing Apache Flink Application. If you want to learn more about Apache Flink you can refer this Apache Flink introduction guide.<\/p>\n<h3>How to Create an Apache Flink Application in Java?<\/h3>\n<p>Apache Flink is an open source framework and distributed processing engine. Flink can be stateful computation over bounded and unbounded data streams. It is specially designed to run in all common cluster environments and perform computations at any scale and in-memory.<\/p>\n<p>Here, we will learn the step by step to create an Apache Flink application in java in eclipse-<\/p>\n<ul>\n<li>Platform<\/li>\n<li>Create a project<\/li>\n<li>Make a class WordCount<\/li>\n<li>Copy wordcount code in an editor<\/li>\n<li>Export Apache Flink jar file<\/li>\n<li>Go to the Flink home directory<\/li>\n<li>Sample data<\/li>\n<li>Submit Flink application<\/li>\n<li>Output<\/li>\n<\/ul>\n<h4>i. Platform<\/h4>\n<ul>\n<li>Operating system: Ubuntu (or any flavor of Linux)<\/li>\n<li>Java 7.x or higher<\/li>\n<li>Eclipse \u2013 Latest version<\/li>\n<\/ul>\n<h4>ii. Steps to Create Project<\/h4>\n<p>a. Create a new java project<\/p>\n<div id=\"attachment_997\" style=\"width: 1012px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-project.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-997\" class=\"wp-image-997 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-project.png\" alt=\"Apache Flink Application\" width=\"1002\" height=\"654\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-project.png 1002w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-project-150x98.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-project-300x196.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-project-768x501.png 768w\" sizes=\"auto, (max-width: 1002px) 100vw, 1002px\" \/><\/a><p id=\"caption-attachment-997\" class=\"wp-caption-text\">Apache Flink Application &#8211; make new project<\/p><\/div>\n<p>b. You can name the project as WordCount or with a name of your choice.<\/p>\n<div id=\"attachment_998\" style=\"width: 626px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-projectv2.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-998\" class=\"wp-image-998 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-projectv2.png\" alt=\"Apache Flink Application\" width=\"616\" height=\"717\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-projectv2.png 616w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-projectv2-129x150.png 129w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/make-new-projectv2-258x300.png 258w\" sizes=\"auto, (max-width: 616px) 100vw, 616px\" \/><\/a><p id=\"caption-attachment-998\" class=\"wp-caption-text\">create an Apache Flink Application &#8211; make new project<\/p><\/div>\n<p>c. Add the following JAR in the build path. You can find the jar files in the lib directory in Flink home:<\/p>\n<ul type=\"disc\">\n<li>flink-dist_2.11-1.0.3.jar<\/li>\n<li>flink-python_2.11-1.0.3.jar<\/li>\n<li>log4j-1.2.17.jar<\/li>\n<li>slf4j-log4j12-1.7.7.jar<\/li>\n<\/ul>\n<p>d. Right Click on the project and select Configure build path option from build path<\/p>\n<div id=\"attachment_1000\" style=\"width: 1022px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/configure-buid-path.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1000\" class=\"wp-image-1000 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/configure-buid-path.png\" alt=\"Apache Flink Application\" width=\"1012\" height=\"685\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/configure-buid-path.png 1012w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/configure-buid-path-150x102.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/configure-buid-path-300x203.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/configure-buid-path-768x520.png 768w\" sizes=\"auto, (max-width: 1012px) 100vw, 1012px\" \/><\/a><p id=\"caption-attachment-1000\" class=\"wp-caption-text\">Apache Flink Project &#8211; configure buid path<\/p><\/div>\n<p>e. Add the jar Files from lib folder present in Apache flink home<\/p>\n<div id=\"attachment_999\" style=\"width: 1376px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-999\" class=\"wp-image-999 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option.png\" alt=\"Apache Flink Application\" width=\"1366\" height=\"768\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option.png 1366w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-150x84.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-300x169.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-768x432.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1024x576.png 1024w\" sizes=\"auto, (max-width: 1366px) 100vw, 1366px\" \/><\/a><p id=\"caption-attachment-999\" class=\"wp-caption-text\">Create Flink Application in Java &#8211; add jar<\/p><\/div>\n<h4>iii. Make a class WordCount<\/h4>\n<div id=\"attachment_1001\" style=\"width: 1023px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/new-class.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1001\" class=\"wp-image-1001 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/new-class.png\" alt=\"Apache Flink Application\" width=\"1013\" height=\"724\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/new-class.png 1013w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/new-class-150x107.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/new-class-300x214.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/new-class-768x549.png 768w\" sizes=\"auto, (max-width: 1013px) 100vw, 1013px\" \/><\/a><p id=\"caption-attachment-1001\" class=\"wp-caption-text\">Apache Flink Application &#8211; make new class<\/p><\/div>\n<h4>iv. Copy below Apache Flink Wordcount Code in Editor<\/h4>\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"null\">import org.apache.flink.api.common.functions.FlatMapFunction;\r\nimport org.apache.flink.api.java.DataSet;\r\nimport org.apache.flink.api.java.ExecutionEnvironment;\r\nimport org.apache.flink.api.java.aggregation.Aggregations;\r\nimport org.apache.flink.api.java.tuple.Tuple2;\r\nimport org.apache.flink.api.java.utils.ParameterTool;\r\nimport org.apache.flink.util.Collector;\r\npublic class WordCount {\r\npublic static void main(String[] args) throws Exception {\r\n\/\/ set up the execution environment\r\nfinal ParameterTool params = ParameterTool.fromArgs(args);\r\nfinal ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();\r\nenv.getConfig().setGlobalJobParameters(params);\r\n\/\/ get input data\r\nDataSet&lt;String&gt; text = env.readTextFile(params.get(\"input\"));\r\nDataSet&lt;Tuple2&lt;String, Integer&gt;&gt; counts =\r\n\/\/ split up the lines in pairs (2-tuples) containing: (word,1)\r\ntext.flatMap(new Splitter())\r\n\/\/ group by the tuple field \"0\" and sum up tuple field \"1\"\r\n.groupBy(0)\r\n.aggregate(Aggregations.SUM, 1);\r\n\/\/ emit result\r\ncounts.writeAsText(params.get(\"output\"));\r\n\/\/ execute program\r\nenv.execute(\"WordCount Example\");\r\n}\r\n}\r\n\/\/The operations are defined by specialized classes, here the Splitter class.\r\nclass Splitter implements FlatMapFunction&lt;String, Tuple2&lt;String, Integer&gt;&gt; {\r\n@Override\r\npublic void flatMap(String value, Collector&lt;Tuple2&lt;String, Integer&gt;&gt; out) {\r\n\/\/ normalize and split the line into words\r\nString[] tokens = value.split(\"\\\\W+\");\r\n\/\/ emit the pairs\r\nfor (String token : tokens) {\r\nif (token.length() &gt; 0) {\r\nout.collect(new Tuple2&lt;String, Integer&gt;(token, 1));\r\n}\r\n}\r\n}\r\n}<\/pre>\n<h4>v. Export the Apache Flink Jar File<\/h4>\n<p>Before running created Apache Flink word count application we have to create a jar file. Right click on project &gt;&gt; export<\/p>\n<div id=\"attachment_1002\" style=\"width: 1376px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1002\" class=\"wp-image-1002 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar.png\" alt=\"Apache Flink Application\" width=\"1366\" height=\"710\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar.png 1366w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar-150x78.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar-300x156.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar-768x399.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar-1024x532.png 1024w\" sizes=\"auto, (max-width: 1366px) 100vw, 1366px\" \/><\/a><p id=\"caption-attachment-1002\" class=\"wp-caption-text\">Apache Flink Application &#8211; export jar<\/p><\/div>\n<p>Select Jar-file Option to Export<\/p>\n<div id=\"attachment_1004\" style=\"width: 1376px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1004\" class=\"wp-image-1004 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1.png\" alt=\"Apache Flink Application\" width=\"1366\" height=\"768\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1.png 1366w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1-150x84.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1-300x169.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1-768x432.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/choose-jar-option-1-1024x576.png 1024w\" sizes=\"auto, (max-width: 1366px) 100vw, 1366px\" \/><\/a><p id=\"caption-attachment-1004\" class=\"wp-caption-text\">Create a project in Flink &#8211; choose jar option<\/p><\/div>\n<p>Create the Jar file<\/p>\n<div id=\"attachment_1003\" style=\"width: 619px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar1.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1003\" class=\"wp-image-1003 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar1.png\" alt=\"Apache Flink Application\" width=\"609\" height=\"624\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar1.png 609w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar1-146x150.png 146w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/export-jar1-293x300.png 293w\" sizes=\"auto, (max-width: 609px) 100vw, 609px\" \/><\/a><p id=\"caption-attachment-1003\" class=\"wp-caption-text\">Apache Flink Application &#8211; export jar v2<\/p><\/div>\n<h4>vi. Go to Apache Flink Home Directory<\/h4>\n<p>i. start the Apache Flink services by using following commands<\/p>\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"null\">cd Flink\r\nbin\/start-local.sh<\/pre>\n<div id=\"attachment_1007\" style=\"width: 1373px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1007\" class=\"wp-image-1007 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home.png\" alt=\"Apache Flink Application\" width=\"1363\" height=\"621\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home.png 1363w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home-150x68.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home-300x137.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home-768x350.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/flink-home-1024x467.png 1024w\" sizes=\"auto, (max-width: 1363px) 100vw, 1363px\" \/><\/a><p id=\"caption-attachment-1007\" class=\"wp-caption-text\">Apache Flink Application &#8211; flink home<\/p><\/div>\n<h4>vii. Sample Data<\/h4>\n<p>Save the following data as input.txt, according to our command it is saved in a home folder.<\/p>\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"null\">DataFlair services pvt ltd provides training in Big Data Hadoop, Apache Spark, Apache Flink, Apache Kafka, Hbase, Apache Hadoop Admin\r\n10000 students are taking training from DataFlair services pvt ltd\r\nThe chances of getting good job in big data hadoop is high\r\nIf you want to become an expert hadoop developer then enroll now!! hurry up!!<\/pre>\n<h4>viii. Submit Apache Flink Application<\/h4>\n<p>Use the following command to Submit the Apache Flink Application<\/p>\n<pre class=\"EnlighterJSRAW\" data-enlighter-language=\"null\">bin\/flink run --class &lt;class-name&gt; &lt;Jar path&gt;\u00a0\u00a0 --input &lt;Input File Path&gt;\u00a0 --output\u00a0&lt;Output Flie Path&gt;\r\nbin\/flink run --class WordCount \/home\/dataflair\/WordCount.jar\u00a0\u00a0 --input file:\/\/\/home\/dataflair\/input.txt\u00a0 --output\u00a0 file:\/\/\/home\/dataflair\/Desktop\/output.txt&lt;br\/&gt;<\/pre>\n<div id=\"attachment_1008\" style=\"width: 1376px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1008\" class=\"wp-image-1008 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command.png\" alt=\"Apache Flink Application\" width=\"1366\" height=\"624\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command.png 1366w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-150x69.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-300x137.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-768x351.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-1024x468.png 1024w\" sizes=\"auto, (max-width: 1366px) 100vw, 1366px\" \/><\/a><p id=\"caption-attachment-1008\" class=\"wp-caption-text\">Apache Flink run command<\/p><\/div>\n<p>We have successfully exported the Apache Flink program. To learn more about the installation of Apache Flink you can refer this Apache Flink installation guide.<\/p>\n<p>Let\u2019s understand above command:<\/p>\n<p>&#8211;class is used to specify the main class which is an entry point of your program<\/p>\n<p>\/home\/dataflair\/WordCount.jar\u00a0\u00a0 &#8211; It is the jar file in which your program exist<\/p>\n<p>&#8211;input is used to specify the input path of your file<\/p>\n<p>&#8211;output is used to specify the output path of your file<\/p>\n<p>When you will run the above command you will get the following result on your terminal-<\/p>\n<div id=\"attachment_1009\" style=\"width: 1376px\" class=\"wp-caption aligncenter\"><a href=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1009\" class=\"wp-image-1009 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output.png\" alt=\"Apache Flink Application\" width=\"1366\" height=\"626\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output.png 1366w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output-150x69.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output-300x137.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output-768x352.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/run-command-output-1024x469.png 1024w\" sizes=\"auto, (max-width: 1366px) 100vw, 1366px\" \/><\/a><p id=\"caption-attachment-1009\" class=\"wp-caption-text\">Apache Flink run command output<\/p><\/div>\n<h4>ix. Output<\/h4>\n<div id=\"attachment_1010\" style=\"width: 1376px\" class=\"wp-caption alignnone\"><a href=\"http:\/\/data-flair.training\/blogs\/wp-content\/uploads\/Apache-Flink-output.png\"><img loading=\"lazy\" decoding=\"async\" aria-describedby=\"caption-attachment-1010\" class=\"wp-image-1010 size-full\" src=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Output.png\" alt=\"Apache Flink Application\" width=\"1366\" height=\"617\" srcset=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Output.png 1366w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Output-150x68.png 150w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Output-300x136.png 300w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Output-768x347.png 768w, https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Output-1024x463.png 1024w\" sizes=\"auto, (max-width: 1366px) 100vw, 1366px\" \/><\/a><p id=\"caption-attachment-1010\" class=\"wp-caption-text\">Apache Flink Application &#8211; output<\/p><\/div>\n<p>Here is the output of our Apache Flink Word Count program.<\/p>\n<p>We can also create Apache Flink project in Scala as well. To Learn Scala follow this Scala tutorial.<\/p>\n<p>So, we have created an Apache Flink Application in Java in Eclipse. Hope you like our explanation. Still, if any doubt, ask freely in the comment tab.<\/p>\n<h3>Conclusion<\/h3>\n<p>Developers may take use of Apache Flink&#8217;s distributed stream and batch processing capabilities for effective big data analysis and application development by building an Apache Flink application in Java.<\/p>\n<p>Developers can take advantage of Flink&#8217;s powerful features to process data from various sources, apply sophisticated transformations, and output results to various sinks by setting up the Flink environment, adding necessary dependencies, writing the application code using Flink&#8217;s Java API, and deploying it on a Flink cluster.<\/p>\n<p>Java developers may create highly dependable and performant data processing applications that address a variety of big data concerns across industries thanks to Flink&#8217;s fault tolerance, scalability, and performance optimisations.<\/p>\n","protected":false},"excerpt":{"rendered":"<p>This step by step tutorial will explain how to create an Apache Flink project in Eclipse and how to submit the application after the creation of jar. Learn how to configure a development environment&#46;&#46;&#46;<\/p>\n","protected":false},"author":6,"featured_media":42826,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[8],"tags":[750,4740,4754,4770,4771,4778,11663],"class_list":["post-996","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-flink","tag-apache-flink","tag-flink-application","tag-flink-data-analysis","tag-flink-java","tag-flink-job","tag-flink-project","tag-run-flink"],"yoast_head":"<!-- This site is optimized with the Yoast SEO plugin v27.8 - https:\/\/yoast.com\/product\/yoast-seo-wordpress\/ -->\n<title>Apache Flink Application in Java Eclipse - DataFlair<\/title>\n<meta name=\"description\" content=\"Create Apache Flink project in Eclipse &amp; submit Flink application after creation of jar. Configure development environment for Flink Application.\" \/>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/data-flair.training\/blogs\/apache-flink-application\/\" \/>\n<meta property=\"og:locale\" content=\"en_US\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Apache Flink Application in Java Eclipse - DataFlair\" \/>\n<meta property=\"og:description\" content=\"Create Apache Flink project in Eclipse &amp; submit Flink application after creation of jar. Configure development environment for Flink Application.\" \/>\n<meta property=\"og:url\" content=\"https:\/\/data-flair.training\/blogs\/apache-flink-application\/\" \/>\n<meta property=\"og:site_name\" content=\"DataFlair\" \/>\n<meta property=\"article:publisher\" content=\"https:\/\/www.facebook.com\/DataFlairWS\/\" \/>\n<meta property=\"article:published_time\" content=\"2016-08-13T04:50:37+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2023-08-14T12:03:05+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Apache-Flink-Application-in-Java-Eclipse-01-1.jpg\" \/>\n\t<meta property=\"og:image:width\" content=\"1200\" \/>\n\t<meta property=\"og:image:height\" content=\"628\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/jpeg\" \/>\n<meta name=\"author\" content=\"DataFlair Team\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:creator\" content=\"@DataFlairWS\" \/>\n<meta name=\"twitter:site\" content=\"@DataFlairWS\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"DataFlair Team\" \/>\n\t<meta name=\"twitter:label2\" content=\"Est. reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"6 minutes\" \/>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Apache Flink Application in Java Eclipse - DataFlair","description":"Create Apache Flink project in Eclipse & submit Flink application after creation of jar. Configure development environment for Flink Application.","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/","og_locale":"en_US","og_type":"article","og_title":"Apache Flink Application in Java Eclipse - DataFlair","og_description":"Create Apache Flink project in Eclipse & submit Flink application after creation of jar. Configure development environment for Flink Application.","og_url":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/","og_site_name":"DataFlair","article_publisher":"https:\/\/www.facebook.com\/DataFlairWS\/","article_published_time":"2016-08-13T04:50:37+00:00","article_modified_time":"2023-08-14T12:03:05+00:00","og_image":[{"width":1200,"height":628,"url":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Apache-Flink-Application-in-Java-Eclipse-01-1.jpg","type":"image\/jpeg"}],"author":"DataFlair Team","twitter_card":"summary_large_image","twitter_creator":"@DataFlairWS","twitter_site":"@DataFlairWS","twitter_misc":{"Written by":"DataFlair Team","Est. reading time":"6 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#article","isPartOf":{"@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/"},"author":{"name":"DataFlair Team","@id":"https:\/\/data-flair.training\/blogs\/#\/schema\/person\/2c58ecb4f73a39f0ef993f1ddfcd7b89"},"headline":"Apache Flink Application in Java Eclipse","datePublished":"2016-08-13T04:50:37+00:00","dateModified":"2023-08-14T12:03:05+00:00","mainEntityOfPage":{"@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/"},"wordCount":805,"commentCount":12,"publisher":{"@id":"https:\/\/data-flair.training\/blogs\/#organization"},"image":{"@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#primaryimage"},"thumbnailUrl":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Apache-Flink-Application-in-Java-Eclipse-01-1.jpg","keywords":["apache flink","flink application","flink data analysis","flink java","flink job","flink project","run flink"],"articleSection":["Apache Flink Tutorials"],"inLanguage":"en-US","potentialAction":[{"@type":"CommentAction","name":"Comment","target":["https:\/\/data-flair.training\/blogs\/apache-flink-application\/#respond"]}]},{"@type":"WebPage","@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/","url":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/","name":"Apache Flink Application in Java Eclipse - DataFlair","isPartOf":{"@id":"https:\/\/data-flair.training\/blogs\/#website"},"primaryImageOfPage":{"@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#primaryimage"},"image":{"@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#primaryimage"},"thumbnailUrl":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Apache-Flink-Application-in-Java-Eclipse-01-1.jpg","datePublished":"2016-08-13T04:50:37+00:00","dateModified":"2023-08-14T12:03:05+00:00","description":"Create Apache Flink project in Eclipse & submit Flink application after creation of jar. Configure development environment for Flink Application.","breadcrumb":{"@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#breadcrumb"},"inLanguage":"en-US","potentialAction":[{"@type":"ReadAction","target":["https:\/\/data-flair.training\/blogs\/apache-flink-application\/"]}]},{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#primaryimage","url":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Apache-Flink-Application-in-Java-Eclipse-01-1.jpg","contentUrl":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/08\/Apache-Flink-Application-in-Java-Eclipse-01-1.jpg","width":1200,"height":628,"caption":"Apache Flink Application in Java Eclipse For 2018"},{"@type":"BreadcrumbList","@id":"https:\/\/data-flair.training\/blogs\/apache-flink-application\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Blog Home","item":"https:\/\/data-flair.training\/blogs\/"},{"@type":"ListItem","position":2,"name":"Apache Flink Tutorials","item":"https:\/\/data-flair.training\/blogs\/category\/flink\/"},{"@type":"ListItem","position":3,"name":"Apache Flink Application in Java Eclipse"}]},{"@type":"WebSite","@id":"https:\/\/data-flair.training\/blogs\/#website","url":"https:\/\/data-flair.training\/blogs\/","name":"DataFlair","description":"Learn Today. Lead Tomorrow.","publisher":{"@id":"https:\/\/data-flair.training\/blogs\/#organization"},"potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/data-flair.training\/blogs\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"en-US"},{"@type":"Organization","@id":"https:\/\/data-flair.training\/blogs\/#organization","name":"DataFlair","url":"https:\/\/data-flair.training\/blogs\/","logo":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/data-flair.training\/blogs\/#\/schema\/logo\/image\/","url":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/07\/Data-Flair.png","contentUrl":"https:\/\/data-flair.training\/blogs\/wp-content\/uploads\/sites\/2\/2016\/07\/Data-Flair.png","width":106,"height":48,"caption":"DataFlair"},"image":{"@id":"https:\/\/data-flair.training\/blogs\/#\/schema\/logo\/image\/"},"sameAs":["https:\/\/www.facebook.com\/DataFlairWS\/","https:\/\/x.com\/DataFlairWS","https:\/\/www.linkedin.com\/company\/dataflair-web-services-pvt-ltd\/","https:\/\/www.youtube.com\/user\/DataFlairWS"]},{"@type":"Person","@id":"https:\/\/data-flair.training\/blogs\/#\/schema\/person\/2c58ecb4f73a39f0ef993f1ddfcd7b89","name":"DataFlair Team","image":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/secure.gravatar.com\/avatar\/1ce4a0e3e542444fc73bbebf83e89e8b73e2d95ccb1fcee64da9945f078b97c5?s=96&d=mm&r=g","url":"https:\/\/secure.gravatar.com\/avatar\/1ce4a0e3e542444fc73bbebf83e89e8b73e2d95ccb1fcee64da9945f078b97c5?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/1ce4a0e3e542444fc73bbebf83e89e8b73e2d95ccb1fcee64da9945f078b97c5?s=96&d=mm&r=g","caption":"DataFlair Team"},"description":"The DataFlair Team provides industry-driven content on programming, Java, Python, C++, DSA, AI, ML, data Science, Android, Flutter, MERN, Web Development, and technology. Our expert educators focus on delivering value-packed, easy-to-follow resources for tech enthusiasts and professionals.","url":"https:\/\/data-flair.training\/blogs\/author\/dfteam2\/"}]}},"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/posts\/996","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/users\/6"}],"replies":[{"embeddable":true,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/comments?post=996"}],"version-history":[{"count":4,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/posts\/996\/revisions"}],"predecessor-version":[{"id":118035,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/posts\/996\/revisions\/118035"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/media\/42826"}],"wp:attachment":[{"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/media?parent=996"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/categories?post=996"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/data-flair.training\/blogs\/wp-json\/wp\/v2\/tags?post=996"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}