1. 程式人生 > >Mac下安裝Flink的local模式(flink-1.0.2)

Mac下安裝Flink的local模式(flink-1.0.2)

1.本地執行

下載
進入下載頁面。如果你想讓Flink與Hadoop進行互動(如HDFS或者HBase),請選擇一個與你的Hadoop版本相匹配的Flink包。當你不確定或者只是想執行在本地檔案系統上,請選擇Hadoop 1.2.x對應的包。

2.環境準備

Flink 可以執行在 Linux、Mac OS X 和 Windows 上。本地模式的安裝唯一需要的只是 Java 1.7.x或更高版本。接下來的指南假定是類Unix環境,Windows使用者請參考 Flink on Windows。

3.配置

對於本地模式,Flink是可以開箱即用的,你不用去更改任何的預設配置。
開箱即用的配置會使用預設的Java環境。如果你想更改Java的執行環境,你可以手動地設定環境變數JAVA_HOME或者conf/flink-conf.yaml中的配置項env.java.home。你可以查閱配置頁面瞭解更多關於Flink的配置。

4. 啟動Flink

你現在就可以開始執行Flink了。解壓已經下載的壓縮包,然後進入新建立的flink目錄。在那裡,你就可以本地模式執行Flink了:

lcc@lcc flink-1.0.2$ tar xzf flink-*.tgz
lcc@lcc flink-1.0.2$ cd flink-*
lcc@lcc flink-1.0.2$ bin/start-local.sh
Starting jobmanager daemon on host lcc.
lcc@lcc flink-1.0.2$

注意:
高版本的,已經沒有start-local.sh指令碼了,所以剛剛學建議用低版本,版本小於等於1.2.0版本

你可以通過觀察logs目錄下的日誌檔案來檢查系統是否正在運行了:

[email protected] flink-1.0.2$tail log/flink-*-jobmanager-*.log
- --------------------------------------------------------------------------------
- Starting JobManager (Version: 1.0.2, Rev:d39af15, Date:18.04.2016 @ 12:42:48 UTC)
- Current user: lcc
- JVM: Java HotSpot
(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.131-b11
- Maximum heap size: 736 MiBytes - JAVA_HOME: /Library/Java/JavaVirtualMachines/jdk1.8.0_131.jdk/Contents/Home - Hadoop version: 2.3.0 - Classpath: /Users/lcc/soft/flink/flink-1.0.2/lib/flink-dist_2.10-1.0.2.jar:/Users/lcc/soft/flink/flink-1.0.2/lib/flink-python_2.10-1.0.2.jar:/Users/lcc/soft/flink/flink-1.0.2/lib/log4j-1.2.17.jar:/Users/lcc/soft/flink/flink-1.0.2/lib/slf4j-log4j12-1.7.7.jar:::/Users/lcc/soft/hadoop/hadoop/etc/hadoop: - Starting with JobManager akka.tcp://[email protected]:6123/user/jobmanager on port 8081

JobManager 同時會在8081埠上啟動一個web前端,你可以通過 http://localhost:8081 來訪問。

這裡寫圖片描述

相關推薦

Mac安裝Flink的local模式flink-1.0.2

1.本地執行 下載 進入下載頁面。如果你想讓Flink與Hadoop進行互動(如HDFS或者HBase),請選擇一個與你的Hadoop版本相匹配的Flink包。當你不確定或者只是想執行在本地檔案系統上,請選擇Hadoop 1.2.x對應的包。 2.環境

Storm的StreamID使用樣例版本1.0.2

alt constant rate fields olt topology next blog for 隨手嘗試了一下StreamID的的用法。留個筆記。 ==數據樣例== { "Address": "小橋鎮小橋中學對面", "CityCode": "

Oracle 12c12.1.0.5OEM server agent 安裝配置

stat oem www 忽略 符號 cin .com 至少 打開 註意: 此文檔為生產上操作文檔,省略了IP,oracle用戶server,agent 端至少需要sudo,ping,ssh,創建目錄權限。 一、安裝要求 1.1. 系統情況一覽 IP 數據庫

windows安裝curl教程遇到坑記錄一下

前言:最近要在本機安裝curl,網上查了很多資料還是沒有成功,最後靠大神解決了,原來有個關鍵步驟沒做,在這裡記錄一下。 1.去官網下載curl的安裝包https://curl.haxx.se/download.html 根據自己電腦情況下載32位或者64位的。

centos7安裝tomcat8筆記不適用於生產環境

2.解壓 $ tar zxvf apache-tomcat-8.0.36.tar.gz 3.進入tomcat的bin目錄啟動tomcat $ cd /home/soft-java-env/apache-tomcat-8.0.36/bin //進入bi

c語言實現linux高危函式system 簡易V1.0版本

system這個函式真的是要慎用,一不小心就會留下漏洞。 下面是用c語言簡易的實現了一下system函式 #include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<err

spring原始碼學習5.1.0版本——Bean的初始化

目錄   前言 createBean 有自定義TargetSource代理類的生成 resolveBeforeInstantiation applyBeanPostProcessorsBeforeInstantiation postProcessBeforeIn

spring原始碼學習5.1.0版本——Bean的初始化

目錄   前言 源頭 preInstantiateSingletons方法 getBean(String beanName) doGetBean getObjectForBeanInstance getObjectFromFactoryBean doGe

vue.js篩選功能基於1.0版本

<!DOCTYPE html> <html lang="zh">     <head>         <meta charset="UTF-8" />         <meta name="viewport" con

Redis安裝及配置基於5.0版本

目前最新版為:5.0.3,官方推薦使用原始碼方式進行安裝,以下是安裝步驟: 1、下載 wget http://download.redis.io/releases/redis-5.0.3.tar.gz 2、解壓 tar -xzvf redis-5.0.3.tar.gz -C

Spring原始碼閱讀5.1.0版本——Contextloaderlistener

目錄 前言 結論 原始碼解析 前言 上了大三了,逐漸想保研,現在一邊準備比賽,一邊學習新知識,一邊做著專案,希望自己能扛下去吧,這篇部落格的原始碼來自spring 5.1.0版本,如有錯誤,歡迎指出 結論 Contextloaderlistener幹了下

c語言實現linux高危函式system 簡易V1.0版本

system這個函式真的是要慎用,一不小心就會留下漏洞。 下面是用c語言簡易的實現了一下system函式 #include<stdio.h> #include<stdlib.h> #include<unistd.h> #inc

spring原始碼閱讀5.1.0版本——AbstractBeanDefinition

目錄 原始碼解析 繼承結構 定義的常量 屬性 總結 什麼是AbstractBeanDefinition AbstractBeanDefinition直接繼承BeanDefiniton,實現了BeanDefinition定義的一系列操作,定義了描述

ORACLE RAC升級12.1.0.1升級至12.1.0.2

檢視當前版本 Crs [[email protected] ~]$ crsctl query crs activeversion Oracle Clusterware active version on the cluster is [12.1.0.1.0] [[email prot

貝葉斯網路工具箱FullBNT-1.0.4使用說明.md

## How to use the Bayes Network Toolbox 定義一個Bayes網路,要確定兩點,網路結構和引數。 教程地址:http://www.cs.ubc.ca/~murphyk/Software/BNT/usage.html#inference #### 1.構造Bayes Ne

Mac安裝MySQL含配置

.tar.gz 界面 take 8.4 通過 -1 pass 查看 pack 首先需要下載 MySQL Community Server 下載地址:https://dev.mysql.com/downloads/mysql/ 進入MySQL的下載界面(https:

mac 安裝jdk

spa idl sig classes frame jstack ascii javah cmd 出自 http://blog.csdn.net/collonn/article/details/28483109: Mac OS 10.9會安裝jdk1.6。蘋果提供的Ja

星雲鏈智能合約開發Mac安裝的準備工作

星雲鏈開發環境安裝 nebulasio安裝 星雲鏈安裝 星雲鏈開發 智能合約開發 Homebrew安裝 包管理工具可以讓你安裝和更新程序變得更方便,目前在Mac系統中最受歡迎的包管理工具是 Homebrew. 我們安裝Homebrew是為了安裝星雲鏈開發環境時更方便快捷。 安裝方法 第一步

星雲鏈智能合約開發Mac安裝星雲鏈

Mac下安裝星雲鏈 星雲鏈智能合約開發 Golang環境搭建 版本用最新版:1.10.2 安裝 brew install go 配置環境變量 vi ~/.bash_profile 打開.bash_profile文件,按"i"鍵可進行編輯,添加: export GOROOT=/u

Mac OS X安裝Vue腳手架vue-cli

前言 Vue作為前端三大框架(Angular,React,Vue)之一,號稱是最簡單,最容易上手的框架,同時也是行內的大趨勢,還可以用來開發最火的小程式。具有開發快,雙向資料流等特點,有些人認為Vue是Angular和React的結合,既有Angular的模板語法也有React的元件化體系,以至於促使其發展