Hacktoberfest 2026: as issues que os mantenedores marcaram para outubro, abertas e boas para iniciantes. Ver issues do Hacktoberfest

es5和es的sink插件id参数不填时, 报空指针异常

Aberta
#385 1 comentário 0 reações 0 responsáveis Ver no GitHub

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade
3/5
Tempo estimado
1-2 dias
Facilidade para iniciantes
25/100
Tipo de issue
Bug
Clareza
Precisa de esclarecimento
Status de atividade
Estagnada
Stack de tecnologia
java, sql
Domínio
backend, data-engineering

Direção de pesquisa

Comece reproduzindo o problema com a configuração SQL de Kafka-to-Elasticsearch descrita no relatório, deixando o parâmetro id do sink plugin sem ser definido. Inspecione o tratamento de ES5 e do ES sink alcançado por essa configuração e capture a exceção completa do contexto da captura de tela vinculada. Considera-se concluído quando a mesma configuração não produzir mais uma NullPointerException.

Escrita pelo modelo de indexação a partir do texto da issue.

Descrição

配置文件
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;

出现以下错误

image

Linguagem predominante
Java
Estrelas
2k
Forks
913
Nenhum PR com merge em 30d

Guia de contribuição

Nenhum guia de contribuição indexado para este repositório

Primeiros passos

  1. Leia a issue inteira e depois o guia de contribuição do projeto.
  2. Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
  3. Faça um fork do repositório e trabalhe em uma branch.
  4. Abra um pull request que referencie o número da issue.

Mais de DTStack/flinkStreamSQL

Todas as issues de DTStack/flinkStreamSQL

Issues semelhantes

Mais issues de Java

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.