如何在Apache Storm Trident中发现事务是否成功提交
我正在尝试开始使用Storm Trident，并使用IOpaquePartitionedTridentSpout和OpaqueMap进行拓扑设置和运行。
然而，我很难找到让spout/函数知道事务是否成功提交的方法。我没有看到任何ack或fail方法，如在常规Storm喷口/螺栓接口。
谢谢
共有1个答案
我建议您考虑实现一个iTridentSpout。它在协调器中有一个success（）方法，当批处理成功时调用该方法。来自协调器的相同元数据被发送给所有发射器，因此他们需要分工。
-
持久性提供程序只需要在Java EE容器环境中支持CDI注入实体侦听器。如果未启用CDI，则持久性提供程序不得调用依赖于CDI注入的实体侦听器。 当从Java EE环境中调用时，实体的回调侦听器共享调用组件的企业命名上下文，并且在调用回调方法时在调用组件的事务和安全上下文中调用实体回调方法。 例如，如果事务提交是事务属性为的会话bean业务方法正常终止的结果，则和回调将在该组件的命名上下文、事务上
-
我在这里很困惑。JPA中的提交或回滚完成事务吗？我使用的是spring和容器管理的EntityManager。感谢任何回答。
-
问题内容： 我有一个表格，基本上是上传一个文件。我要提交两次表格，第1次不包含多部分，第二次1次包含多部分。 但是我想先检查一下第一次提交表单是否成功，然后再进行第二次提交 引用@Vern后编辑 这是我的servlet部分。我在哪里确定它是否由多个部分组成。如果未将 resultType 存储到会话变量中，则返回， 现在，我要检查此“已 提交 ”或类似内容，然后第二次提交表格。 第二表单提交：在这
-
问题内容： 即使文件在远程http服务器上不存在，它也会以静默方式返回，它只是将html页面保存到命名文件中。例如： 即使abc.jpg在google.com服务器上不存在，它只是默默返回，生成的不是有效的jpg文件，它实际上是html页面。我猜返回的标头（一个httplib.HTTPMessage实例）可以用来实际上告诉检索是否成功，但是我找不到的任何文档。 有人可以提供有关此问题的一些信息吗？
-
我在A处有个方法 服务B中的另一种方法 我的问题是，例如，当“repository.insertRandomValue（）”抛出ConstraintViolationException时，即使它在catch（）中被捕获，线程也以 我尝试将传播设置为REQUIRES\u NEW，并尝试将transaction manager和GlobalRollbackOnParticipationFailure设
-
handler_name:SoundHandle\n输出#0,mp3,to'/tmp/voice00045.mp3':\n元数据:\n major_brand:3gp4\n minor_version:0\n compatible_brands:isom3gp4\n TSSE:lavf56.40.101\n Stream#0:0(eng):audio:mp3(libmp3lame)，44100 H