Hacktoberfest 2026: los issues que los mantenedores marcaron para octubre, abiertos y aptos para principiantes. Explorar issues de Hacktoberfest

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

Abierto
#385 1 comentario 0 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Evaluación

Dificultad
3/5
Tiempo estimado
1-2 días
Aptitud para principiantes
25/100
Tipo de issue
Error
Claridad
Necesita aclaración
Estado de actividad
Estancado
Stack tecnológico
java, sql
Área
backend, data-engineering

Línea de trabajo

Comienza reproduciendo el problema con la configuración SQL de Kafka-to-Elasticsearch indicada en el informe, dejando sin establecer el parámetro id del plugin sink. Inspecciona el manejo de ES5 y del sink de ES al que se llega mediante esta configuración y captura la excepción completa del contexto de la captura de pantalla enlazada. Se considera terminado cuando la misma configuración ya no produce una NullPointerException.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

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

Lenguaje dominante
Java
Estrellas
2k
Forks
913
Sin PR fusionados en 30 d

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Más de DTStack/flinkStreamSQL

Todos los issues de DTStack/flinkStreamSQL

Issues similares

Más issues de Java

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.