killme2008 / killme2008/Metamorphosis

与Storm0.10集成出错

Open
#124 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
1.3k
Forks
672
PR merge metrics
No merged PRs in 30d

Description

53693 [storm-test-fetch-Runner-0] ERROR c.t.m.c.c.SimpleFetchManager - Process messages failed,topic=test,partition=1
java.lang.RuntimeException: MetaSpout -- Obtain data fail!
at com.heetian.bigdata.storm.spout.MetaSpout$1.recieveMessages(MetaSpout.java:139) ~[metaq-storm-0.0.1-SNAPSHOT.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.processReceiveMessage(SimpleFetchManager.java:415) [metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.receiveMessages(SimpleFetchManager.java:362) [metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.notifyListener(SimpleFetchManager.java:324) [metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.processRequest(SimpleFetchManager.java:232) [metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.run(SimpleFetchManager.java:215) [metamorphosis-client-1.4.6.2.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_73]
54459 [storm-test-fetch-Runner-0] ERROR c.t.m.c.c.SimpleFetchManager - è·åæ¶æ¯å¤±è´¥,topic=test,partition=1
java.lang.NoClassDefFoundError: Could not initialize class com.taobao.metamorphosis.utils.monitor.MonitorLog
at com.taobao.metamorphosis.utils.MetaStatLog.addStatValue2(MetaStatLog.java:336) ~[metamorphosis-commons-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.processReceiveMessage(SimpleFetchManager.java:474) ~[metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.receiveMessages(SimpleFetchManager.java:362) ~[metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.notifyListener(SimpleFetchManager.java:324) [metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.processRequest(SimpleFetchManager.java:232) [metamorphosis-client-1.4.6.2.jar:?]
at com.taobao.metamorphosis.client.consumer.SimpleFetchManager$FetchRequestRunner.run(SimpleFetchManager.java:215) [metamorphosis-client-1.4.6.2.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_73]

Contributor guide

No contributing guide indexed for this repository

Research direction

Start with the stack trace at MetaSpout.java:139 and inspect the initialization path for com.taobao.metamorphosis.utils.monitor.MonitorLog. Check how the Storm 0.10 integration loads the Metamorphosis dependencies, then reproduce the fetch for topic=test and partition=1. Done means message processing no longer produces the reported RuntimeException or NoClassDefFoundError.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
distributed-systems
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
20/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.