sink使用定时任务提交数据会和checkpoint不同步

Aberta

#327 aberta em 28/5/2020 0 comentários 0 reações 0 responsáveis Ver no GitHub

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade: 4/5
Tempo estimado: 3-5 dias
Facilidade para iniciantes: 20/100

Tipo de issue: Bug
Clareza: Precisa de esclarecimento
Status de atividade: Estagnada
Stack de tecnologia: java, sql
Domínio: stream-processing

Direção de pesquisa

A issue não fornece arquivos, testes nem pontos de entrada. Comece localizando as implementações de sinks Java e o tratamento de checkpoints do Flink; em seguida, reproduza a incompatibilidade de timing e estabeleça o comportamento de sincronização esperado antes de fazer uma alteração.

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

Descrição

Esta issue não tem descrição.

Linguagem predominante: Java
Estrelas: 2k
Forks: 913
Métricas de merge de PRs: Nenhum PR com merge em 30d

Guia de contribuição

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

Primeiros passos

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

Mais de DTStack/flinkStreamSQL

Flink SQL 使用滚动窗口，能不能获取到延迟数据，跟datastream一样，可以放到侧输出里面 Aberta

Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 20/100

DTStack/flinkStreamSQL#467 · 1 comentário · Aberta em 27/9/2024
这个如何引入使用flink-connector-hive啊 Aberta

Dificuldade 4/5 3-5 dias Facilidade para iniciantes 25/100

DTStack/flinkStreamSQL#437 · 3 comentários · Aberta em 25/2/2022
kudu sink writemode参数没填写报NULLPointerException Aberta

Dificuldade 3/5 1-2 dias Facilidade para iniciantes 38/100

DTStack/flinkStreamSQL#432 · 1 comentário · Aberta em 16/11/2021
新版FlinkStreamSQL已经融合进FlinkX项目 Aberta

Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 15/100

DTStack/flinkStreamSQL#431 · Aberta em 1/11/2021
有无对sql 语法校验的方法 Aberta

Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 15/100

DTStack/flinkStreamSQL#430 · 1 comentário · Aberta em 8/10/2021

Todas as issues de DTStack/flinkStreamSQL

Issues semelhantes

Azure Sandboxes: Small and ExtraSmall tiers always fail to deploy (disk request exceeds tier maximum) Aberta

area-deployment area-integrations triage:bot-seen

Dificuldade 2/5 Meio dia Facilidade para iniciantes 86/100

microsoft/aspire#20459 · 1 comentário · Aberta em 24/9/2026
[Bug][api] ContextRetrievalRequestEvent accepts a non-positive max_results Aberta

Dificuldade 2/5 1-3 horas Facilidade para iniciantes 75/100

apache/flink-agents#1156 · Aberta em 24/9/2026
[source-shopify] FAILED bulk operation without partialDataUrl is silently treated as successful Aberta

area/connectors autoteam community connectors/source/shopify needs-triage team/use type/bug

Dificuldade 2/5 1-3 horas Facilidade para iniciantes 84/100

airbytehq/airbyte#86962 · Aberta em 24/9/2026
`check_required_components()` in HDF5's CMake package configuration file doesn't function Aberta

Dificuldade 2/5 1-3 horas Facilidade para iniciantes 70/100

HDFGroup/hdf5#6690 · Aberta em 24/9/2026
[Bug] FE metric http_copy_into_query_err_total is registered under the upload error name Aberta

Dificuldade 1/5 Menos de uma hora Facilidade para iniciantes 85/100

apache/doris#68505 · 2 comentários · Aberta em 24/9/2026

Mais issues de Java