Flink JDBCSource Гарантии ⇐ JAVA

[Anonymous]

Мы используем следующее приложение jdbcsource в Flink , которое подключается к Snowflake и получает некоторые данные.

Код: Выделить всё

    return JdbcSource.builder()
.setSql("SELECT id, test WHERE ts BETWEEN ? AND ?")
.setDriverName("net.snowflake.client.jdbc.SnowflakeDriver")
.setDBUrl(config.snowflake.jdbcUrl)
.setUsername(config.snowflake.user)
.setConnectionProperty("warehouse", config.snowflake.warehouse)
.setConnectionProperty("db", config.snowflake.database)
.setConnectionProperty("role", config.snowflake.role)
.setConnectionProperty("schema", config.snowflake.schema)
.setConnectionProperty("private_key_base64", Base64.getEncoder().encodeToString(privateKeyBytes))
.setConnectionProperty("CLIENT_SESSION_KEEP_ALIVE", "true")
.setTypeInformation(TypeInformation.of(TestEntity::class.java))
.setJdbcParameterValuesProvider(
JdbcSlideTimingParameterProvider(
System.currentTimeMillis(),
15000,
15000,
0L,
),
)
.setContinuousUnBoundingSettings(
ContinuousUnBoundingSettings(
Duration.ofSeconds(5),
Duration.ofSeconds(15),
),
)
.setResultExtractor { TestEntity(it.getString(1), it.getString(2)) }
.build()

В ситуации, когда у нас может быть большее количество строк, извлеченных с одним запросом в данное момент, каковы гарантии того, что, когда мое приложение не сбои, строки, которые были направлены дальше к операторам снижения. Является ли JDBCSource Полностью поддержка контрольная точка/сбоя? Я хотел бы запустить запрос с помощью непрерывных обанкротильств.>

Подробнее здесь: https://stackoverflow.com/questions/796 ... guarantees