Skip to content
This repository was archived by the owner on Aug 22, 2025. It is now read-only.
This repository was archived by the owner on Aug 22, 2025. It is now read-only.

Inner join with streaming sources failing after some time #75

Description

@dhiguero

It seems that the actor timeouts from the point of view of the client, and the results being calculated on the MetaServer is unable to reach the client.

From the Metash point of view:

Result page: 0
metash-sh:dhiguero:demo>
Result: QID: 92c789e8-4462-480a-8526-58789c8ca4be

Partial result: true

name | age | rating | member | name | gender | email | age | bool | phrase |
name_5 | 15 | 2.0 | true | female | name_5@domain.com | false | |

Result page: 0
metash-sh:dhiguero:demo> insert into demo.temporal (name, age, rating, member) values ('name_5', 10, 2.0, true);
QID: 62c45dd3-3497-4ea3-aa63-b01b8571dfb2

metash-sh:dhiguero:demo>
Result: QID: 62c45dd3-3497-4ea3-aa63-b01b8571dfb2

Partial result: true
Result |
Data inserted |

Result page: 0
metash-sh:dhiguero:demo>
(Nothing arrives here)

On the MetaServer

[MetaServer] 28-07-2014 10:27:36.010 [DEBUG|DAGScheduler] After removal of stage 30, remaining stages = 0
[MetaServer] 28-07-2014 10:27:36.011 [INFO|SparkContext] Job finished: take at Bridge.java:329, took 1.855455151 s
[MetaServer] 28-07-2014 10:27:36.012 [INFO|DeepUtils] Deep Result: 1 rows & 8 columns
[MetaServer] 28-07-2014 10:27:36.012 [DEBUG|DeepUtils]

name | age | rating | member | gender | email | bool | phrase |

com.stratio.meta.common.data.Cell@7d253121 - com.stratio.meta.common.data.Cell@14bcadb7 - com.stratio.meta.common.data.Cell@6f30d403 - com.stratio.meta.common.data.Cell@6eaf49fc - com.stratio.meta.common.data.Cell@36227829 - com.stratio.meta.common.data.Cell@10fee783 - com.stratio.meta.common.data.Cell@4f11522c - com.stratio.meta.common.data.Cell@7a29ef41 -

Metadata

Metadata

Assignees

No one assigned

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions