Injecting a fault into a stream operator in a data stream processing application
    2.
    发明授权
    Injecting a fault into a stream operator in a data stream processing application 有权
    在数据流处理应用程序中将故障注入流操作符

    公开(公告)号:US08997039B2

    公开(公告)日:2015-03-31

    申请号:US13867595

    申请日:2013-04-22

    IPC分类号: G06F9/44 G06F11/28 G06F11/36

    摘要: In one embodiment, the invention comprises partial fault tolerant stream processing applications. One embodiment of a method for implementing partial fault tolerance in a stream processing application comprising a plurality of stream operators includes: defining a quality score function that expresses how well the application is performing quantitatively, injecting a fault into at least one of the plurality of operators, assessing an impact of the fault on the quality score function, and selecting at least one partial fault-tolerant technique for implementation in the application based on the quantitative metric-driven assessment.

    摘要翻译: 在一个实施例中,本发明包括部分容错流处理应用。 用于在包括多个流操作器的流处理应用中实现部分容错的方法的一个实施例包括:定义表示应用程序在定量上执行良好的质量得分函数,将故障注入多个操作符中的至少一个 评估故障对质量得分函数的影响,以及基于定量度量驱动评估,选择至少一种部分容错技术在应用中实现。

    RESTORATION OF CONSISTENT REGIONS WITHIN A STREAMING ENVIRONMENT
    3.
    发明申请
    RESTORATION OF CONSISTENT REGIONS WITHIN A STREAMING ENVIRONMENT 有权
    在流域环境中恢复一致性地区

    公开(公告)号:US20170033979A1

    公开(公告)日:2017-02-02

    申请号:US14815430

    申请日:2015-07-31

    IPC分类号: H04L12/24 H04L29/08 H04L12/26

    摘要: A streams manager intelligently restores multiple consistent regions of streaming applications in a streaming environment to increase performance and reduce overloading of other operators and resources. The streams manager detects a failure that affects multiple consistent regions and determines a preferred schedule to restore the multiple consistent regions by analyzing the relationships of the operators and resources associated with the multiple consistent regions. The streams manager may create a dependency graph that maps the interrelationships of the operators and resources associated with the consistent regions of the streaming application and then consult the dependency graph to determine the schedule to restore the multiple consistent regions affected by the failure.

    摘要翻译: 流管理器在流媒体环境中智能地恢复流应用的多个一致区域,以提高性能并减少其他运营商和资源的超载。 流管理器检测到影响多个一致区域的故障,并且通过分析与多个一致区域相关联的运营商和资源的关系来确定优选调度以恢复多个一致区域。 流管理器可以创建依赖图,其映射与流应用的一致区域相关联的运算符和资源的相互关系,然后参考依赖关系图以确定恢复受故障影响的多个一致区域的调度。

    EVOLUTION AWARE CLUSTERING OF STREAMING GRAPHS
    6.
    发明申请
    EVOLUTION AWARE CLUSTERING OF STREAMING GRAPHS 有权
    流动图的演变聚集

    公开(公告)号:US20150269211A1

    公开(公告)日:2015-09-24

    申请号:US14219373

    申请日:2014-03-19

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30353 G06F17/30598

    摘要: A system to manage clustering vertices of a streaming graph includes a memory storing a computer program, a vertex structure storing vertices of the graph, and a cluster structure storing clusters of the graph, and a processor. Each cluster structure comprises a plurality of edge structures represent edges of the graph and each edge structure comprises two of the vertices. The processor is configured to execute the program to cluster the vertices using the structures and a maximum cluster size that is constant.

    摘要翻译: 用于管理流图的聚类顶点的系统包括存储计算机程序的存储器,存储图的顶点的顶点结构以及存储该图的簇的簇结构以及处理器。 每个簇结构包括表示图的边缘的多个边缘结构,并且每个边缘结构包括两个顶点。 处理器配置为执行程序以使用结构聚集顶点,最大聚类大小为常数。

    PARTIAL FAULT TOLERANT STREAM PROCESSING APPLICATIONS
    7.
    发明申请
    PARTIAL FAULT TOLERANT STREAM PROCESSING APPLICATIONS 有权
    部分容错流程处理应用

    公开(公告)号:US20130238936A1

    公开(公告)日:2013-09-12

    申请号:US13867595

    申请日:2013-04-22

    IPC分类号: G06F11/28

    摘要: In one embodiment, the invention comprises partial fault tolerant stream processing applications. One embodiment of a method for implementing partial fault tolerance in a stream processing application comprising a plurality of stream operators includes: defining a quality score function that expresses how well the application is performing quantitatively, injecting a fault into at least one of the plurality of operators, assessing an impact of the fault on the quality score function, and selecting at least one partial fault-tolerant technique for implementation in the application based on the quantitative metric-driven assessment.

    摘要翻译: 在一个实施例中,本发明包括部分容错流处理应用。 用于在包括多个流操作器的流处理应用中实现部分容错的方法的一个实施例包括:定义表示应用程序在定量上执行良好的质量得分函数,将故障注入多个操作符中的至少一个 评估故障对质量得分函数的影响,以及基于定量度量驱动评估,选择至少一种部分容错技术在应用中实现。