2

私はBAMを何日も使用していますが、BAM 2.0.1のドキュメントに示されているように、突然、簡単な例（HTTPDログ分析サンプル）を実行できなくなりました。オフセットは変更していません。

私が取っているステップは次のとおりです。

-LinuxでBAMサーバーを起動する

-$ WSO2_BAM_HOME / samples / httpd-logs/resourcesディレクトリからaccess.logを読み取ります

-管理コンソールに「HTTPDログと分析」ツールボックスをインストールする

インストール中にハイブスクリプトエラーが発生しました::

"Hiveスクリプトの実行中にエラーが発生しました。クエリがゼロ以外のコードを返しました：9、原因：失敗：実行エラー、org.apache.hadoop.hive.ql.exec.DDLTaskからコード1を返します"

どこがおかしいのか教えていただけますか？

バックエンドのエラーは

ERROR {org.apache.hadoop.hive.ql.exec.Task} -  FAILED: Error in metadata: MetaException(message:Unable to connect to the server org.apache.hadoop.hive.cassandra.CassandraException: unable to connect to server)
org.apache.hadoop.hive.ql.metadata.HiveException: MetaException(message:Unable to connect to the server org.apache.hadoop.hive.cassandra.CassandraException: unable to connect to server)
        at org.apache.hadoop.hive.ql.metadata.Hive.createTable(Hive.java:546)
        at org.apache.hadoop.hive.ql.exec.DDLTask.createTable(DDLTask.java:3479)
        at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:225)
        at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:133)
        at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:57)
        at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:1334)
        at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1125)
        at org.apache.hadoop.hive.ql.Driver.run(Driver.java:933)
        at org.apache.hadoop.hive.service.HiveServer$HiveServerHandler.execute(HiveServer.java:201)
        at org.apache.hadoop.hive.jdbc.HiveStatement.executeQuery(HiveStatement.java:187)
        at org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:325)
        at org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:225)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
        at java.util.concurrent.FutureTask.run(FutureTask.java:138)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
Caused by: MetaException(message:Unable to connect to the server org.apache.hadoop.hive.cassandra.CassandraException: unable to connect to server)
        at org.apache.hadoop.hive.cassandra.CassandraManager.openConnection(CassandraManager.java:118)
        at org.apache.hadoop.hive.cassandra.CassandraStorageHandler.preCreateTable(CassandraStorageHandler.java:168)
        at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createTable(HiveMetaStoreClient.java:397)
        at org.apache.hadoop.hive.ql.metadata.Hive.createTable(Hive.java:540)
        ... 16 more

FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
[2013-01-16 20:03:01,464] ERROR {org.apache.hadoop.hive.ql.Driver} -  FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
[2013-01-16 20:03:01,470] ERROR {org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl} -  Error while executing Hive script.
Query returned non-zero code: 9, cause: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
java.sql.SQLException: Query returned non-zero code: 9, cause: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
        at org.apache.hadoop.hive.jdbc.HiveStatement.executeQuery(HiveStatement.java:189)
        at org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:325)
        at org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:225)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
        at java.util.concurrent.FutureTask.run(FutureTask.java:138)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
[2013-01-16 20:03:01,473] ERROR {org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask} -  Error while executing script : httpd_logs_script_507
org.wso2.carbon.analytics.hive.exception.HiveExecutionException: Error while executing Hive script.Query returned non-zero code: 9, cause: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
        at org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl.execute(HiveExecutorServiceImpl.java:110)
        at org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask.execute(HiveScriptExecutorTask.java:60)
        at org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:56)
        at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
        at java.util.concurrent.FutureTask.run(FutureTask.java:138)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
[2013-01-16 20:03:09,139]  INFO {org.wso2.carbon.core.services.util.CarbonAuthenticationUtil} -  'admin@carbon.super [-1234]' logged in at [2013-01-16 20:03:09,139+0530]
4

4 に答える 4

0

Hive が cassandra に接続できないようです。任意のオフセットで BAM サーバーを起動した場合、casssandra ポートも 9160+< port-offset > に変更されます。「cassandra.port」を 9160+< port-offset > に置き換えてください。

また、変更を反映させるために、Httpd_log_script に記載されている Hive テーブルを削除する必要がある場合もあります。これは、既にスクリプトを実行しており、特定のテーブル名のテーブル定義が既に保存されており、存在しない場合はスクリプト内でテーブルが作成されるため、再度作成しようとしないためです。(CREATE EXTERNAL TABLE IF NOT EXISTS) .

于 2013-01-16T09:15:00.997 に答える
0

サーバー ログから完全なエラー トレースを投稿していただけますか?

「Hive スクリプトの実行中にエラーが発生しました。クエリがゼロ以外のコードを返しました: 9、原因: FAILED: 実行エラー、org.apache.hadoop.hive.ql.exec.DDLTask からコード 1 を返しました」、根本原因を突き止めるには、完全な例外トレースが必要です。

于 2013-01-16T08:41:29.507 に答える
0

サーバーへの接続に問題があるようです。ユーザー名またはパスワードを変更しましたか? (デフォルトのユーザー名とパスワードはadminとadminです)

また、同じ既存の Hive テーブルを別のスキーマで作成する場合は、CREATE ....の前に既存のテーブルを削除する必要があります。シントゥージャが言ったように命令します。

例: テーブルtable1を削除します。

drop table table1;
于 2013-01-16T10:18:38.840 に答える
-1

最初にBAM2.0.1のHTTPDログサンプルを試すことができますか？/samples/httpd-logs/README.txtの指示に従うことができます。それはうまくいきました。これらは、そのファイルに記載されている手順です。

  1. WSO2BAMサーバーを起動します
  2. コンソールから$WSO2_BAM_HOME/ samples/httpd-logsディレクトリに移動します
  3. コンソールから「ant」と入力します（これにより、$ WSO2_BAM_HOME / samples / httpd-logs / resourcesディレクトリからaccess.logが読み取られ、各ログ行がイベントとして送信されます）
  4. WSO2BAMサーバーの管理コンソールに移動します。
  5. [メイン]->[BAMツールボックス]->[追加]に移動します。「HTTPDログ分析ツールボックス」を選択し、「インストール」ボタンをクリックします。
  6. [メイン]->[BAMツールボックス]->[リスト]に移動します。「HTTPDログ分析ツールボックス」ツールボックスのステータスが「インストール済み」に変わるまで待ちます。
  7. データを公開した後、スクリプトが最初の実行を完了するまでしばらく待ちます（スクリプトは1分ごとに実行されます）。
  8. [メイン]->[ガジェット]->[ポータルの表示]をクリックして、さまざまな国からのリクエストがないことの概要を表示する、入力されたガジェットを表示します。
于 2013-01-16T05:50:42.510 に答える