달력

04

« 2016/04 »

  •  
  •  
  •  
  •  
  •  
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30

Storm 을 소개하는 글을 보면 보통 실시간 데이터 처리용 이라고들 하더라.

아무튼 어찌되었든 쓰긴할것처럼 보여서 일단 Hello World 찍어보고 .기본사용법만 익혀본다.


완전 java 로 만들어져있는것처럼 

다른 opensource 마냥 무언가 application 을 설치하는 형태라고 보긴 모호한것같다.



사용 버전 : 0.9.6 

사용노드 수 : 6대 ( 1 : nimbus , 5 : supervisor )

주키퍼 버전 : 3.4.6 (원래쓰던거임으로 ~ 일단 이건 패스)


수정한 설정파일 내역

주키퍼설정, 디렉토리 , 호트 , 슬롯포트 정도만 넣었다.

conf 디렉토리의 storm.yaml 파일만 수정하고 모든 노드에 동일하게 적용. 


########### These MUST be filled in for a storm configuration

storm.zookeeper.servers:

     - "192.168.0.112"

     - "192.168.0.113"

     - "192.168.0.114"

     - "192.168.0.115"

     - "192.168.0.116"



storm.local.dir: "/apps/strm/data"


nimbus.host: "192.168.0.111"

supervisor.slots.ports:

    - 6700

    - 6701

    - 6702

    - 6703


ui.port: 6799



설정후 백그라운드 실행을 하면

자바프로세스명으로 nimbus ( 마스터 노드 ? )

나머지 5대노드에선 (supervisor ) 라고 보일것이다.    

그리고 마스터 노드에선 ( nimbus 가 있는 노드 ) ui 도 띄웠다. 


전부 백드라운드로 실행함.  


UI 화면 ( http://192.168.0.111:6799/index.html )




HelloWorld 찍을 소스 ( 책보고 만듬 : 책이름 : 에이콘꺼 아파치 Storm을 이용한 분산 실시간 빅데이터 처리 - 도움된다. 적절히 ㅋ ) 

스톰의 HelloWorld 는 단어세기라고 한다. 우리 그 뭐시냐 빅데이터 RM 테스트할때도 단어세기가 대표적이니.이것도 마찬가지인듯.

(아래소스는 싱글노드용이나 마찬가지다. 클러스토로 할땐 다른클래스를 호출해서 써야하던데 그건 다음기록에;;;)


테스트한 단어 배열 ( 미국 국가라고 한다 - 검색해서 대충 복사함 )


Spout 부분

public class TestSpout extends BaseRichSpout 

{

private SpoutOutputCollector collector;

private String[] test_str = 

{

"Oh, say can you see, by the dawn’s early light,",

"What so proudly we hailed at the twilight’s last gleaming?",

"Whose broad stripes and bri",

"ght stars, through the perilous fight,",

"O’er the ramparts we watched, were so gallantly streaming?",

"And the rockets’red glare, the bombs bursting in air,",

"Gave proof through the night that our flag was still there.",

"Oh say, does that star spangled banner yet wave",

"O’er the land of the free and the home of the brave?"

};

private int index = 0;

/*  

    public static void main( String[] args )

    {

        System.out.println( "Hello World!" );

    }

*/

@Override

public void declareOutputFields(OutputFieldsDeclarer arg0) {

// TODO Auto-generaated method stub

System.out.println("sput declareoutputfields!!!");

arg0.declare(new Fields("sentence"));

}


@Override

public void open(Map arg0, TopologyContext arg1, SpoutOutputCollector arg2) {

// TODO Auto-generated method stub

System.out.println("sput open!!!");

this.collector = arg2;

}

@Override

public void nextTuple() {

// TODO Auto-generated method stub

System.out.println("sput nexttuple!!!");

this.collector.emit(new Values(test_str[index]));

index++;

System.out.println("sput nexttuple =======" + index);

System.out.println(index + "<<<<<<<<<<<<<<<<<<<=============================>>>>>>>>>>>>>>>>>>>>>" + test_str.length);

if ( index >= test_str.length)

{

index = 0;

System.out.println("sput nexttuple =======zero ===============" + 0);

}

waitForSeconds(1);

System.out.println("next tupple last");

}


public static void waitForSeconds(int seconds) {

        try {

            Thread.sleep(seconds * 1);

        } catch (InterruptedException e) {

        }

    }


}


Bolt부분 ( 문장배열 분리 )

public class TestBolt extends BaseRichBolt {


private OutputCollector collector;

@Override

public void declareOutputFields(OutputFieldsDeclarer arg0) {

// TODO Auto-generated method stub

System.out.println("==================== declare ====================");

arg0.declare(new Fields("word")); 

}

@Override

public void prepare(Map arg0, TopologyContext arg1, OutputCollector arg2) {

// TODO Auto-generated method stub

System.out.println("bolt prepare!!!");

this.collector = arg2;

}

@Override

public void execute(Tuple arg0) {

// TODO Auto-generated method stub

System.out.println("bolt execute!!!");

String sentence = arg0.getStringByField("sentence");

String[] words = sentence.split(" ");

for(String word: words)

{

this.collector.emit(new Values(word));

System.out.println("bolt execute!!! === >>>>>>>>>>>>>>>> " + word);

}

}


Bolt부분 두번째 ( 분리한 문장과 단어에서 단어 수 체크  작업 )

public class Test2Bolt extends BaseRichBolt {


private OutputCollector collector;

private HashMap<String,Long> counts = null;

@Override

public void prepare(Map arg0, TopologyContext arg1, OutputCollector arg2) {

// TODO Auto-generated method stub

System.out.println("test2 prepare");

this.collector = arg2;

this.counts = new HashMap<String, Long>();

}

@Override

public void execute(Tuple arg0) {

// TODO Auto-generated method stub

System.out.println("test2 execute");

String word = arg0.getStringByField("word");

Long count = this.counts.get(word);

if(count == null)

{

count = 0L;

}

count++;

this.counts.put(word, count);

this.collector.emit(new Values(word,count));

}



@Override

public void declareOutputFields(OutputFieldsDeclarer arg0) {

// TODO Auto-generated method stub

System.out.println("test2 declareoutput");

arg0.declare( new Fields("word","count"));

}


}



Bolt부분 세번째 ( 결과 출력 부분 )

public class ResultBolt extends BaseRichBolt {


private HashMap<String,Long> counts = null;

@Override

public void execute(Tuple arg0) {

// TODO Auto-generated method stub

String word = arg0.getStringByField("word");

Long count = arg0.getLongByField("count");

this.counts.put(word, count);

}


@Override

public void prepare(Map arg0, TopologyContext arg1, OutputCollector arg2) {

// TODO Auto-generated method stub

this.counts = new HashMap<String, Long>();

}


@Override

public void declareOutputFields(OutputFieldsDeclarer arg0) {

// TODO Auto-generated method stub

System.out.println("====================== This is result declare ================");

}

public void cleanup()

{

System.out.println("====================== Result ========================");

List<String> keys = new ArrayList<String>();

keys.addAll(this.counts.keySet());

Collections.sort(keys);

for (String key : keys)

{

System.out.println("======> " + key + "=======>>>>>>" + this.counts.get(key));

}

System.out.println("====================== Result ========================");

}


}




토폴로지 구현

이게 java 로 말하면 main 인듯.

토폴로지 부분을 보면 SPOUT 에들어간 인스턴스 넣고 , 이놈이 다음 볼트에 들어가고 , 그놈이 또 다음볼트 , 이놈이 또 다음볼트 이렇게 

들어가는것처럼 보인다.


해당 책을 가지고 있다면 글에도 써있겠지만 로컬테스트에선 이상없는데 난 일단 운영서버처럼 서버구성후 클러스터로 돌려서 그런지

이게 무한대로 돌더라~ 


그래서 아래 토폴로지 소스의 빨간색부분을 보면 이게 출력하는 매쏘드 인데.

이걸 직접 호출함. 아무튼 그런거같음 ㅋ


그러니 책있는 사람중에 노드 구현해서 테스트하는 사람은 . 저거 넣어줘야 출력이 될것임.


public class TestTolpo {


private static final String SENDENCE_SPOUT_ID = "test_spout_id";

private static final String SPLIT_BOLT_ID = "test_split_bolt_id";

private static final String COUNT_BOLT_ID = "test_count_bolt_id";

private static final String RESULT_BOLT_ID = "test_result_bolt_id";

private static final String TOPOL_NAME = "tpol_name";

public static void main(String[] args) throws Exception {

TestSpout ts = new TestSpout();

TestBolt tb1 = new TestBolt();

Test2Bolt tb2 = new Test2Bolt();

ResultBolt rs = new ResultBolt();

TopologyBuilder build = new TopologyBuilder();

System.out.println("======================== bolt set ========================== ");

build.setSpout(SENDENCE_SPOUT_ID, ts);

build.setBolt(SPLIT_BOLT_ID, tb1).shuffleGrouping(SENDENCE_SPOUT_ID);

build.setBolt(COUNT_BOLT_ID, tb2).fieldsGrouping(SPLIT_BOLT_ID, new Fields("word"));

build.setBolt(RESULT_BOLT_ID, rs).globalGrouping(COUNT_BOLT_ID);

Config cf = new Config();

System.out.println("======================== cluster regist ========================== ");

LocalCluster cluster = new LocalCluster();

cluster.submitTopology(TOPOL_NAME,cf,build.createTopology());

System.out.println("======================== submit ========================== ");

waitForSeconds(20);

System.out.println("======================== 10 s ========================== ");

cluster.killTopology(TOPOL_NAME);

rs.cleanup();

System.out.println("======================== kill ========================== ");

cluster.shutdown();

System.out.println("======================== shutdown ========================== ");

}

public static void waitForSeconds(int seconds) {

        try {

            Thread.sleep(seconds * 1000);

        } catch (InterruptedException e) {

        } 

    }

}




위의 소스를 가지고 jar로 만들어준다음 ( 난 maven 씀 )

storm 토폴로지에 등록시켜서 실행해본다.

 ./storm jar /home/hadoop/chapter1-0.0.1-SNAPSHOT.jar storm.blueprint.chapter1.TestTolpo 


이러면 자바로 뭐 막 이것저것 쭉쭉 등록하고 어쩌구 저쩌구 실행이 되는과정이 나온다. ㅋ 

======================== bolt set ==========================

======================== cluster regist ==========================

2126 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT

2130 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:host.name=os1.local

2130 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_77

2130 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.home=/apps/j2se/jre

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.class.path=/apps/strm/lib/storm-core-0.9.6.jar:/apps/strm/lib/ring-jetty-adapter-0.3.11.jar:/apps/strm/lib/clout-1.0.1.jar:/apps/strm/lib/joda-time-2.0.jar:/apps/strm/lib/

math.numeric-tower-0.0.1.jar:/apps/strm/lib/clojure-1.5.1.jar:/apps/strm/lib/jline-2.11.jar:/apps/strm/lib/compojure-1.1.3.jar:/apps/strm/lib/logback-core-1.0.13.jar:/apps/strm/lib/commons-codec-1.6.jar:/apps/strm/lib/jetty-6.1.26.jar:/apps/strm/lib/kr

yo-2.21.jar:/apps/strm/lib/ring-core-1.1.5.jar:/apps/strm/lib/disruptor-2.10.4.jar:/apps/strm/lib/commons-logging-1.1.3.jar:/apps/strm/lib/core.incubator-0.1.0.jar:/apps/strm/lib/logback-classic-1.0.13.jar:/apps/strm/lib/jetty-util-6.1.26.jar:/apps/str

m/lib/hiccup-0.3.6.jar:/apps/strm/lib/commons-fileupload-1.2.1.jar:/apps/strm/lib/objenesis-1.2.jar:/apps/strm/lib/commons-io-2.4.jar:/apps/strm/lib/json-simple-1.1.jar:/apps/strm/lib/commons-lang-2.5.jar:/apps/strm/lib/ring-devel-0.3.11.jar:/apps/strm

/lib/ring-servlet-0.3.11.jar:/apps/strm/lib/servlet-api-2.5.jar:/apps/strm/lib/tools.cli-0.2.4.jar:/apps/strm/lib/asm-4.0.jar:/apps/strm/lib/carbonite-1.4.0.jar:/apps/strm/lib/tools.logging-0.2.3.jar:/apps/strm/lib/tools.macro-0.1.0.jar:/apps/strm/lib/

slf4j-api-1.7.5.jar:/apps/strm/lib/snakeyaml-1.11.jar:/apps/strm/lib/clj-stacktrace-0.2.2.jar:/apps/strm/lib/clj-time-0.4.1.jar:/apps/strm/lib/chill-java-0.3.5.jar:/apps/strm/lib/reflectasm-1.07-shaded.jar:/apps/strm/lib/commons-exec-1.1.jar:/apps/strm

/lib/log4j-over-slf4j-1.6.6.jar:/apps/strm/lib/minlog-1.2.jar:/apps/strm/lib/jgrapht-core-0.9.0.jar:/home/hadoop/chapter1-0.0.1-SNAPSHOT.jar:/apps/strm/conf:/apps/strm/bin

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/local/lib:/opt/local/lib:/usr/lib

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:os.name=Linux

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:os.arch=amd64

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:os.version=3.10.0-327.10.1.el7.x86_64

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:user.name=hadoop

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:user.home=/home/hadoop

2131 [main] INFO  org.apache.storm.zookeeper.ZooKeeper - Client environment:user.dir=/apps/strm/bin

2144 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT

2145 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:host.name=os1.local

2145 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.version=1.8.0_77

2145 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.vendor=Oracle Corporation

2145 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.home=/apps/j2se/jre

2148 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.class.path=/apps/strm/lib/storm-core-0.9.6.jar:/apps/strm/lib/ring-jetty-adapter-0.3.11.jar:/apps/strm/lib/clout-1.0.1.jar:/apps/strm/lib/joda-time-2.0.jar:/a

pps/strm/lib/math.numeric-tower-0.0.1.jar:/apps/strm/lib/clojure-1.5.1.jar:/apps/strm/lib/jline-2.11.jar:/apps/strm/lib/compojure-1.1.3.jar:/apps/strm/lib/logback-core-1.0.13.jar:/apps/strm/lib/commons-codec-1.6.jar:/apps/strm/lib/jetty-6.1.26.jar:/app

s/strm/lib/kryo-2.21.jar:/apps/strm/lib/ring-core-1.1.5.jar:/apps/strm/lib/disruptor-2.10.4.jar:/apps/strm/lib/commons-logging-1.1.3.jar:/apps/strm/lib/core.incubator-0.1.0.jar:/apps/strm/lib/logback-classic-1.0.13.jar:/apps/strm/lib/jetty-util-6.1.26.

jar:/apps/strm/lib/hiccup-0.3.6.jar:/apps/strm/lib/commons-fileupload-1.2.1.jar:/apps/strm/lib/objenesis-1.2.jar:/apps/strm/lib/commons-io-2.4.jar:/apps/strm/lib/json-simple-1.1.jar:/apps/strm/lib/commons-lang-2.5.jar:/apps/strm/lib/ring-devel-0.3.11.j

ar:/apps/strm/lib/ring-servlet-0.3.11.jar:/apps/strm/lib/servlet-api-2.5.jar:/apps/strm/lib/tools.cli-0.2.4.jar:/apps/strm/lib/asm-4.0.jar:/apps/strm/lib/carbonite-1.4.0.jar:/apps/strm/lib/tools.logging-0.2.3.jar:/apps/strm/lib/tools.macro-0.1.0.jar:/a

pps/strm/lib/slf4j-api-1.7.5.jar:/apps/strm/lib/snakeyaml-1.11.jar:/apps/strm/lib/clj-stacktrace-0.2.2.jar:/apps/strm/lib/clj-time-0.4.1.jar:/apps/strm/lib/chill-java-0.3.5.jar:/apps/strm/lib/reflectasm-1.07-shaded.jar:/apps/strm/lib/commons-exec-1.1.j

ar:/apps/strm/lib/log4j-over-slf4j-1.6.6.jar:/apps/strm/lib/minlog-1.2.jar:/apps/strm/lib/jgrapht-core-0.9.0.jar:/home/hadoop/chapter1-0.0.1-SNAPSHOT.jar:/apps/strm/conf:/apps/strm/bin

2148 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.library.path=/usr/local/lib:/opt/local/lib:/usr/lib

2148 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.io.tmpdir=/tmp

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:java.compiler=<NA>

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:os.name=Linux

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:os.arch=amd64

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:os.version=3.10.0-327.10.1.el7.x86_64

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:user.name=hadoop

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:user.home=/home/hadoop

2149 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Server environment:user.dir=/apps/strm/bin

2993 [main] INFO  org.apache.storm.zookeeper.server.ZooKeeperServer - Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 datadir /tmp/0ff07ea0-be81-44fb-a9e1-c813c71bce61/version-2 snapdir /tmp/0ff07ea0-be81-44fb-a9e1-c813

c71bce61/version-2

3007 [main] INFO  org.apache.storm.zookeeper.server.NIOServerCnxnFactory - binding to port 0.0.0.0/0.0.0.0:2000

3014 [main] INFO  backtype.storm.zookeeper - Starting inprocess zookeeper at port 2000 and dir /tmp/0ff07ea0-be81-44fb-a9e1-c813c71bce61

3284 [main] INFO  backtype.storm.daemon.nimbus - Starting Nimbus with conf {"dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.tick.tuple.freq.secs" nil, "topology.builtin.metrics.bucket.size.secs" 60, "topology.fall.back.on.java.serialization"

 true, "topology.max.error.report.per.interval" 5, "zmq.linger.millis" 0, "topology.skip.missing.kryo.registrations" true, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reas

sign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts" "-Xmx128m", "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "topology.e

xecutor.send.buffer.size" 1024, "storm.local.dir" "/tmp/6ab89940-328b-4454-b360-4dbe4e7dabc3", "storm.messaging.netty.buffer_size" 5242880, "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.

secs" 600, "nimbus.inbox.jar.expiration.secs" 3600, "drpc.worker.threads" 64, "storm.meta.serialization.delegate" "backtype.storm.serialization.DefaultSerializationDelegate", "topology.worker.shared.thread.pool.size" 4, "nimbus.host" "192.168.0.111", "

storm.messaging.netty.min_wait_ms" 100, "storm.zookeeper.port" 2000, "transactional.zookeeper.port" nil, "topology.executor.receive.buffer.size" 1024, "transactional.zookeeper.servers" nil, "storm.zookeeper.root" "/storm", "storm.zookeeper.retry.interv

alceiling.millis" 30000, "supervisor.enable" true, "storm.messaging.netty.server_worker_threads" 1, "storm.zookeeper.servers" ["localhost"], "transactional.zookeeper.root" "/transactional", "topology.acker.executors" nil, "topology.transfer.buffer.size

" 1024, "topology.worker.childopts" nil, "drpc.queue.size" 128, "worker.childopts" "-Xmx768m", "supervisor.heartbeat.frequency.secs" 5, "topology.error.throttle.interval.secs" 10, "zmq.hwm" 0, "drpc.port" 3772, "supervisor.monitor.frequency.secs" 3, "d

rpc.childopts" "-Xmx768m", "topology.receiver.buffer.size" 8, "task.heartbeat.frequency.secs" 3, "topology.tasks" nil, "storm.messaging.netty.



중간은 열라 길어서 패스 ~ ㅡ_ㅡ;;;;;;



====================== Result ========================

======> And=======>>>>>>1213

======> Gave=======>>>>>>1213

======> Oh=======>>>>>>1212

======> Oh,=======>>>>>>1213

======> O셞r=======>>>>>>2425

======> What=======>>>>>>1213

======> Whose=======>>>>>>1213

======> air,=======>>>>>>1213

======> and=======>>>>>>2425

======> at=======>>>>>>1213

======> banner=======>>>>>>1212

======> bombs=======>>>>>>1213

======> brave?=======>>>>>>1212

======> bri=======>>>>>>1213

======> broad=======>>>>>>1213

======> bursting=======>>>>>>1213

======> by=======>>>>>>1213

======> can=======>>>>>>1213

======> dawn셲=======>>>>>>1213

======> does=======>>>>>>1212

======> early=======>>>>>>1213

======> fight,=======>>>>>>1213

======> flag=======>>>>>>1213

======> free=======>>>>>>1212

======> gallantly=======>>>>>>1213

======> ght=======>>>>>>1213

======> glare,=======>>>>>>1213

======> gleaming?=======>>>>>>1213

======> hailed=======>>>>>>1213

======> home=======>>>>>>1212

======> in=======>>>>>>1213

======> land=======>>>>>>1212

======> last=======>>>>>>1213

======> light,=======>>>>>>1213

======> night=======>>>>>>1213

======> of=======>>>>>>2424

======> our=======>>>>>>1213

======> perilous=======>>>>>>1213

======> proof=======>>>>>>1213

======> proudly=======>>>>>>1213

======> ramparts=======>>>>>>1213

======> rockets셱ed=======>>>>>>1213

======> say=======>>>>>>1213

======> say,=======>>>>>>1212

======> see,=======>>>>>>1213

======> so=======>>>>>>2426

======> spangled=======>>>>>>1212

======> star=======>>>>>>1212

======> stars,=======>>>>>>1213

======> still=======>>>>>>1213

======> streaming?=======>>>>>>1213

======> stripes=======>>>>>>1213

======> that=======>>>>>>2425

======> the=======>>>>>>13339

======> there.=======>>>>>>1213

======> through=======>>>>>>2426

======> twilight셲=======>>>>>>1213

======> was=======>>>>>>1213

======> watched,=======>>>>>>1213

======> wave=======>>>>>>1212

======> we=======>>>>>>2426

======> were=======>>>>>>1213

======> yet=======>>>>>>1212

======> you=======>>>>>>1213

====================== Result ========================

55332 [Thread-4] INFO  backtype.storm.daemon.executor - Shut down executor test_result_bolt_id:[3 3]

55333 [Thread-4] INFO  backtype.storm.daemon.executor - Shutting down executor test_split_bolt_id:[4 4]

55334 [Thread-12-disruptor-executor[4 4]-send-queue] INFO  backtype.storm.util - Async loop interrupted!

55334 [Thread-13-test_split_bolt_id] INFO  backtype.storm.util - Async loop interrupted!

55335 [Thread-4] INFO  backtype.storm.daemon.executor - Shut down executor test_split_bolt_id:[4 4]

55336 [Thread-4] INFO  backtype.storm.daemon.executor - Shutting down executor test_spout_id:[5 5]

55339 [Thread-15-test_spout_id] INFO  backtype.storm.util - Async loop interrupted!

55339 [Thread-14-disruptor-executor[5 5]-send-queue] INFO  backtype.storm.util - Async loop interrupted!

55341 [Thread-4] INFO  backtype.storm.daemon.executor - Shut down executor test_spout_id:[5 5]

55342 [Thread-4] INFO  backtype.storm.daemon.executor - Shutting down executor __system:[-1 -1]

55342 [Thread-17-__system] INFO  backtype.storm.util - Async loop interrupted!

55343 [Thread-16-disruptor-executor[-1 -1]-send-queue] INFO  backtype.storm.util - Async loop interrupted!

55343 [Thread-4] INFO  backtype.storm.daemon.executor - Shut down executor __system:[-1 -1]

Storm 은개념이 안서면 쓰기힘들듯.

저작자 표시
신고
Posted by ORACLE,DBA,BIG,DATA,JAVA 흑풍전설

RabbitMQ vs KafKa를 테스트한 자료가 외국블로그에 소개가 되는글을 우연히 본후 

이 두가지를 동시에 사용하면서 메세지 전송을 위한 작업을 진행해보고자 한다.


그래서 우선 요거부터 기본설치를 한다.


카프카 프로젝트 : http://kafka.apache.org

설치 버전 : 0.9.0.1


* 구성형태


사실 이건 설치고자시고 할것도 없더라.

그냥 바로 사용해되 된다. ㅎㅎ... 우선 나같은 경우는 zookeeper 가 있는 상태이고 사용중이기때문에 (hbase에서) 

그냥 바로 이용한다.


카프카에서는 Topic 이라고 하는가본데 이 Topic 을 등록하고 그 Topic 을 통해서 메세지를 주고받는것인가보더라.


내가 구성한 형태는 아래와 같다.


* 카프카를 주키퍼가 있는 서버에 같이 설치를 했으니 그림은 아래와 같은형태이며 

  주키퍼가 이 카프카들의 통신을 해주는 녀석이 되는것이다.


  아래 은색의 원통이 주키퍼가 되며 

  검은색서버같은게 노드가 되겠다 ㅡ_ㅡ;;; ( 저렇게 링형으로 통신하는거 아님 ;;;;; 그냥 저들끼리 연결대있다 라고 표시만 한거임 )


  실제로는 난 5대만 설치해서 사용한다. 

  (hadoop 과 hbase의 마스터 노드가 1번인지라 1번은 안힘들게하려구 ㅋ )

  

  
















* 설정 


config 디렉토리에 server.properties 을 복사해서 설정파일을 카프카를 설치할 노드수만큼 복사해서 이름을 바꾼다.


참고로난 아래와 같다. 

아래 콘솔 스크린샷을 보면 server1.properties ~ server5.properties5 까지가 보일껀데 

저게 각 5대의 노드에 설정할 설정파일이다. 

server.properties 를 복사해서 설정파일을 저렇게 만들고 각파일을 각노드에 맞게 돌어갈수있게 수정하고 각서버에 복사함.




server.properties  ( 1~5번까지 ) ~ 설정변경한 부분


아래 내용은 2번서버다. ( broker.id는 1,2,3,4,5 각 파일별로 )

port 도 9093 ~ 9097까지 다르게 

host.name은 당연히 각 서버명 

zookeeper.connect 는 주키퍼 연결서버에 맞게. ㅋ 주었다.


broker.id=1 

port=9093

host.name=os2.local

zookeeper.connect=os2.local:2181,os3.local:2181,os4.local:2181,os5.local:2181,os6.local:2181




* 터미널상에서 실행한 명령


Topic 만들기 

[hadoop@os2 config]$ ./kafka-topics.sh --create --zookeeper os2.local:2181 --partitions 20 --replication-factor 5 --topic test2  


각서버 스타트~ 

1번 /apps/kafka/bin/kafka-server-start.sh /apps/kafka/config/server1.properties

2번 /apps/kafka/bin/kafka-server-start.sh /apps/kafka/config/server2.properties

3번 /apps/kafka/bin/kafka-server-start.sh /apps/kafka/config/server3.properties

4번 /apps/kafka/bin/kafka-server-start.sh /apps/kafka/config/server4.properties

5번 /apps/kafka/bin/kafka-server-start.sh /apps/kafka/config/server5.properties



------------------------------------------------------------------------------------------------------------------------------------------


그리고나서 Producer가 될곳 아무데나 프로세스를 띄우고. ( 난 첫번째 서버에서 띄움 )

[hadoop@os2 bin]$ ./kafka-console-producer.sh --broker-list os2.local:9092 --topic test2

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/home/hadoop/classes/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/hadoop/classes/logback-classic-1.1.2.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/apps/kafka/libs/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]


이렇게 대기중~



------------------------------------------------------------------------------------------------------------------------------------------


그리고 Consumer 가 될곳도 프로세스를 띄우자 ㅋ 

아래 예제는 다섯번째 서버

[hadoop@os6 bin]$ ./kafka-console-consumer.sh --zookeeper os6.local:2181 --topic test2 --from-beginning

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/home/hadoop/classes/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/hadoop/classes/logback-classic-1.1.2.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/apps/kafka/libs/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]


Consumer 가 될놈을 난 예시로 3군데를 띄움 ( 아래 결과 사진 )

그리고 Producer 쪽에서 아무거나 입력을 하면 Consumer 쪽에서 짠짠하고 나온다. ㅋㅋㅋ



* 결과 


 192.168.0.112번이 Producer ( 발송하는놈 ) 가 되고 여기서 메세지를 입력하면 


 나머지 콘솔에서 그대로 출력을 한다. ( 이쪽은 Consumer 라고 부른다. ) 


저작자 표시
신고
Posted by ORACLE,DBA,BIG,DATA,JAVA 흑풍전설

RabbitMQ HelloWorld 를 찍어보기로 한다.

원래 이건 인터넷 서핑중에 우연히 발견한 오픈소스? 이다. 

원래 얼랭을 뒤져보다가. 발견한건데. 메세지 서버로 쓸만하다. 메세지 큐서버 라고 해야하나??? 

아무튼 내가 X라고 보내면 서버에서 메세지를 가지고 있다가 받는쪽에서 X라고 받는 이런형태더라.


아래와 같은 형태로 HelloWorld를 찍기로 했다.


사용한 RabbitMQ 버전 : 3.6.1

Java Client 버전 : 3.6.1 ( 이건 당연히 이클립스에 서버콘솔쪽에 classpath추가함 )

JDK : 1.8



192.168.0.5 : 내가 작업하는 컴퓨터 ( 이클립스에서 Console java 하나 만들어서 실행 )

192.168.0.111 : RabbitMQ 서버가 설치된 서버

Console Result : 192.168.0.111안에 자바로 실행한 결과 받는 콘솔.



https://www.rabbitmq.com/ 에 있는 tutorial 에서 helloworld 를 그대로 실행하면 아래처럼 에러가 날것이다.

Exception in thread "main" com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.

        at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:339)

        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:716)

        at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:760)

        at mqtest.main(mqtest.java:21)


그도 그럴것이 rabbitmqctl 로 help를 살펴보면 웬 사용자 추가, 호스트설정, 퍼미션 어쩌구 저쩌구등이 있다.

그래서 그것들을 추가함.

대충 그럴듯한것들을 추가해봤다 ㅋㅋ


id : testman 

pw : 1234

vhost : /testhost

퍼미션은 전부를 준것같음 ( 인터넷 구글링 뒤져봤을땐 대충 그런거같음 ㅋㅋ 잘모르니;;; 나중에 자세히 파보면 또기록을 남길예정. ) 

[root@os1 ~]# rabbitmqctl add_user testman 1234

[root@os1 ~]# rabbitmqctl add_vhost /testhost

[root@os1 ~]# rabbitmqctl set_permissions -p /testhost testman ".*" ".*" ".*" 




192.168.0.111에 있는 자바소스 (받을놈)

import java.io.IOException;

import java.util.concurrent.TimeoutException;


import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Consumer;

import com.rabbitmq.client.Envelope;

import com.rabbitmq.client.AMQP;

import com.rabbitmq.client.DefaultConsumer;


public class mqrecv {

  private final static String QUEUE_NAME = "testqueue_namessssssss";


  public static void main(String[] argv)

      throws java.io.IOException,

             java.lang.InterruptedException {


    ConnectionFactory factory = new ConnectionFactory();

         factory.setHost("192.168.0.111");

            factory.setUsername("testman");

            factory.setPassword("1234");

            factory.setVirtualHost("/testhost");

    Connection connection;



        try {

                connection = factory.newConnection();



                Channel channel = connection.createChannel();


            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");




        Consumer consumer = new DefaultConsumer(channel) {

              @Override

              public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)

                  throws IOException {

                String message = new String(body, "UTF-8");

                System.out.println(" [x] Received '" + message + "'");

              }

            };

            channel.basicConsume(QUEUE_NAME, true, consumer);



        } catch (TimeoutException e) {


                e.printStackTrace();

        }



}

}


위에꺼 컴파일 하고 실행하면 아래처럼 나온다.

받을것대기중인상태.




그리고나서~



아래 보내는부분 만들기.


192.168.0.5인 내가 작업하는 곳 이클립스에서 사용한 소스 (보낼놈)


import java.util.concurrent.TimeoutException;


import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;


public class mqsend {

private final static String QUEUE_NAME = "testqueue_namessssssss";

public static void main(String[] args) throws java.io.IOException 

{

    ConnectionFactory factory = new ConnectionFactory();

    factory.setHost("192.168.0.111");

    factory.setUsername("testman");

    factory.setPassword("1234");

    factory.setVirtualHost("/testhost");

    Connection connection;

try {

connection = factory.newConnection();

Channel channel = connection.createChannel();

    channel.queueDeclare(QUEUE_NAME, false, false, false, null);

    String message = "Hello Ocmpromaster hahahahahahah !!!!!!";

    channel.basicPublish("", QUEUE_NAME, null, message.getBytes());

    System.out.println(" [x] Sent '" + message + "'");

    channel.close();

    connection.close();

    

} catch (TimeoutException e) {

e.printStackTrace();

}

    

}

}


위의 소스를 만들고 실행(메세지보내기) 하면 아래 이클립스 OutPut쪽에 send메세지가 보임.



위의 받는쪽 결과에 메세지에 이클립스에서 보낸 메세지가 바로 보인다 ㅋㅋㅋ~~~~ 오~~~~~~~~~~~~~




이제 이걸로 뭘할까 ㅡ_ㅡ;;;;;;;;;

우선 tutorial 부분몇개보고 내가 테스트중인 6노드 서버에 다 설치를 해서 뭔가를 해볼려고 한다. ~ 뭔가 쓸모가 있을듯. ㅎㅎ...

 

저작자 표시
신고
Posted by ORACLE,DBA,BIG,DATA,JAVA 흑풍전설

Rabiit MQ 설치를 해보기로 하면서 이왕 할꺼 erlang 을 해보기로 함.


RabbitMQ : https://www.rabbitmq.com/

얼랭 사이트 : https://www.erlang-solutions.com/


Rabbit MQ 다운로드에 java client 말고 erlang 이 있길래 설치하는것임;;;;;


설치방법에 yum으로 설치하는것이 있길래 설치 시도.

repository가 없는것같아서 centos 7 repo 로 뒤져보고 rpm 받아서 repo추가한후 설치한 과정을 기록한다.

[root@os1 hadoop]# wget http://dl.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-5.noarch.rpm

--2016-04-09 07:51:41--  http://dl.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-5.noarch.rpm

Resolving dl.fedoraproject.org (dl.fedoraproject.org)... 209.132.181.24, 209.132.181.27, 209.132.181.26, ...

Connecting to dl.fedoraproject.org (dl.fedoraproject.org)|209.132.181.24|:80... connected.

HTTP request sent, awaiting response... 200 OK

Length: 14524 (14K) [application/x-rpm]

Saving to: 쁢pel-release-7-5.noarch.rpm


100%[=====================================================================================>] 14,524      61.8KB/s   in 0.2s   


2016-04-09 07:51:42 (61.8 KB/s) - 쁢pel-release-7-5.noarch.rpmsaved [14524/14524]


[root@os1 hadoop]# rpm -ivh epel-release-7-5.noarch.rpm 

warning: epel-release-7-5.noarch.rpm: Header V3 RSA/SHA256 Signature, key ID 352c64e5: NOKEY

Preparing...                          ################################# [100%]

Updating / installing...

   1:epel-release-7-5                 ################################# [100%]

[root@os1 hadoop]# yum repolist 

Loaded plugins: fastestmirror, langpacks

epel/x86_64/metalink                                                                                    | 5.3 kB  00:00:00     

epel                                                                                                    | 4.3 kB  00:00:00     

epel/x86_64/updateinfo         FAILED                                          

http://ftp.jaist.ac.jp/pub/Linux/Fedora/epel/7/x86_64/repodata/a5c59d9418d5f1fd31c97c52897caa9d9cdb34125183aa808272846705d6f348-updateinfo.xml.bz2: [Errno 14] HTTP Error 404 - Not Found

Trying other mirror.

To address this issue please refer to the below knowledge base article 


https://access.redhat.com/articles/1320623


If above article doesn't help to resolve this issue please create a bug on https://bugs.centos.org/


(1/3): epel/x86_64/updateinfo                                                                           | 524 kB  00:00:00     

(2/3): epel/x86_64/group_gz                                                                             | 169 kB  00:00:01     

(3/3): epel/x86_64/primary_db                                                                           | 4.0 MB  00:00:02     

Loading mirror speeds from cached hostfile

 * base: ftp.neowiz.com

 * epel: mirror.premi.st

 * extras: ftp.neowiz.com

 * updates: ftp.neowiz.com

repo id                                      repo name                                                                   status

base/7/x86_64                                CentOS-7 - Base                                                             9,007

*epel/x86_64                                 Extra Packages for Enterprise Linux 7 - x86_64                              9,739

extras/7/x86_64                              CentOS-7 - Extras                                                             264

updates/7/x86_64                             CentOS-7 - Updates                                                          1,241

repolist: 20,251

[root@os1 hadoop]# yum install erlang

Loaded plugins: fastestmirror, langpacks

Loading mirror speeds from cached hostfile

 * base: ftp.neowiz.com

 * epel: mirror.premi.st

 * extras: ftp.neowiz.com

 * updates: ftp.neowiz.com

Resolving Dependencies

--> Running transaction check

---> Package erlang.x86_64 0:R16B-03.16.el7 will be installed

--> Processing Dependency: erlang-xmerl(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-wx(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-webtool(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-typer(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-tv(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-tools(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-toolbar(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-test_server(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-syntax_tools(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-stdlib(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-ssl(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-ssh(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-snmp(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-sasl(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-runtime_tools(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-reltool(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-public_key(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-pman(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-percept(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-parsetools(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-otp_mibs(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-os_mon(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-orber(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-odbc(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-observer(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-mnesia(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-megaco(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-kernel(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-jinterface(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-inets(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-ic(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-hipe(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-gs(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-examples(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-eunit(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-et(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-erts(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-erl_interface(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-erl_docgen(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-eldap(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-edoc(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-diameter(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-dialyzer(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-debugger(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-crypto(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosTransactions(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosTime(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosProperty(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosNotification(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosFileTransfer(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosEventDomain(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-cosEvent(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-compiler(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-common_test(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-asn1(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Processing Dependency: erlang-appmon(x86-64) = R16B-03.16.el7 for package: erlang-R16B-03.16.el7.x86_64

--> Running transaction check

---> Package erlang-appmon.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-asn1.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-common_test.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-compiler.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosEvent.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosEventDomain.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosFileTransfer.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosNotification.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosProperty.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosTime.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-cosTransactions.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-crypto.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-debugger.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-dialyzer.x86_64 0:R16B-03.16.el7 will be installed

--> Processing Dependency: graphviz for package: erlang-dialyzer-R16B-03.16.el7.x86_64

---> Package erlang-diameter.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-edoc.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-eldap.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-erl_docgen.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-erl_interface.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-erts.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-et.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-eunit.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-examples.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-gs.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-hipe.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-ic.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-inets.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-jinterface.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-kernel.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-megaco.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-mnesia.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-observer.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-odbc.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-orber.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-os_mon.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-otp_mibs.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-parsetools.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-percept.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-pman.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-public_key.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-reltool.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-runtime_tools.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-sasl.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-snmp.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-ssh.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-ssl.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-stdlib.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-syntax_tools.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-test_server.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-toolbar.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-tools.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-tv.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-typer.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-webtool.x86_64 0:R16B-03.16.el7 will be installed

---> Package erlang-wx.x86_64 0:R16B-03.16.el7 will be installed

--> Processing Dependency: libwx_gtk2u_xrc-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_stc-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_html-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_gl-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_core-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_aui-2.8.so.0(WXU_2.8.5)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_aui-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_adv-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_baseu-2.8.so.0(WXU_2.8)(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_xrc-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_stc-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_html-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_gl-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_core-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_aui-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_gtk2u_adv-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_baseu_xml-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

--> Processing Dependency: libwx_baseu-2.8.so.0()(64bit) for package: erlang-wx-R16B-03.16.el7.x86_64

---> Package erlang-xmerl.x86_64 0:R16B-03.16.el7 will be installed

--> Running transaction check

---> Package graphviz.x86_64 0:2.30.1-19.el7 will be installed

---> Package wxBase.x86_64 0:2.8.12-20.el7 will be installed

---> Package wxGTK.x86_64 0:2.8.12-20.el7 will be installed

---> Package wxGTK-gl.x86_64 0:2.8.12-20.el7 will be installed

--> Finished Dependency Resolution


Dependencies Resolved


===============================================================================================================================

 Package                                 Arch                    Version                           Repository             Size

===============================================================================================================================

Installing:

 erlang                                  x86_64                  R16B-03.16.el7                    epel                   31 k

Installing for dependencies:

 erlang-appmon                           x86_64                  R16B-03.16.el7                    epel                  139 k

 erlang-asn1                             x86_64                  R16B-03.16.el7                    epel                  758 k

 erlang-common_test                      x86_64                  R16B-03.16.el7                    epel                  720 k

 erlang-compiler                         x86_64                  R16B-03.16.el7                    epel                  1.0 M

 erlang-cosEvent                         x86_64                  R16B-03.16.el7                    epel                  155 k

 erlang-cosEventDomain                   x86_64                  R16B-03.16.el7                    epel                  120 k

 erlang-cosFileTransfer                  x86_64                  R16B-03.16.el7                    epel                  174 k

 erlang-cosNotification                  x86_64                  R16B-03.16.el7                    epel                  739 k

 erlang-cosProperty                      x86_64                  R16B-03.16.el7                    epel                  167 k

 erlang-cosTime                          x86_64                  R16B-03.16.el7                    epel                  112 k

 erlang-cosTransactions                  x86_64                  R16B-03.16.el7                    epel                  172 k

 erlang-crypto                           x86_64                  R16B-03.16.el7                    epel                   85 k

 erlang-debugger                         x86_64                  R16B-03.16.el7                    epel                  546 k

 erlang-dialyzer                         x86_64                  R16B-03.16.el7                    epel                  656 k

 erlang-diameter                         x86_64                  R16B-03.16.el7                    epel                  657 k

 erlang-edoc                             x86_64                  R16B-03.16.el7                    epel                  321 k

 erlang-eldap                            x86_64                  R16B-03.16.el7                    epel                  102 k

 erlang-erl_docgen                       x86_64                  R16B-03.16.el7                    epel                  154 k

 erlang-erl_interface                    x86_64                  R16B-03.16.el7                    epel                  185 k

 erlang-erts                             x86_64                  R16B-03.16.el7                    epel                  2.5 M

 erlang-et                               x86_64                  R16B-03.16.el7                    epel                  225 k

 erlang-eunit                            x86_64                  R16B-03.16.el7                    epel                  153 k

 erlang-examples                         x86_64                  R16B-03.16.el7                    epel                  1.1 M

 erlang-gs                               x86_64                  R16B-03.16.el7                    epel                  628 k

 erlang-hipe                             x86_64                  R16B-03.16.el7                    epel                  2.4 M

 erlang-ic                               x86_64                  R16B-03.16.el7                    epel                  885 k

 erlang-inets                            x86_64                  R16B-03.16.el7                    epel                  800 k

 erlang-jinterface                       x86_64                  R16B-03.16.el7                    epel                  100 k

 erlang-kernel                           x86_64                  R16B-03.16.el7                    epel                  1.1 M

 erlang-megaco                           x86_64                  R16B-03.16.el7                    epel                  5.5 M

 erlang-mnesia                           x86_64                  R16B-03.16.el7                    epel                  700 k

 erlang-observer                         x86_64                  R16B-03.16.el7                    epel                  557 k

 erlang-odbc                             x86_64                  R16B-03.16.el7                    epel                   69 k

 erlang-orber                            x86_64                  R16B-03.16.el7                    epel                  946 k

 erlang-os_mon                           x86_64                  R16B-03.16.el7                    epel                  114 k

 erlang-otp_mibs                         x86_64                  R16B-03.16.el7                    epel                   32 k

 erlang-parsetools                       x86_64                  R16B-03.16.el7                    epel                  178 k

 erlang-percept                          x86_64                  R16B-03.16.el7                    epel                  151 k

 erlang-pman                             x86_64                  R16B-03.16.el7                    epel                  113 k

 erlang-public_key                       x86_64                  R16B-03.16.el7                    epel                  537 k

 erlang-reltool                          x86_64                  R16B-03.16.el7                    epel                  359 k

 erlang-runtime_tools                    x86_64                  R16B-03.16.el7                    epel                  179 k

 erlang-sasl                             x86_64                  R16B-03.16.el7                    epel                  294 k

 erlang-snmp                             x86_64                  R16B-03.16.el7                    epel                  1.5 M

 erlang-ssh                              x86_64                  R16B-03.16.el7                    epel                  394 k

 erlang-ssl                              x86_64                  R16B-03.16.el7                    epel                  587 k

 erlang-stdlib                           x86_64                  R16B-03.16.el7                    epel                  2.2 M

 erlang-syntax_tools                     x86_64                  R16B-03.16.el7                    epel                  336 k

 erlang-test_server                      x86_64                  R16B-03.16.el7                    epel                  281 k

 erlang-toolbar                          x86_64                  R16B-03.16.el7                    epel                   55 k

 erlang-tools                            x86_64                  R16B-03.16.el7                    epel                  565 k

 erlang-tv                               x86_64                  R16B-03.16.el7                    epel                  397 k

 erlang-typer                            x86_64                  R16B-03.16.el7                    epel                   66 k

 erlang-webtool                          x86_64                  R16B-03.16.el7                    epel                   50 k

 erlang-wx                               x86_64                  R16B-03.16.el7                    epel                  2.9 M

 erlang-xmerl                            x86_64                  R16B-03.16.el7                    epel                  997 k

 graphviz                                x86_64                  2.30.1-19.el7                     base                  1.3 M

 wxBase                                  x86_64                  2.8.12-20.el7                     epel                  588 k

 wxGTK                                   x86_64                  2.8.12-20.el7                     epel                  2.9 M

 wxGTK-gl                                x86_64                  2.8.12-20.el7                     epel                   34 k


Transaction Summary

===============================================================================================================================

Install  1 Package (+60 Dependent packages)


Total download size: 41 M

Installed size: 85 M

Is this ok [y/d/N]: y

Downloading packages:

warning: /var/cache/yum/x86_64/7/epel/packages/erlang-R16B-03.16.el7.x86_64.rpm: Header V3 RSA/SHA256 Signature, key ID 352c64e5: NOKEY

Public key for erlang-R16B-03.16.el7.x86_64.rpm is not installed

(1/61): erlang-R16B-03.16.el7.x86_64.rpm                                                                |  31 kB  00:00:03     

(2/61): erlang-appmon-R16B-03.16.el7.x86_64.rpm                                                         | 139 kB  00:00:01     

(3/61): erlang-asn1-R16B-03.16.el7.x86_64.rpm                                                           | 758 kB  00:00:03     

(4/61): erlang-common_test-R16B-03.16.el7.x86_64.rpm                                                    | 720 kB  00:00:01     

(5/61): erlang-compiler-R16B-03.16.el7.x86_64.rpm                                                       | 1.0 MB  00:00:01     

(6/61): erlang-cosEvent-R16B-03.16.el7.x86_64.rpm                                                       | 155 kB  00:00:00     

(7/61): erlang-cosEventDomain-R16B-03.16.el7.x86_64.rpm                                                 | 120 kB  00:00:00     

(8/61): erlang-cosFileTransfer-R16B-03.16.el7.x86_64.rpm                                                | 174 kB  00:00:00     

(9/61): erlang-cosNotification-R16B-03.16.el7.x86_64.rpm                                                | 739 kB  00:00:01     

(10/61): erlang-cosProperty-R16B-03.16.el7.x86_64.rpm                                                   | 167 kB  00:00:00     

(11/61): erlang-cosTime-R16B-03.16.el7.x86_64.rpm                                                       | 112 kB  00:00:00     

(12/61): erlang-cosTransactions-R16B-03.16.el7.x86_64.rpm                                               | 172 kB  00:00:00     

(13/61): erlang-crypto-R16B-03.16.el7.x86_64.rpm                                                        |  85 kB  00:00:00     

(14/61): erlang-debugger-R16B-03.16.el7.x86_64.rpm                                                      | 546 kB  00:00:00     

(15/61): erlang-dialyzer-R16B-03.16.el7.x86_64.rpm                                                      | 656 kB  00:00:00     

(16/61): erlang-diameter-R16B-03.16.el7.x86_64.rpm                                                      | 657 kB  00:00:00     

(17/61): erlang-edoc-R16B-03.16.el7.x86_64.rpm                                                          | 321 kB  00:00:00     

(18/61): erlang-eldap-R16B-03.16.el7.x86_64.rpm                                                         | 102 kB  00:00:00     

(19/61): erlang-erl_docgen-R16B-03.16.el7.x86_64.rpm                                                    | 154 kB  00:00:00     

(20/61): erlang-erl_interface-R16B-03.16.el7.x86_64.rpm                                                 | 185 kB  00:00:00     

(21/61): erlang-erts-R16B-03.16.el7.x86_64.rpm                                                          | 2.5 MB  00:00:02     

(22/61): erlang-et-R16B-03.16.el7.x86_64.rpm                                                            | 225 kB  00:00:00     

(23/61): erlang-eunit-R16B-03.16.el7.x86_64.rpm                                                         | 153 kB  00:00:00     

(24/61): erlang-examples-R16B-03.16.el7.x86_64.rpm                                                      | 1.1 MB  00:00:01     

(25/61): erlang-gs-R16B-03.16.el7.x86_64.rpm                                                            | 628 kB  00:00:00     

(26/61): erlang-hipe-R16B-03.16.el7.x86_64.rpm                                                          | 2.4 MB  00:00:02     

(27/61): erlang-ic-R16B-03.16.el7.x86_64.rpm                                                            | 885 kB  00:00:01     

(28/61): erlang-inets-R16B-03.16.el7.x86_64.rpm                                                         | 800 kB  00:00:00     

(29/61): erlang-jinterface-R16B-03.16.el7.x86_64.rpm                                                    | 100 kB  00:00:00     

(30/61): erlang-kernel-R16B-03.16.el7.x86_64.rpm                                                        | 1.1 MB  00:00:01     

(31/61): erlang-megaco-R16B-03.16.el7.x86_64.rpm                                                        | 5.5 MB  00:00:03     

(32/61): erlang-mnesia-R16B-03.16.el7.x86_64.rpm                                                        | 700 kB  00:00:00     

(33/61): erlang-observer-R16B-03.16.el7.x86_64.rpm                                                      | 557 kB  00:00:00     

(34/61): erlang-odbc-R16B-03.16.el7.x86_64.rpm                                                          |  69 kB  00:00:00     

(35/61): erlang-orber-R16B-03.16.el7.x86_64.rpm                                                         | 946 kB  00:00:00     

(36/61): erlang-os_mon-R16B-03.16.el7.x86_64.rpm                                                        | 114 kB  00:00:00     

(37/61): erlang-otp_mibs-R16B-03.16.el7.x86_64.rpm                                                      |  32 kB  00:00:00     

(38/61): erlang-parsetools-R16B-03.16.el7.x86_64.rpm                                                    | 178 kB  00:00:00     

(39/61): erlang-percept-R16B-03.16.el7.x86_64.rpm                                                       | 151 kB  00:00:00     

(40/61): erlang-pman-R16B-03.16.el7.x86_64.rpm                                                          | 113 kB  00:00:00     

(41/61): erlang-public_key-R16B-03.16.el7.x86_64.rpm                                                    | 537 kB  00:00:00     

(42/61): erlang-reltool-R16B-03.16.el7.x86_64.rpm                                                       | 359 kB  00:00:00     

(43/61): erlang-runtime_tools-R16B-03.16.el7.x86_64.rpm                                                 | 179 kB  00:00:00     

(44/61): erlang-sasl-R16B-03.16.el7.x86_64.rpm                                                          | 294 kB  00:00:00     

(45/61): erlang-snmp-R16B-03.16.el7.x86_64.rpm                                                          | 1.5 MB  00:00:01     

(46/61): erlang-ssh-R16B-03.16.el7.x86_64.rpm                                                           | 394 kB  00:00:00     

(47/61): erlang-ssl-R16B-03.16.el7.x86_64.rpm                                                           | 587 kB  00:00:00     

(48/61): erlang-stdlib-R16B-03.16.el7.x86_64.rpm                                                        | 2.2 MB  00:00:01     

(49/61): erlang-syntax_tools-R16B-03.16.el7.x86_64.rpm                                                  | 336 kB  00:00:00     

(50/61): erlang-test_server-R16B-03.16.el7.x86_64.rpm                                                   | 281 kB  00:00:00     

(51/61): erlang-toolbar-R16B-03.16.el7.x86_64.rpm                                                       |  55 kB  00:00:00     

(52/61): erlang-tools-R16B-03.16.el7.x86_64.rpm                                                         | 565 kB  00:00:00     

(53/61): erlang-tv-R16B-03.16.el7.x86_64.rpm                                                            | 397 kB  00:00:00     

(54/61): erlang-typer-R16B-03.16.el7.x86_64.rpm                                                         |  66 kB  00:00:00     

(55/61): erlang-webtool-R16B-03.16.el7.x86_64.rpm                                                       |  50 kB  00:00:00     

(56/61): erlang-wx-R16B-03.16.el7.x86_64.rpm                                                            | 2.9 MB  00:00:02     

(57/61): graphviz-2.30.1-19.el7.x86_64.rpm                                                              | 1.3 MB  00:00:00     

(58/61): erlang-xmerl-R16B-03.16.el7.x86_64.rpm                                                         | 997 kB  00:00:00     

(59/61): wxBase-2.8.12-20.el7.x86_64.rpm                                                                | 588 kB  00:00:01     

(60/61): wxGTK-2.8.12-20.el7.x86_64.rpm                                                                 | 2.9 MB  00:00:10     

(61/61): wxGTK-gl-2.8.12-20.el7.x86_64.rpm                                                              |  34 kB  00:00:00     

-------------------------------------------------------------------------------------------------------------------------------

Total                                                                                          623 kB/s |  41 MB  00:01:07     

Retrieving key from file:///etc/pki/rpm-gpg/RPM-GPG-KEY-EPEL-7

Importing GPG key 0x352C64E5:

 Userid     : "Fedora EPEL (7) <epel@fedoraproject.org>"

 Fingerprint: 91e9 7d7c 4a5e 96f1 7f3e 888f 6a2f aea2 352c 64e5

 Package    : epel-release-7-5.noarch (installed)

 From       : /etc/pki/rpm-gpg/RPM-GPG-KEY-EPEL-7

Is this ok [y/N]: y

Running transaction check

Running transaction test

Transaction test succeeded

Running transaction

Warning: RPMDB altered outside of yum.

** Found 1 pre-existing rpmdb problem(s), 'yum check' output follows:

ant-1.9.2-9.el7.noarch has missing requires of java-devel >= ('0', '1.5.0', None)

  Installing : erlang-crypto-R16B-03.16.el7.x86_64                                                                        1/61 

  Installing : erlang-kernel-R16B-03.16.el7.x86_64                                                                        2/61 

  Installing : erlang-syntax_tools-R16B-03.16.el7.x86_64                                                                  3/61 

  Installing : erlang-erts-R16B-03.16.el7.x86_64                                                                          4/61 

  Installing : erlang-stdlib-R16B-03.16.el7.x86_64                                                                        5/61 

  Installing : erlang-compiler-R16B-03.16.el7.x86_64                                                                      6/61 

  Installing : erlang-hipe-R16B-03.16.el7.x86_64                                                                          7/61 

  Installing : erlang-gs-R16B-03.16.el7.x86_64                                                                            8/61 

  Installing : erlang-mnesia-R16B-03.16.el7.x86_64                                                                        9/61 

  Installing : erlang-runtime_tools-R16B-03.16.el7.x86_64                                                                10/61 

  Installing : erlang-snmp-R16B-03.16.el7.x86_64                                                                         11/61 

  Installing : erlang-xmerl-R16B-03.16.el7.x86_64                                                                        12/61 

  Installing : erlang-asn1-R16B-03.16.el7.x86_64                                                                         13/61 

  Installing : erlang-public_key-R16B-03.16.el7.x86_64                                                                   14/61 

  Installing : erlang-ssl-R16B-03.16.el7.x86_64                                                                          15/61 

  Installing : erlang-inets-R16B-03.16.el7.x86_64                                                                        16/61 

  Installing : erlang-orber-R16B-03.16.el7.x86_64                                                                        17/61 

  Installing : erlang-tools-R16B-03.16.el7.x86_64                                                                        18/61 

  Installing : erlang-sasl-R16B-03.16.el7.x86_64                                                                         19/61 

  Installing : erlang-cosEvent-R16B-03.16.el7.x86_64                                                                     20/61 

  Installing : wxBase-2.8.12-20.el7.x86_64                                                                               21/61 

  Installing : wxGTK-2.8.12-20.el7.x86_64                                                                                22/61 

  Installing : erlang-cosTime-R16B-03.16.el7.x86_64                                                                      23/61 

  Installing : erlang-cosNotification-R16B-03.16.el7.x86_64                                                              24/61 

  Installing : erlang-cosProperty-R16B-03.16.el7.x86_64                                                                  25/61 

  Installing : erlang-edoc-R16B-03.16.el7.x86_64                                                                         26/61 

  Installing : erlang-ssh-R16B-03.16.el7.x86_64                                                                          27/61 

  Installing : erlang-otp_mibs-R16B-03.16.el7.x86_64                                                                     28/61 

  Installing : erlang-pman-R16B-03.16.el7.x86_64                                                                         29/61 

  Installing : erlang-tv-R16B-03.16.el7.x86_64                                                                           30/61 

  Installing : erlang-os_mon-R16B-03.16.el7.x86_64                                                                       31/61 

  Installing : erlang-erl_docgen-R16B-03.16.el7.x86_64                                                                   32/61 

  Installing : erlang-cosFileTransfer-R16B-03.16.el7.x86_64                                                              33/61 

  Installing : erlang-cosEventDomain-R16B-03.16.el7.x86_64                                                               34/61 

  Installing : wxGTK-gl-2.8.12-20.el7.x86_64                                                                             35/61 

  Installing : erlang-wx-R16B-03.16.el7.x86_64                                                                           36/61 

  Installing : erlang-debugger-R16B-03.16.el7.x86_64                                                                     37/61 

  Installing : erlang-et-R16B-03.16.el7.x86_64                                                                           38/61 

  Installing : erlang-webtool-R16B-03.16.el7.x86_64                                                                      39/61 

  Installing : erlang-observer-R16B-03.16.el7.x86_64                                                                     40/61 

  Installing : erlang-test_server-R16B-03.16.el7.x86_64                                                                  41/61 

  Installing : erlang-common_test-R16B-03.16.el7.x86_64                                                                  42/61 

  Installing : erlang-megaco-R16B-03.16.el7.x86_64                                                                       43/61 

  Installing : erlang-reltool-R16B-03.16.el7.x86_64                                                                      44/61 

  Installing : erlang-cosTransactions-R16B-03.16.el7.x86_64                                                              45/61 

  Installing : erlang-percept-R16B-03.16.el7.x86_64                                                                      46/61 

  Installing : erlang-appmon-R16B-03.16.el7.x86_64                                                                       47/61 

  Installing : erlang-diameter-R16B-03.16.el7.x86_64                                                                     48/61 

  Installing : erlang-eldap-R16B-03.16.el7.x86_64                                                                        49/61 

  Installing : erlang-toolbar-R16B-03.16.el7.x86_64                                                                      50/61 

  Installing : erlang-odbc-R16B-03.16.el7.x86_64                                                                         51/61 

  Installing : erlang-eunit-R16B-03.16.el7.x86_64                                                                        52/61 

  Installing : erlang-parsetools-R16B-03.16.el7.x86_64                                                                   53/61 

  Installing : erlang-ic-R16B-03.16.el7.x86_64                                                                           54/61 

  Installing : erlang-jinterface-R16B-03.16.el7.x86_64                                                                   55/61 

  Installing : erlang-erl_interface-R16B-03.16.el7.x86_64                                                                56/61 

  Installing : graphviz-2.30.1-19.el7.x86_64                                                                             57/61 

  Installing : erlang-dialyzer-R16B-03.16.el7.x86_64                                                                     58/61 

  Installing : erlang-typer-R16B-03.16.el7.x86_64                                                                        59/61 

  Installing : erlang-examples-R16B-03.16.el7.x86_64                                                                     60/61 

  Installing : erlang-R16B-03.16.el7.x86_64                                                                              61/61 

  Verifying  : erlang-hipe-R16B-03.16.el7.x86_64                                                                          1/61 

  Verifying  : erlang-odbc-R16B-03.16.el7.x86_64                                                                          2/61 

  Verifying  : graphviz-2.30.1-19.el7.x86_64                                                                              3/61 

  Verifying  : erlang-cosTransactions-R16B-03.16.el7.x86_64                                                               4/61 

  Verifying  : erlang-cosEventDomain-R16B-03.16.el7.x86_64                                                                5/61 

  Verifying  : erlang-jinterface-R16B-03.16.el7.x86_64                                                                    6/61 

  Verifying  : erlang-eunit-R16B-03.16.el7.x86_64                                                                         7/61 

  Verifying  : erlang-public_key-R16B-03.16.el7.x86_64                                                                    8/61 

  Verifying  : erlang-runtime_tools-R16B-03.16.el7.x86_64                                                                 9/61 

  Verifying  : erlang-os_mon-R16B-03.16.el7.x86_64                                                                       10/61 

  Verifying  : erlang-debugger-R16B-03.16.el7.x86_64                                                                     11/61 

  Verifying  : erlang-compiler-R16B-03.16.el7.x86_64                                                                     12/61 

  Verifying  : erlang-tv-R16B-03.16.el7.x86_64                                                                           13/61 

  Verifying  : erlang-cosNotification-R16B-03.16.el7.x86_64                                                              14/61 

  Verifying  : wxGTK-gl-2.8.12-20.el7.x86_64                                                                             15/61 

  Verifying  : erlang-ssl-R16B-03.16.el7.x86_64                                                                          16/61 

  Verifying  : erlang-pman-R16B-03.16.el7.x86_64                                                                         17/61 

  Verifying  : erlang-dialyzer-R16B-03.16.el7.x86_64                                                                     18/61 

  Verifying  : erlang-crypto-R16B-03.16.el7.x86_64                                                                       19/61 

  Verifying  : erlang-et-R16B-03.16.el7.x86_64                                                                           20/61 

  Verifying  : erlang-cosFileTransfer-R16B-03.16.el7.x86_64                                                              21/61 

  Verifying  : erlang-diameter-R16B-03.16.el7.x86_64                                                                     22/61 

  Verifying  : erlang-kernel-R16B-03.16.el7.x86_64                                                                       23/61 

  Verifying  : erlang-syntax_tools-R16B-03.16.el7.x86_64                                                                 24/61 

  Verifying  : erlang-R16B-03.16.el7.x86_64                                                                              25/61 

  Verifying  : erlang-common_test-R16B-03.16.el7.x86_64                                                                  26/61 

  Verifying  : wxBase-2.8.12-20.el7.x86_64                                                                               27/61 

  Verifying  : erlang-webtool-R16B-03.16.el7.x86_64                                                                      28/61 

  Verifying  : erlang-inets-R16B-03.16.el7.x86_64                                                                        29/61 

  Verifying  : erlang-percept-R16B-03.16.el7.x86_64                                                                      30/61 

  Verifying  : erlang-otp_mibs-R16B-03.16.el7.x86_64                                                                     31/61 

  Verifying  : erlang-edoc-R16B-03.16.el7.x86_64                                                                         32/61 

  Verifying  : erlang-erts-R16B-03.16.el7.x86_64                                                                         33/61 

  Verifying  : erlang-erl_interface-R16B-03.16.el7.x86_64                                                                34/61 

  Verifying  : erlang-examples-R16B-03.16.el7.x86_64                                                                     35/61 

  Verifying  : erlang-cosTime-R16B-03.16.el7.x86_64                                                                      36/61 

  Verifying  : erlang-gs-R16B-03.16.el7.x86_64                                                                           37/61 

  Verifying  : erlang-stdlib-R16B-03.16.el7.x86_64                                                                       38/61 

  Verifying  : erlang-test_server-R16B-03.16.el7.x86_64                                                                  39/61 

  Verifying  : erlang-typer-R16B-03.16.el7.x86_64                                                                        40/61 

  Verifying  : erlang-mnesia-R16B-03.16.el7.x86_64                                                                       41/61 

  Verifying  : erlang-reltool-R16B-03.16.el7.x86_64                                                                      42/61 

  Verifying  : erlang-parsetools-R16B-03.16.el7.x86_64                                                                   43/61 

  Verifying  : erlang-xmerl-R16B-03.16.el7.x86_64                                                                        44/61 

  Verifying  : erlang-eldap-R16B-03.16.el7.x86_64                                                                        45/61 

  Verifying  : erlang-megaco-R16B-03.16.el7.x86_64                                                                       46/61 

  Verifying  : erlang-appmon-R16B-03.16.el7.x86_64                                                                       47/61 

  Verifying  : erlang-snmp-R16B-03.16.el7.x86_64                                                                         48/61 

  Verifying  : erlang-ic-R16B-03.16.el7.x86_64                                                                           49/61 

  Verifying  : erlang-observer-R16B-03.16.el7.x86_64                                                                     50/61 

  Verifying  : erlang-cosProperty-R16B-03.16.el7.x86_64                                                                  51/61 

  Verifying  : erlang-orber-R16B-03.16.el7.x86_64                                                                        52/61 

  Verifying  : wxGTK-2.8.12-20.el7.x86_64                                                                                53/61 

  Verifying  : erlang-cosEvent-R16B-03.16.el7.x86_64                                                                     54/61 

  Verifying  : erlang-ssh-R16B-03.16.el7.x86_64                                                                          55/61 

  Verifying  : erlang-sasl-R16B-03.16.el7.x86_64                                                                         56/61 

  Verifying  : erlang-wx-R16B-03.16.el7.x86_64                                                                           57/61 

  Verifying  : erlang-erl_docgen-R16B-03.16.el7.x86_64                                                                   58/61 

  Verifying  : erlang-asn1-R16B-03.16.el7.x86_64                                                                         59/61 

  Verifying  : erlang-toolbar-R16B-03.16.el7.x86_64                                                                      60/61 

  Verifying  : erlang-tools-R16B-03.16.el7.x86_64                                                                        61/61 


Installed:

  erlang.x86_64 0:R16B-03.16.el7                                                                                               


Dependency Installed:

  erlang-appmon.x86_64 0:R16B-03.16.el7                          erlang-asn1.x86_64 0:R16B-03.16.el7                           

  erlang-common_test.x86_64 0:R16B-03.16.el7                     erlang-compiler.x86_64 0:R16B-03.16.el7                       

  erlang-cosEvent.x86_64 0:R16B-03.16.el7                        erlang-cosEventDomain.x86_64 0:R16B-03.16.el7                 

  erlang-cosFileTransfer.x86_64 0:R16B-03.16.el7                 erlang-cosNotification.x86_64 0:R16B-03.16.el7                

  erlang-cosProperty.x86_64 0:R16B-03.16.el7                     erlang-cosTime.x86_64 0:R16B-03.16.el7                        

  erlang-cosTransactions.x86_64 0:R16B-03.16.el7                 erlang-crypto.x86_64 0:R16B-03.16.el7                         

  erlang-debugger.x86_64 0:R16B-03.16.el7                        erlang-dialyzer.x86_64 0:R16B-03.16.el7                       

  erlang-diameter.x86_64 0:R16B-03.16.el7                        erlang-edoc.x86_64 0:R16B-03.16.el7                           

  erlang-eldap.x86_64 0:R16B-03.16.el7                           erlang-erl_docgen.x86_64 0:R16B-03.16.el7                     

  erlang-erl_interface.x86_64 0:R16B-03.16.el7                   erlang-erts.x86_64 0:R16B-03.16.el7                           

  erlang-et.x86_64 0:R16B-03.16.el7                              erlang-eunit.x86_64 0:R16B-03.16.el7                          

  erlang-examples.x86_64 0:R16B-03.16.el7                        erlang-gs.x86_64 0:R16B-03.16.el7                             

  erlang-hipe.x86_64 0:R16B-03.16.el7                            erlang-ic.x86_64 0:R16B-03.16.el7                             

  erlang-inets.x86_64 0:R16B-03.16.el7                           erlang-jinterface.x86_64 0:R16B-03.16.el7                     

  erlang-kernel.x86_64 0:R16B-03.16.el7                          erlang-megaco.x86_64 0:R16B-03.16.el7                         

  erlang-mnesia.x86_64 0:R16B-03.16.el7                          erlang-observer.x86_64 0:R16B-03.16.el7                       

  erlang-odbc.x86_64 0:R16B-03.16.el7                            erlang-orber.x86_64 0:R16B-03.16.el7                          

  erlang-os_mon.x86_64 0:R16B-03.16.el7                          erlang-otp_mibs.x86_64 0:R16B-03.16.el7                       

  erlang-parsetools.x86_64 0:R16B-03.16.el7                      erlang-percept.x86_64 0:R16B-03.16.el7                        

  erlang-pman.x86_64 0:R16B-03.16.el7                            erlang-public_key.x86_64 0:R16B-03.16.el7                     

  erlang-reltool.x86_64 0:R16B-03.16.el7                         erlang-runtime_tools.x86_64 0:R16B-03.16.el7                  

  erlang-sasl.x86_64 0:R16B-03.16.el7                            erlang-snmp.x86_64 0:R16B-03.16.el7                           

  erlang-ssh.x86_64 0:R16B-03.16.el7                             erlang-ssl.x86_64 0:R16B-03.16.el7                            

  erlang-stdlib.x86_64 0:R16B-03.16.el7                          erlang-syntax_tools.x86_64 0:R16B-03.16.el7                   

  erlang-test_server.x86_64 0:R16B-03.16.el7                     erlang-toolbar.x86_64 0:R16B-03.16.el7                        

  erlang-tools.x86_64 0:R16B-03.16.el7                           erlang-tv.x86_64 0:R16B-03.16.el7                             

  erlang-typer.x86_64 0:R16B-03.16.el7                           erlang-webtool.x86_64 0:R16B-03.16.el7                        

  erlang-wx.x86_64 0:R16B-03.16.el7                              erlang-xmerl.x86_64 0:R16B-03.16.el7                          

  graphviz.x86_64 0:2.30.1-19.el7                                wxBase.x86_64 0:2.8.12-20.el7                                 

  wxGTK.x86_64 0:2.8.12-20.el7                                   wxGTK-gl.x86_64 0:2.8.12-20.el7                               


Complete!

[root@os1 hadoop]# chkconfig rabbitmq-server on

[root@os1 hadoop]# service rabbitmq-server start

Starting rabbitmq-server (via systemctl):                  [  OK  ]

[root@os1 hadoop]# 

[root@os1 ~]# rabbitmqctl status

Status of node rabbit@os1 ...

[{pid,6637},

 {running_applications,[{rabbit,"RabbitMQ","3.6.1"},

                        {os_mon,"CPO  CXC 138 46","2.2.14"},

                        {rabbit_common,[],"3.6.1"},

                        {mnesia,"MNESIA  CXC 138 12","4.11"},

                        {xmerl,"XML parser","1.3.6"},

                        {ranch,"Socket acceptor pool for TCP protocols.",

                               "1.2.1"},

                        {sasl,"SASL  CXC 138 11","2.3.4"},

                        {stdlib,"ERTS  CXC 138 10","1.19.4"},

                        {kernel,"ERTS  CXC 138 10","2.16.4"}]},

 {os,{unix,linux}},

 {erlang_version,"Erlang R16B03-1 (erts-5.10.4) [source] [64-bit] [smp:8:8] [async-threads:64] [hipe] [kernel-poll:true]\n"},

 {memory,[{total,42929272},

          {connection_readers,0},

          {connection_writers,0},

          {connection_channels,0},

          {connection_other,0},

          {queue_procs,2800},

          {queue_slave_procs,0},

          {plugins,0},

          {other_proc,19203912},

          {mnesia,60184},

          {mgmt_db,0},

          {msg_index,53200},

          {other_ets,903312},

          {binary,24224},

          {code,17032669},

          {atom,654217},

          {other_system,4994754}]},

 {alarms,[]},

 {listeners,[{clustering,25672,"::"},{amqp,5672,"::"}]},

 {vm_memory_high_watermark,0.4},

 {vm_memory_limit,3275040358},

 {disk_free_limit,50000000},

 {disk_free,19079950336},

 {file_descriptors,[{total_limit,924},

                    {total_used,2},

                    {sockets_limit,829},

                    {sockets_used,0}]},

 {processes,[{limit,1048576},{used,144}]},

 {run_queue,0},

 {uptime,2497},

 {kernel,{net_ticktime,60}}]

[root@os1 ~]# 


저작자 표시
신고
Posted by ORACLE,DBA,BIG,DATA,JAVA 흑풍전설

개놈에 카산드라 -- 연동 짜증난다 ㅋ

Hbase 연동을 먼저좀 해보려고 하다가 실패를 하고 짜증나서 카산드라 연동좀 시도해보고 성공후에 기록남김.


spark 버전 : 1.6.1 ( 하둡 2.7.2를 사용해서 하둡용으로 컴파일된 버전사용 )

cassandra 버전 : 3.4 

cassandra spark java connector 버전 : 1.5버전 사용.

node 수 : 6


cassandra 설치는 쉬우므로 내가 기록할 정보만 기록한다.

나는 6대로 계속 테스트중이므로~~~


참고로 모든 노드의 스펙은 아래와 같다. ( vmware 스펙 ㅋ )


카산드라 설정파일 작업부분.

위의 VM들을 가지고 모든 노드에 각각 아이피를 할당하여 설정한 설정정보만 남긴다.


카산드라의 분산및 리플리케이션을 위한 구성을 위해서 건드려야할 파일리스트 


cassandra.yaml

* 변경위치 : 

- listen_address : 해당노드의 아이피

- rpc_address : 해당노드의 아이피

- seed_provider의 seeds 부분 : 연결된노드 아이피들~~ "111.111.111.111,222.222.222.222" 이런식으로.


cassandra-env.sh

* 변경위치 :

- JVM_OPTS의 hostname 부분 : 해당노드의 아이피


여기까지 변경하고 cassandra를 실행하면 1개의 datacenter 에 1개의 rack 으로 해서 6개의 노드가 생겨지더라.


아래 두개파일로 datacenter 는 몇개로 할지 rack은 몇개로 할지 등을 설정.


cassandra-rackdc.properties


cassandra-topology.properties


카산드라 노드 연결된 상태 확인.

[hadoop@os1 bin]$ ./nodetool status

Datacenter: datacenter1

=======================

Status=Up/Down

|/ State=Normal/Leaving/Joining/Moving

--  Address        Load       Tokens       Owns (effective)  Host ID                               Rack

UN  192.168.0.111  201.03 KB  256          49.5%             e13656b7-1436-4011-bd1d-01042a2d75fc  rack1

UN  192.168.0.112  205.89 KB  256          47.7%             09ef262e-9013-4292-9ea8-98a32ebdadc1  rack1

UN  192.168.0.113  253.59 KB  256          47.7%             bad6d57a-3135-4dff-b546-21887d77aca6  rack1

UN  192.168.0.114  198.71 KB  256          49.3%             c2e5c7bc-b9a1-4751-9e6b-6179b20fc76f  rack1

UN  192.168.0.115  214 KB      256          53.8%             9f9d28e9-7e03-4653-a329-7aba65aaf5f0  rack1

UN  192.168.0.116  219.55 KB  256          52.1%             cffba9e0-19b3-4070-93ba-ecb4e6263e47  rack1


[hadoop@os1 bin]$ 


참고로 노드가 죽으면 DN 으로 바뀌더라;;;


이제 카산드라에 기본 데이터몇개 넣기.

* 설정파일이 로컬이아닌 아이피를 넣으니 cqlsh 만 치면 못찾더라 ㅋ

* 메뉴얼의 굵은글씨만 보고 일단 만들어서 실행 ㅋ


[hadoop@os1 bin]$ ./cqlsh 192.168.0.111

Connected to CASDR at 192.168.0.111:9042.

[cqlsh 5.0.1 | Cassandra 3.4 | CQL spec 3.4.0 | Native protocol v4]

Use HELP for help.

cqlsh> create keyspace keytest with replication = {'class' :'SimpleStrategy','replication_factor' : 3};

cqlsh>

cqlsh> use keytest;

cqlsh:keytest> create table test_table ( id varchar,name varchar,primary key(id));          

cqlsh:keytest> insert into test_table (id,name) values('2','fasdlkffasdffajfkls');

cqlsh:keytest> select *from test_table;


 id | name

----+-------------------------------

  3 | fasdlkfasdfasdfaffasdffajfkls

  2 |           fasdlkffasdffajfkls

  1 |     fasdlkfjafkljfsdklfajfkls


(3 rows)

cqlsh:keytest> 



* 현재 상황은 1~6번까지 노드가 있고 spark는 1번노드에 설치해놓음.

* 인터넷에 떠돌아 다니는 소스를 조합하여 몇몇가지 수정해서 실행함.

* 아래는 콘솔에서 짠 cassandra 테이블 카운트 세는 소스

* 아래소스보면 커넥터를 1.6과 1.5를 테스트하느라 둘다 쓴게 나오는데 1.6 , 1.5어느거 하나만 써도 상관없이 작동하니 신경쓰지말것.

import static com.datastax.spark.connector.japi.CassandraJavaUtil.javaFunctions;


import java.util.ArrayList;

import java.util.List;


import org.apache.spark.SparkConf;

import org.apache.spark.api.java.JavaRDD;

import org.apache.spark.api.java.JavaSparkContext;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.Result;

import org.apache.spark.api.java.JavaPairRDD;

import org.apache.spark.api.java.function.Function;

import org.apache.hadoop.hbase.io.ImmutableBytesWritable;

import org.apache.hadoop.hbase.mapreduce.TableInputFormat;


import com.datastax.spark.connector.japi.CassandraJavaUtil;

import com.datastax.spark.connector.japi.CassandraRow;




public class test3 {


        public static void main(String[] args)

        {


                SparkConf conf = new SparkConf(true)

                .set("spark.cassandra.connection.host","192.168.0.111")

                .setMaster("spark://192.168.0.111:7077")

                .setAppName("casr")

                .setJars(new String[]{"/apps/spark/lib/spark-cassandra-connector-java_2.10-1.6.0-M1.jar","/apps/spark/lib/spark-cassandra-connec

tor_2.10-1.6.0-M1.jar"})

                .setSparkHome("/apps/spark");



                JavaSparkContext sc = new JavaSparkContext(conf);


                sc.addJar("/home/hadoop/classes/cassandra-driver-core-3.0.0.jar");

                sc.addJar("/home/hadoop/classes/guava-19.0.jar");

                JavaRDD<CassandraRow> cassandraRdd = CassandraJavaUtil.javaFunctions(sc)

                        .cassandraTable("keytest", "test_table")

                        .select("name");


                                        System.out.println("row count:"+ cassandraRdd.count()); // once it is in RDD, we can use RDD 



               }

}


위의것을 컴파일후 실행하면 아래처럼 실행되더라.

[hadoop@os1 ~]$ java test3

Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties

SLF4J: Class path contains multiple SLF4J bindings.

SLF4J: Found binding in [jar:file:/home/hadoop/classes/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: Found binding in [jar:file:/home/hadoop/classes/logback-classic-1.1.2.jar!/org/slf4j/impl/StaticLoggerBinder.class]

SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

16/04/08 00:53:19 INFO SparkContext: Running Spark version 1.6.1

16/04/08 00:53:20 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable

16/04/08 00:53:20 INFO SecurityManager: Changing view acls to: hadoop

16/04/08 00:53:20 INFO SecurityManager: Changing modify acls to: hadoop

16/04/08 00:53:20 INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(hadoop); users with modify permissions: Set(hadoop)

16/04/08 00:53:21 INFO Utils: Successfully started service 'sparkDriver' on port 54330.

16/04/08 00:53:22 INFO Slf4jLogger: Slf4jLogger started

16/04/08 00:53:22 INFO Remoting: Starting remoting

16/04/08 00:53:22 INFO Remoting: Remoting started; listening on addresses :[akka.tcp://sparkDriverActorSystem@192.168.0.111:34441]

16/04/08 00:53:22 INFO Utils: Successfully started service 'sparkDriverActorSystem' on port 34441.

16/04/08 00:53:22 INFO SparkEnv: Registering MapOutputTracker

16/04/08 00:53:22 INFO SparkEnv: Registering BlockManagerMaster

16/04/08 00:53:22 INFO DiskBlockManager: Created local directory at /tmp/blockmgr-e91fb4d5-8f1e-45b5-9631-2af967164aff

16/04/08 00:53:22 INFO MemoryStore: MemoryStore started with capacity 1077.8 MB

16/04/08 00:53:22 INFO SparkEnv: Registering OutputCommitCoordinator

16/04/08 00:53:23 INFO Utils: Successfully started service 'SparkUI' on port 4040.

16/04/08 00:53:23 INFO SparkUI: Started SparkUI at http://192.168.0.111:4040

16/04/08 00:53:23 INFO HttpFileServer: HTTP File server directory is /tmp/spark-d02efafe-ae00-4eaa-9cfc-0700e5848dd3/httpd-c8f30120-f92a-4ec9-922f-c201e94998af

16/04/08 00:53:23 INFO HttpServer: Starting HTTP Server

16/04/08 00:53:23 INFO Utils: Successfully started service 'HTTP file server' on port 48452.

16/04/08 00:53:23 INFO SparkContext: Added JAR /apps/spark/lib/spark-cassandra-connector-java_2.10-1.6.0-M1.jar at http://192.168.0.111:48452/jars/spark-cassandra-connector-java_2.10-1.6.0-M1.jar with timestamp 1460044403426

16/04/08 00:53:23 INFO SparkContext: Added JAR /apps/spark/lib/spark-cassandra-connector_2.10-1.6.0-M1.jar at http://192.168.0.111:48452/jars/spark-cassandra-connector_2.10-1.6.0-M1.jar with timestamp 1460044403435

16/04/08 00:53:23 INFO AppClient$ClientEndpoint: Connecting to master spark://192.168.0.111:7077...

16/04/08 00:53:23 INFO SparkDeploySchedulerBackend: Connected to Spark cluster with app ID app-20160408005323-0013

16/04/08 00:53:23 INFO AppClient$ClientEndpoint: Executor added: app-20160408005323-0013/0 on worker-20160407175148-192.168.0.111-57563 (192.168.0.111:57563) with 8 cores

16/04/08 00:53:23 INFO SparkDeploySchedulerBackend: Granted executor ID app-20160408005323-0013/0 on hostPort 192.168.0.111:57563 with 8 cores, 1024.0 MB RAM

16/04/08 00:53:23 INFO Utils: Successfully started service 'org.apache.spark.network.netty.NettyBlockTransferService' on port 44940.

16/04/08 00:53:23 INFO NettyBlockTransferService: Server created on 44940

16/04/08 00:53:23 INFO BlockManagerMaster: Trying to register BlockManager

16/04/08 00:53:23 INFO BlockManagerMasterEndpoint: Registering block manager 192.168.0.111:44940 with 1077.8 MB RAM, BlockManagerId(driver, 192.168.0.111, 44940)

16/04/08 00:53:23 INFO BlockManagerMaster: Registered BlockManager

16/04/08 00:53:23 INFO AppClient$ClientEndpoint: Executor updated: app-20160408005323-0013/0 is now RUNNING

16/04/08 00:53:24 INFO SparkDeploySchedulerBackend: SchedulerBackend is ready for scheduling beginning after reached minRegisteredResourcesRatio: 0.0

16/04/08 00:53:24 INFO SparkContext: Added JAR /home/hadoop/classes/cassandra-driver-core-3.0.0.jar at http://192.168.0.111:48452/jars/cassandra-driver-core-3.0.0.jar with timestamp 1460044404233

16/04/08 00:53:24 INFO SparkContext: Added JAR /home/hadoop/classes/guava-19.0.jar at http://192.168.0.111:48452/jars/guava-19.0.jar with timestamp 1460044404244

16/04/08 00:53:24 INFO NettyUtil: Found Netty's native epoll transport in the classpath, using it

16/04/08 00:53:25 INFO Cluster: New Cassandra host /192.168.0.111:9042 added

16/04/08 00:53:25 INFO Cluster: New Cassandra host /192.168.0.112:9042 added

16/04/08 00:53:25 INFO LocalNodeFirstLoadBalancingPolicy: Added host 192.168.0.112 (datacenter1)

16/04/08 00:53:25 INFO Cluster: New Cassandra host /192.168.0.113:9042 added

16/04/08 00:53:25 INFO LocalNodeFirstLoadBalancingPolicy: Added host 192.168.0.113 (datacenter1)

16/04/08 00:53:25 INFO Cluster: New Cassandra host /192.168.0.114:9042 added

16/04/08 00:53:25 INFO LocalNodeFirstLoadBalancingPolicy: Added host 192.168.0.114 (datacenter1)

16/04/08 00:53:25 INFO Cluster: New Cassandra host /192.168.0.115:9042 added

16/04/08 00:53:25 INFO LocalNodeFirstLoadBalancingPolicy: Added host 192.168.0.115 (datacenter1)

16/04/08 00:53:25 INFO Cluster: New Cassandra host /192.168.0.116:9042 added

16/04/08 00:53:25 INFO LocalNodeFirstLoadBalancingPolicy: Added host 192.168.0.116 (datacenter1)

16/04/08 00:53:25 INFO CassandraConnector: Connected to Cassandra cluster: CASDR

16/04/08 00:53:26 INFO SparkContext: Starting job: count at test3.java:44

16/04/08 00:53:26 INFO DAGScheduler: Got job 0 (count at test3.java:44) with 7 output partitions

16/04/08 00:53:26 INFO DAGScheduler: Final stage: ResultStage 0 (count at test3.java:44)

16/04/08 00:53:26 INFO DAGScheduler: Parents of final stage: List()

16/04/08 00:53:26 INFO DAGScheduler: Missing parents: List()

16/04/08 00:53:26 INFO DAGScheduler: Submitting ResultStage 0 (CassandraTableScanRDD[1] at RDD at CassandraRDD.scala:15), which has no missing parents

16/04/08 00:53:26 INFO MemoryStore: Block broadcast_0 stored as values in memory (estimated size 7.3 KB, free 7.3 KB)

16/04/08 00:53:26 INFO MemoryStore: Block broadcast_0_piece0 stored as bytes in memory (estimated size 3.8 KB, free 11.1 KB)

16/04/08 00:53:26 INFO BlockManagerInfo: Added broadcast_0_piece0 in memory on 192.168.0.111:44940 (size: 3.8 KB, free: 1077.7 MB)

16/04/08 00:53:26 INFO SparkContext: Created broadcast 0 from broadcast at DAGScheduler.scala:1006

16/04/08 00:53:26 INFO DAGScheduler: Submitting 7 missing tasks from ResultStage 0 (CassandraTableScanRDD[1] at RDD at CassandraRDD.scala:15)

16/04/08 00:53:26 INFO TaskSchedulerImpl: Adding task set 0.0 with 7 tasks

16/04/08 00:53:27 INFO SparkDeploySchedulerBackend: Registered executor NettyRpcEndpointRef(null) (os1.local:56503) with ID 0

16/04/08 00:53:27 INFO BlockManagerMasterEndpoint: Registering block manager os1.local:53103 with 511.1 MB RAM, BlockManagerId(0, os1.local, 53103)

16/04/08 00:53:27 INFO TaskSetManager: Starting task 0.0 in stage 0.0 (TID 0, os1.local, partition 0,NODE_LOCAL, 26312 bytes)

16/04/08 00:53:27 INFO TaskSetManager: Starting task 1.0 in stage 0.0 (TID 1, os1.local, partition 1,NODE_LOCAL, 26222 bytes)

16/04/08 00:53:27 INFO TaskSetManager: Starting task 5.0 in stage 0.0 (TID 2, os1.local, partition 5,NODE_LOCAL, 26352 bytes)

16/04/08 00:53:28 INFO BlockManagerInfo: Added broadcast_0_piece0 in memory on os1.local:53103 (size: 3.8 KB, free: 511.1 MB)

16/04/08 00:53:31 INFO TaskSetManager: Starting task 2.0 in stage 0.0 (TID 3, os1.local, partition 2,ANY, 26312 bytes)

16/04/08 00:53:31 INFO TaskSetManager: Starting task 3.0 in stage 0.0 (TID 4, os1.local, partition 3,ANY, 21141 bytes)

16/04/08 00:53:31 INFO TaskSetManager: Starting task 4.0 in stage 0.0 (TID 5, os1.local, partition 4,ANY, 23882 bytes)

16/04/08 00:53:31 INFO TaskSetManager: Starting task 6.0 in stage 0.0 (TID 6, os1.local, partition 6,ANY, 10818 bytes)

16/04/08 00:53:32 INFO TaskSetManager: Finished task 6.0 in stage 0.0 (TID 6) in 1106 ms on os1.local (1/7)

16/04/08 00:53:33 INFO TaskSetManager: Finished task 1.0 in stage 0.0 (TID 1) in 5530 ms on os1.local (2/7)

16/04/08 00:53:33 INFO TaskSetManager: Finished task 3.0 in stage 0.0 (TID 4) in 1945 ms on os1.local (3/7)

16/04/08 00:53:33 INFO TaskSetManager: Finished task 0.0 in stage 0.0 (TID 0) in 6015 ms on os1.local (4/7)

16/04/08 00:53:33 INFO TaskSetManager: Finished task 5.0 in stage 0.0 (TID 2) in 5959 ms on os1.local (5/7)

16/04/08 00:53:33 INFO TaskSetManager: Finished task 4.0 in stage 0.0 (TID 5) in 2150 ms on os1.local (6/7)

16/04/08 00:53:33 INFO TaskSetManager: Finished task 2.0 in stage 0.0 (TID 3) in 2286 ms on os1.local (7/7)

16/04/08 00:53:33 INFO DAGScheduler: ResultStage 0 (count at test3.java:44) finished in 7.049 s

16/04/08 00:53:33 INFO TaskSchedulerImpl: Removed TaskSet 0.0, whose tasks have all completed, from pool 

16/04/08 00:53:33 INFO DAGScheduler: Job 0 finished: count at test3.java:44, took 7.435243 s

16/04/08 00:53:34 INFO CassandraConnector: Disconnected from Cassandra cluster: CASDR

16/04/08 00:53:35 INFO BlockManagerInfo: Removed broadcast_0_piece0 on 192.168.0.111:44940 in memory (size: 3.8 KB, free: 1077.8 MB)

row count:3 <--------- 요기 요거가 나온답 ㅋ

16/04/08 00:53:35 INFO BlockManagerInfo: Removed broadcast_0_piece0 on os1.local:53103 in memory (size: 3.8 KB, free: 511.1 MB)

16/04/08 00:53:35 INFO SparkContext: Invoking stop() from shutdown hook

16/04/08 00:53:35 INFO ContextCleaner: Cleaned accumulator 1

16/04/08 00:53:35 INFO SparkUI: Stopped Spark web UI at http://192.168.0.111:4040

16/04/08 00:53:35 INFO SparkDeploySchedulerBackend: Shutting down all executors

16/04/08 00:53:35 INFO SparkDeploySchedulerBackend: Asking each executor to shut down

16/04/08 00:53:35 INFO MapOutputTrackerMasterEndpoint: MapOutputTrackerMasterEndpoint stopped!

16/04/08 00:53:35 INFO MemoryStore: MemoryStore cleared

16/04/08 00:53:35 INFO BlockManager: BlockManager stopped

16/04/08 00:53:35 INFO BlockManagerMaster: BlockManagerMaster stopped

16/04/08 00:53:35 INFO OutputCommitCoordinator$OutputCommitCoordinatorEndpoint: OutputCommitCoordinator stopped!

16/04/08 00:53:35 INFO SparkContext: Successfully stopped SparkContext

16/04/08 00:53:35 INFO ShutdownHookManager: Shutdown hook called

16/04/08 00:53:35 INFO ShutdownHookManager: Deleting directory /tmp/spark-d02efafe-ae00-4eaa-9cfc-0700e5848dd3/httpd-c8f30120-f92a-4ec9-922f-c201e94998af

16/04/08 00:53:35 INFO RemoteActorRefProvider$RemotingTerminator: Shutting down remote daemon.

16/04/08 00:53:35 INFO ShutdownHookManager: Deleting directory /tmp/spark-d02efafe-ae00-4eaa-9cfc-0700e5848dd3

16/04/08 00:53:35 INFO RemoteActorRefProvider$RemotingTerminator: Remote daemon shut down; proceeding with flushing remote transports.

[hadoop@os1 ~]$


주의사항

위에 저 빨간 글씨인 row count 나오게 하려고 별짓을 다했다. ㅋ

이 클래스안에서 실행되는 spark와 cassandra는 새로 이 두놈에 접속을 하여 자바에서 설정된 환경설정을 따라서 

실행되는것으로 보인다.

java 소스상에 보면 setJars 를 통해서 jar파일위치를 추가해주었다.

그랬더니 길고긴 닭질을 끝내고 성공하게 됨;;;; 

그렇게 서버를 만져도 자꾸 망각하게되는 부분. ㅎㅎ;;;


저작자 표시
신고
Posted by ORACLE,DBA,BIG,DATA,JAVA 흑풍전설

이클립스에서 개발테스트중에 발생한 오류 ( 실행하면 SparkConf쪽에서 바로 오류가 난다.)

사실 저 매쏘드를 찾아보려고 jar을 다뒤져보고 역컴파일하다가 짜증나서 폭팔함;;


Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.$conforms()Lscala/Predef$$less$colon$less;

at org.apache.spark.util.Utils$.getSystemProperties(Utils.scala:1546)

at org.apache.spark.SparkConf.<init>(SparkConf.scala:59)

at spark1.test1.main(test1.java:20)


해결책 : 버전을 잘 마춰준다 ㅋㅋ

참고 : spark-1.6.1 , scala-library 2.10.4버전 사용 

maven 버전은 아래처럼 마춰서 사용. 



에러 날때 사용한 버전

<dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-core_2.11</artifactId>

  <version>1.6.1</version>

  </dependency>

  <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-sql_2.11</artifactId>

  <version>1.6.1</version>

  </dependency>

  <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-streaming_2.11</artifactId>

  <version>1.6.1</version>

  </dependency>

  <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-mllib_2.11</artifactId>

  <version>1.6.1</version>

   </dependency>


이걸사용하고나니 없어짐 

 <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-core_2.10</artifactId>

  <version>1.6.1</version>

  </dependency>

  <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-sql_2.10</artifactId>

  <version>1.6.1</version>

  </dependency>

  <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-streaming_2.10</artifactId>

  <version>1.6.1</version>

  </dependency>

  <dependency>

  <groupId>org.apache.spark</groupId>

  <artifactId>spark-mllib_2.10</artifactId>

  <version>1.6.1</version>

  </dependency>


저작자 표시
신고
Posted by ORACLE,DBA,BIG,DATA,JAVA 흑풍전설