streamsets

1熱

1答えて

RabbitMQでJSON形式のキューがあり、ストリームセレクタを使用してStreamSetsの条件を修正し、新しいデータベース（JDBC Producer）に一定の値を保存するデータを取得したいと考えています。条件の後に特定の値を書き込んでデータベースに送信するにはどうすればよいですか？あなたのパイプライン図から

-1熱

1答えて

他のクラス内のあるクラスのインスタンスにアクセスする際の問題

別のクラス内のあるクラスのメソッドでインスタンスにアクセスしようとしていて、それらを変更しようとしています。しかし、それは私に "としてエラーをスローされている包括的なscope.Andで定義されている非最終ローカル変数nextSourceOffsetを参照することはできません最終"に変数を変更する修正を与えている "私はそれらを増やすことはできません。私は、次のコードを使用しています： pub

1熱

1答えて

SDC HTTPサーバーURLにデータを投稿するとJavaScriptからCORSの問題が表示される

ブラウザからのストリーミングデータにStreamsetsパイプラインを使用しています。そこで、HTTPサーバーの原点を持つパイプラインを作成して、Javascriptのブラウザからデータを送信し、RESTクライアントを使用してそのURLに書き込もうとしましたが、正常に書き込みます。応答ヘッダーは、SDC.propertiesファイルにすでに設定されています。 http.access.control

1熱

2答えて

ストリームセットデータコレクタの宛先パッケージを手動でダウンロードしてインストールする方法

Streamsets Data Collectorの宛先パッケージをダウンロードしてインストールする方法を知っている人はいませんか。私のSDCはインターネットにアクセスできないので、なぜ私はそれを標準的な方法で行うことができません。特にkafkaパッケージをダウンロードし、手動でStreamsets Data Collectorにインストールしたいと考えています。

1熱

1答えて

Streamsetsクラスが見つかりません。例外

私はSQLからデータを読み込むためにストリームセットにパイプラインを構築し、データキャプチャを変更しました。パイプラインの実行を開始すると、次のエラーが発生します。パイプラインのステータス：START_ERROR：java.lang.NoClassDefFoundErrorが：ORG/apacheの/カフカ/共通/ KafkaException

1熱

1答えて

ストリームセットDCおよびCrate例外。エラー：SQLParseException：行1：13： '特性'で有効な代替手段がありません

ストリームセットデータコレクタのパイプライン起点（JDBCコンシューマ）としてCrateに接続しようとしています。 "JDBC_00 - 指定されたデータベースに接続できません：com.streamsets.pipeline.api.StageException：JDBC_06 - 接続プールの初期化に失敗しました：com.zaxxer.hikari.pool.PoolInitialization

0熱

1答えて

HBaseから読み込み、フラットファイルのコンテンツに参加してHiveに書き込むためのNiFiまたはストリームセット

Apache NiFiまたはStreamsetsで結合できるかどうかを調べようとしていました。私はHBaseから定期的に読み込み、他のテーブルと結合し、Hiveテーブルにいくつかのフィールドを書き込むことができます。または、この操作をサポートする他のワークフローマネージャツールがありますか？

1熱

1答えて

StreamSetのアップグレードとLDAP認証

Cloudera Manager（5.8.2）を使用してStreamSetを2.1.0.2から2.4.0.0にアップグレードしただけです。ストリームセットにもうログインできません - 「ログインに失敗しました」というメッセージが表示されます。新しいバージョンは、別のLDAPルックアップメソッドを使用しているようです。マイログ Updateは、以下のように見える、BEFORE： 3月15日、10：