es5和es的sink插件id参数不填时, 报空指针异常
まだ誰も着手していません。
評価
- 難易度
- 3/5
- 見積もり時間
- 1〜2日
- 初心者へのやさしさ
- 25/100
- issue の種類
- バグ
- 明瞭さ
- 説明が足りない
- 活発さ
- 停滞
調査の方向性
まず、報告にある Kafka-to-Elasticsearch SQL 構成で、sink plugin の id パラメーターを未設定のままにして問題を再現します。この構成によって到達する ES5 および ES sink の処理を調査し、リンクされたスクリーンショットのコンテキストから完全な例外を記録します。同じ構成で null pointer exception が発生しなくなれば完了です。
索引モデルが issue の本文から書いたものです。
説明
配置文件
CREATE TABLE kafka(
id varchar
)WITH(
bootstrapServers='10.10.14.117:9092',
timezone='Asia/Shanghai',
groupId='ddd',
parallelism='1',
topic='ddd',
offsetReset='latest',
sourcedatatype='dt_nest',
type='kafka');
CREATE TABLE es(
id varchar
)WITH(
sourceid='b93d1e56-0b17-4855-a60f-bd18fd245a78',
cluster='aiops-cluster',
address='10.10.14.51:9200',
parallelism='1',
index='myresult',
estype='_doc',
authMesh='false',
type='elasticsearch');
insert into es select id from kafka;
出现以下错误

- 主要言語
- Java
- スター
- 2k
- フォーク
- 913
- PR マージ指標
- 30日以内にマージされた PR はありません
コントリビューションガイド
このリポジトリのコントリビューションガイドは索引されていません
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
DTStack/flinkStreamSQL のほかの issue
-
難易度 5/5 1週間以上 初心者へのやさしさ 20/100
DTStack/flinkStreamSQL#467 · コメント 1 件 ·
-
難易度 4/5 3〜5日 初心者へのやさしさ 25/100
DTStack/flinkStreamSQL#437 · コメント 3 件 ·
-
難易度 3/5 1〜2日 初心者へのやさしさ 38/100
DTStack/flinkStreamSQL#432 · コメント 1 件 ·
-
難易度 5/5 1週間以上 初心者へのやさしさ 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 オープン
難易度 5/5 1週間以上 初心者へのやさしさ 15/100
DTStack/flinkStreamSQL#430 · コメント 1 件 ·
DTStack/flinkStreamSQL の issue をすべて見る
似ている issue
-
難易度 2/5 1〜3時間 初心者へのやさしさ 75/100
elastic/gradle-plugins#157 ·
-
enhancement Tools
難易度 1/5 1時間未満 初心者へのやさしさ 75/100
-
難易度 2/5 1〜3時間 初心者へのやさしさ 70/100
apache/rocketmq-dashboard#5008 ·
-
bug
難易度 2/5 1〜3時間 初心者へのやさしさ 75/100
-
DETECT_PARAMETER_NAMES=false silently disables @ConstructorProperties-based Creator detection too オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 70/100
FasterXML/jackson-databind#6229 ·