initial project

.gitignore

@@ -0,0 +1,74 @@
+#Binario
+#
+package/files/flink-bin-1.8.1/flink.tar.gz
+# Directories #
+/build/
+/bin/
+**/bin/
+target/
+# OS Files #
+.DS_Store
+*.class
+# Package Files #
+*.war
+*.ear
+*.db
+######################
+# Windows
+######################
+# Windows image file caches
+Thumbs.db 
+# Folder config file
+Desktop.ini
+######################
+# OSX
+######################
+.DS_Store
+.svn
+# Thumbnails
+._*
+# Files that might appear on external disk
+.Spotlight-V100
+.Trashes
+######################
+# Eclipse
+######################
+.project
+.metadata
+.classpath
+.settings/
+.loadpath
+*.pydevproject
+bin/**
+tmp/**
+tmp/**/*
+*.tmp
+*.bak
+*.swp
+*~.nib
+local.properties
+/src/main/resources/rebel.xml
+# External tool builders
+.externalToolBuilders/
+# Locally stored "Eclipse launch configurations"
+*.launch
+# CDT-specific
+.cproject
+.project
+# PDT-specific
+.buildpath
+#liferay sdk
+build-common-theme.xml
+build-common-portlet.xml
+create.bat
+create.sh
+merge.bat
+/build.xml
+readme.txt
+*/META-INF/*
+*build.properties*
+######################
+# IntelliJ
+######################
+.idea
+*.iml

README.md

@@ -0,0 +1,3 @@
+## Flink ambari service
+
+### Install flink service

configuration/flink-env.xml

@@ -0,0 +1,88 @@
+<?xml version="1.0"?>
+<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
+<!-- /** * Licensed to the Apache Software Foundation (ASF) under one * or 
+	more contributor license agreements. See the NOTICE file * distributed with 
+	this work for additional information * regarding copyright ownership. The 
+	ASF licenses this file * to you under the Apache License, Version 2.0 (the 
+	* "License"); you may not use this file except in compliance * with the License. 
+	You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 
+	* * Unless required by applicable law or agreed to in writing, software * 
+	distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT 
+	WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the 
+	License for the specific language governing permissions and * limitations 
+	under the License. */ -->
+<configuration supports_adding_forbidden="true">
+	<property>
+		<name>flink_user</name>
+		<display-name>Flink User</display-name>
+		<value>flink</value>
+		<property-type>USER</property-type>
+		<description />
+		<value-attributes>
+			<type>user</type>
+			<overridable>false</overridable>
+			<user-groups>
+				<property>
+					<type>cluster-env</type>
+					<name>user_group</name>
+				</property>
+			</user-groups>
+		</value-attributes>
+		<on-ambari-upgrade add="true" />
+	</property>
+	<property>
+		<name>flink_log_dir</name>
+		<display-name>Flink Log directory</display-name>
+		<value>/var/log/flink</value>
+		<description>Flink log directory where the daemon writes</description>
+		<value-attributes>
+			<type>directory</type>
+		</value-attributes>
+		<on-ambari-upgrade add="true" />
+	</property>
+	<property>
+		<name>flink_pid_dir</name>
+		<display-name>Flink PID directory</display-name>
+		<value>/var/run/flink</value>
+		<description />
+		<value-attributes>
+			<type>directory</type>
+		</value-attributes>
+		<on-ambari-upgrade add="true" />
+	</property>
+	<property>
+		<name>flink_principal_name</name>
+		<description>Flink principal name</description>
+		<property-type>KERBEROS_PRINCIPAL</property-type>
+		<value>flink/_HOST</value>
+		<on-ambari-upgrade add="true" />
+	</property>
+	<property>
+		<name>flink_keytab</name>
+		<description>Flink keytab path</description>
+		<value>/etc/security/keytabs/flink.service.keytab</value>
+		<on-ambari-upgrade add="true" />
+	</property>
+	<property>
+		<name>hadoop_conf_dir</name>
+		<display-name>Haddop conf path</display-name>
+		<value>/etc/hadoop/conf</value>
+		<description>Haddop conf path (where is located core-site etc..)
+		</description>
+		<value-attributes>
+			<type>directory</type>
+		</value-attributes>
+		<on-ambari-upgrade add="true" />
+	</property>
+	<property>
+		<name>has_metric_collector</name>
+		<value>false</value>
+		<description>If true, Flink report metrics to ambari collector, by
+			default false.</description>
+		<value-attributes>
+			<type>boolean</type>
+		</value-attributes>
+		<on-ambari-upgrade add="true" />
+	</property>
+
+</configuration>