Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Updating to flink 1.1.2 version #5

Open
wants to merge 6 commits into
base: master
Choose a base branch
from
Open

Updating to flink 1.1.2 version #5

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
93c0abb
Update flink version
supergarotinho Sep 7, 2016
e806d81
Update flink version
supergarotinho Sep 7, 2016
7359ef7
Update .gitignore
supergarotinho Sep 7, 2016
7ca3012
Update flink version
supergarotinho Sep 7, 2016
15cda7a
Merge branch 'master' of https://github.com/supergarotinho/ambari-fli…
supergarotinho Sep 7, 2016
77c664d
Update for flink 1.2 and scala 2.11
supergarotinho Feb 16, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
.DS_Store
.class
.swp

# Pycharm IDE
.idea
41 changes: 20 additions & 21 deletions configuration/flink-ambari-config.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
<?xml version="1.0"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>

<configuration>

<!-- params for service -->
Expand All @@ -9,65 +9,64 @@
<name>flink_install_dir</name>
<value>/opt/flink</value>
<description>Location to install Flink</description>
</property>
</property>

<property>
<name>flink_numcontainers</name>
<value>1</value>
<description>Number of YARN container to allocate (=Number of Task Managers)</description>
</property>
</property>

<property>
<name>flink_appname</name>
<value>flinkapp-from-ambari</value>
<description>Flink application name</description>
</property>
</property>

<property>
<name>flink_queue</name>
<value>default</value>
<description>YARN queue to schedule Flink job on</description>
</property>
</property>

<property>
<name>flink_streaming</name>
<value>false</value>
<description>If true, Flink will be started in streaming mode: to be used when only streaming jobs will be executed on Flink</description>
</property>
</property>

<property>
<name>flink_jobmanager_memory</name>
<value>768</value>
<description>Memory for JobManager Container [in MB]. Must be at least 768</description>
</property>
</property>

<property>
<name>flink_container_memory</name>
<value>1024</value>
<description>Memory per TaskManager Container [in MB]</description>
</property>

</property>

<property>
<name>setup_prebuilt</name>
<value>true</value>
<description>If false, will compile Flink from source instead</description>
</property>
</property>


<property>
<name>hadoop_conf_dir</name>
<value>/etc/hadoop/conf</value>
<description>Hadoop conf dir. Needed to submit to YARN</description>
</property>
</property>

<property>
<name>flink_download_url</name>
<value>http://www.us.apache.org/dist/flink/flink-1.0.0/flink-1.0.0-bin-hadoop27-scala_2.10.tgz</value>
<value>http://www-us.apache.org/dist/flink/flink-1.2.0/flink-1.2.0-bin-hadoop27-scala_2.11.tgz</value>
<description>Snapshot download location. Downloaded when setup_prebuilt is true</description>
</property>
</property>







</configuration>
</configuration>
2 changes: 1 addition & 1 deletion metainfo.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
<name>FLINK</name>
<displayName>Flink</displayName>
<comment>Apache Flink is a streaming dataflow engine that provides data distribution, communication, and fault tolerance for distributed computations over data streams.</comment>
<version>1.0</version>
<version>1.1.2</version>
<components>
<component>
<name>FLINK_MASTER</name>
Expand Down