Xikui Wang created ASTERIXDB-1908:
-------------------------------------

             Summary: Cannot attach join function in the feed workflow
                 Key: ASTERIXDB-1908
                 URL: https://issues.apache.org/jira/browse/ASTERIXDB-1908
             Project: Apache AsterixDB
          Issue Type: Bug
            Reporter: Xikui Wang
            Assignee: Xikui Wang


Given following query:
{noformat}
use dataverse exp2;
create function feed_join_func($a) {
    object_merge($a,
    {
        "annotations": {
                    'did': for $b in dataset testD2 where $a.num1 = $b.num1 
return $b.str1
        }
    })
}
use dataverse ${dataverse_name};

create feed ${feed_name} using socket_adapter
(
    ("sockets"="${ingest_node}:${ingest_port}"),
    ("address-type"="NC"),
    ("type-name"="probeType"),
    ("format"="adm")
);

connect feed ${feed_name} to dataset testD1 apply function feed_join_func;
start feed ${feed_name};
{noformat}
we are expecting the incoming records will be annotated with information from 
existed dataset testD2. Currently we don't support this as the messages in feed 
is not properly handled with HybridHashJoinOperator. The feed message is 
processed as a proper record which causes the build fail.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to