datastax-enterprise

0熱

1答えて

com.datastax.driver.core.ControlConnection：[コントロールの接続] 60000ミリ秒で再試行をスケジューリングする任意のホストに接続できません

DSEとKafkaを使用して作成されたSparkストリーミングアプリケーションがあります。クラスタ仕様：3分析、2カッサンドラ、および1カフカノード。すべてec2インスタンスです。ストリーミングでは、KafkaでSparkストリーミングを使用します。 ERROR 2017-03-20 06：13：54,690 com.datastax.driver.core.ControlConnection：[

1熱

2答えて

グラフクエリを実行しようとすると、ノードjsドライバからのdseグラフ接続のタイムアウトが発生する

私はDSE Enterpriseの最新バージョンで遊んでいます。私はグラフの機能に興味があります。 TitanにはDSEグラフに触発されたオープンソースのグラフデータベースが1つあり、DSE Graphを代替データベースとして評価しようとしています。Titanには多くの管理機能と操作機能がありません。 nodejsドライバを使用してdatastaxクラスタ上のグラフのクエリを実行しようとしていると

0熱

1答えて

Datastax 5.0.5 INFO [POスレッド0] DbInfoRollupPlugin.java - ノードレベルのDBサマリーを取得中にエラーが発生しました。

2つの同一のクラスタでDSE 5.0.5を実行していますが、すべてのノードがSpark + SOLRです。しかし、何かが間違っていると私はできない「INFO」として報告されて INFO [PO-thread-0] 2017-04-02 19:26:43,176 DbInfoRollupPlugin.java:196 - Error retrieving node level db summary

1熱

1答えて

TwitterUtilsライブラリをscalaからインポートする方法

私はDSE 4.8を使用しています。私はストリーミングできるようにパッケージを追加する方法を教えてください object twitter is not a member of package org.apache.spark.streaming. ：私は、それはエラーを見せて輸入org.apache.spark.streaming.twitter.TwitterUtils を使用してtwitte

1熱

1答えて

Datastax DSE 5.0.xグラフで（または）クエリでindexが使用されないのはなぜですか？

私がしなければ、私は、ユーザーにとUUID にインデックスを作成しました： schema.vertexLabel("User").describe() 私が手： schema.vertexLabel("User").index("byUuid").materialized().by("uuid").add() 私が実行しているとき： g.V().hasLabel("User").has("

0熱

1答えて

allow_scanが無効になることなく、Datastax DSE 5.0.x Graphからデータのサブセットを照会できないのはなぜですか？

こんにちは私は自分のスキーマでスキャンを無効にしました。私はそれらのようなクエリが許可されないことを知っている： g.V() g.V().hasLabel("User") org.apache.tinkerpop.gremlin.driver.exception.ResponseException：問合せ句に答えるために、インデックスが見つかりませんでしたし、 graph.allow_

0熱

1答えて

違法循環参照は、私がスパーク+ Scalaの組み合わせで</em></strong>エラーを含む<strong><em>違法循環参照に直面しています

を兼ね備えています。 Error Ocured during job for '1473170880000000' and Error Message is scala.reflect.internal.Symbols$CyclicReference: illegal cyclic reference involving method srcip at scala.reflect.int

1熱

1答えて

DSE opscenterは、1つのノードがダウンしたときにクラスタに対する書き込み要求の失敗を示します。

2ノードのcassandraクラスタがあり、そのうちの1つを停止して再起動しました。私たちは、オレンジ色の線とのノードを再起動：この時間間隔の間に、OpsCenterの中のグラフは、このようなものを示しました。私はなぜこのグラフに休憩があるのだろうかと思います。私はこれを尋ねます。アプリケーションが正常に動作していて、他のノードが再起動されている間、青い線でノードにデータが書き込まれていたからで

0熱

1答えて

Cassandraテーブルにjsonファイルを挿入する

現在、Cassandra-Rubyドライバを使用して、JSONファイルのデータをデータベースの既存のテーブルに挿入しています。 JSONファイルには、次のようになります。 [ { "id": "123", "destination": "234", "type": "equipment", "support": "type 1", "te

0熱

1答えて

私のCassandra Prepared Statementはなぜデータの摂取が遅いのですか？

私はカサンドラ3.10.0私のコードは、摂取でDatastaxエンタープライズ5.1を実行している私は3ノードカサンドラクラスタに摂取したい10万名前のJavaのリストを持っているが、それはlooooong時間がかかります。私はクラスタでストレステストを実行し、毎秒25,000回以上の書き込みを行うことができました。私の摂取コードでは、約200 /秒のひどいパフォーマンスを得ています。 My J