问题标签 [savepoints]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
106 浏览

java - Flink,如何创建 Sink 支持的 Savepoint?

我使用 Flink(1.9.2) 和 MongoDB。我想自定义一个接收器以将一些消息输出到 mongoDB 中进行测试。但是在我完成并运行它之后,我的工作无法获取保存点

我的水槽:

当我单击保存点时:无法确认接收器操作员。 错误信息

日志 我在 JobManager 和 TaskManager 中找不到错误日志,看起来不错,但保存点失败。

0 投票
0 回答
29 浏览

apache-flink - Flink 独立集群手动重启是否正常到作业状态/处理偏移?

当我们手动停止一个独立的集群(stop-cluster.sh)然后重新启动它(start-cluster.sh),我们可以看到集群启动后所有的作业都恢复了。这是使用 savepoints underhood 来保存和恢复作业,还是建议在停止集群之前手动停止带有保存点的作业,然后在重新启动集群后恢复带有保存点的作业。谢谢。

0 投票
1 回答
163 浏览

mysql - 如何在mysql中获取所有保存点状态列表

我正在学习 SQL。我正在尝试获取所有保存点列表。那么哪个命令用于获取数据库/表中的所有保存点列表?我试过 SHOW SAVEPOINTS 但它不起作用。

0 投票
1 回答
76 浏览

sql - 在 SQL 中,如果您尝试从另一个用户回滚到保存点,会发生什么?

如果 USER1 做了一些工作,添加一个保存点 SP1 但不提交。

然后,USER2 执行一些其他工作,并尝试回滚到 SP1。

会不会有错误?谢谢

0 投票
1 回答
148 浏览

postgresql - Postgresql:如果存在,则回滚到保存点

在处理 DAL 类型的系统时,我遇到了保存点安全问题:在进程开始时创建保存点,并在成功完成时释放或在错误时回滚。

然而,虽然这不正常,但整个事务有可能被正在运行的进程提交(或回滚)。这将删除我们试图释放/回滚的保存点。这个问题可以通过在发布/回滚周围放置另一个保存点来解决,但显然不可能出现SAVEPOINT错误的事务。

有没有办法对此进行最大努力的处理,以便保存点在存在时被释放/回滚,否则不会发生任何事情?根据In Postgres,如何获取当前定义的保存点列表?当时没有办法去 LBYL,现在似乎也没有办法了。

0 投票
1 回答
41 浏览

java - Flink保存点不保存值状态

我正在编写一个 Flink 程序,在重新启动新作业时无法保存我的状态变量。

我使用来自 Kafka 的连接器制作了一个简单的程序,在该连接器中接收消息和带有 valueState 变量的 RichFlatMap。这个变量是一个整数,每收到一条消息就加 1。

当值在 15 左右时,我创建了一个停止保存点,但是当我从该保存点恢复它时,计数器又回到 1。

Streamingjob.java:

测试.java:

这是我用于停止保存点的命令 ../bin/flink stop --savepointPath f74c92af01ed51af94e530ee0e208d7c

而这个用于开始保存点 ../bin/flink run flink-andy-12.3.0.jar --savepointPath file:/{...}/savepoint-f74c92-6acdb05afd11

关于我应该做什么的任何想法?

0 投票
0 回答
46 浏览

spring-boot - 如何在 Hibernate 中创建保存点 - Spring Boot

我有一个带有@Transactional 注释的方法A 和内部方法A,我调用方法B(A 和B 在同一个服务类中)。如何在方法 B 中创建保存点?类似@Transactional(propagation = Propagation.NESTED)

0 投票
0 回答
49 浏览

database - Aws rds 回溯与极光保存点有什么区别

我需要一个干净的数据库来运行测试。发现有两种方法可以工作:

  1. RDS 实例中的回溯功能似乎可以将数据库恢复到特定时间。
  2. Aurora 支持保存点以回滚事务。

他们听起来像在做同样的事情吗?有什么不同吗?我想要一种更简单的方法来实现目标,请各位大侠提出建议。谢谢!

0 投票
0 回答
14 浏览

flink-streaming - 在关闭 UDF 时以编程方式创建 flink 保存点

是否可以创建一个 flink 保存点,但不能通过客户端,而是以编程方式?

我检查了状态处理器的文档https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/libs/state_processor_api/

但我很困惑。我想在我的一个有状态 UDF 的 onClose() 钩子上触发保存点......我不知道从哪里得到

部分。我不知道要开始的 UID,因为我们需要随机生成它们,而且我似乎在 onClose() 钩子上也没有任何上下文来检索转换图......

0 投票
0 回答
14 浏览

mysql - How to know if I have started transaction control in MySQL already or not?

While running MySQL queries with the intention to be inside a transaction control, I often forget to issue the statement - START TRANSACTION; and keep on creating multiple SAVEPOINT only in the end when I try to return to a particular SAVEPOINT I realize that I have not started the transaction in the first place. In this way I wasted last 1 hour.

So, while supposedly doing transactions and creating savepoints is it possoble to check whether I have started transaction or not?