Início / user-1165499

ashur's questions

Martin Hope
ashur
Asked: 2025-04-03 00:05:39 +0800 CST
  • 5

Tenho a seguinte definição de JDBCfonte em Apache Flink.

    val jdbcSource = JdbcSource.builder<LoggedInEvent>()
    .setDBUrl("jdbc:postgresql://db:5432/postgres")
    .setSql("SELECT player_id, past_logins FROM user_initial_data")
    .setUsername("postgres")
    .setPassword("example")
    .setTypeInformation(TypeInformation.of(PlayerLoggedInEvent::class.java))
    .setResultExtractor { LoggedInEvent(it.getInt(1).toString(), it.getInt(2), Instant.now().toEpochMilli()) }
    .build()

val snapshotsStream = env.fromSource(jdbcSource, WatermarkStrategy.noWatermarks(), "LoggedInSnapshots")

Atualmente estou enfrentando dois problemas com esta solução:

  1. Não posso programar isso para ser executado a cada N segundos. Existe alguma maneira simples de fazer isso com as ferramentas existentes?
  2. Isso está relacionado ao #1, mas isso é executado apenas uma vez e o trabalho termina. Quero que isso seja agendado e executado continuamente dentro do mesmo trabalho.
java