0

私のSqoop2クライアントプログラムを書くためのこのガイドを参照しています: http://sqoop.apache.org/docs/1.99.2/ClientAPI.html

この例では、table.columns プロパティに列名を設定するだけで、正常に動作しますが、テーブル内のすべてのレコードをインポートします。単純な where-clause sql に基づいて一連のレコードのみをインポートする必要があります。table.sql プロパティを設定しようとしましたが、SqoopClient.createJob(newJob) を呼び出すと常に「受け入れられない」ステータスが返されます。Sqoop2 (CDH4.4.0) で自由形式のクエリを使用して正常にインポートを実行した人はいますか?

connectorForm.getStringInput("table.sql").setValue("select id,value from tableName where ${CONDITIONS} and groupid=123");
4

1 に答える 1

1

SqoopClient.createJob() によって返される全体的なステータスに加えて、指定された MJob オブジェクトはステータス メッセージで変更されます。フォームと入力を反復処理し、メソッドgetValidationMessage()を呼び出すことで、ジョブの問題点に関する正確なエラー メッセージを取得できます。

于 2013-11-07T18:20:52.040 に答える