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)