asterixdb-notifications mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ildar Absalyamov (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (ASTERIXDB-1301) Socket feed connection fails
Date Mon, 22 Feb 2016 06:24:18 GMT

     [ https://issues.apache.org/jira/browse/ASTERIXDB-1301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Ildar Absalyamov updated ASTERIXDB-1301:
----------------------------------------
    Description: 
Run the following code, which creates a feed using socket adapter fails during feed connect:
{noformat}
drop dataverse experiments if exists;
create dataverse experiments;
use dataverse experiments;

create type TwitterUserType as closed {
    screen-name: string,
    lang: string,
    friends_count: int32,
    statuses_count: int32,
    name: string,
    followers_count: int32
}

create type TweetMessageType as closed {
    tweetid: int64,
    user: TwitterUserType,
    sender-location: point,
    send-time: datetime,
    referred-topics: {{ string }},
    message-text: string
}

create dataset Tweets(TweetMessageType) primary key tweetid;

create feed TweetFeed using socket_adapter
(
    ("sockets"="127.0.0.1:10001"),
    ("address-type"="IP"),
    ("type-name"="TweetMessageType"),
    ("format"="adm")
);

set wait-for-completion-feed "false";

connect feed TweetFeed to dataset Tweets;
{noformat}
pushRuntime creation fails with the error:
{noformat}
SEVERE: Initialization of the feed adaptor failed with exception org.apache.hyracks.api.exceptions.HyracksDataException:
Source intake task not found for source feed id experiments.TweetFeed1
java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization
of the feed adapter failed
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:76)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivity.createPushRuntime(SuperActivity.java:168)
	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:134)
	at org.apache.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:132)
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization of the feed
adapter failed
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:111)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.init(SuperActivityOperatorNodePushable.java:95)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:74)
	... 3 more
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Source intake task not
found for source feed id experiments.TweetFeed1
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:101)
	... 5 more
java.lang.RuntimeException: java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:177)
	at org.apache.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:132)
Caused by: java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:76)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivity.createPushRuntime(SuperActivity.java:168)
	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:134)
	... 1 more
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization of the feed
adapter failed
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:111)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.init(SuperActivityOperatorNodePushable.java:95)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:74)
	... 3 more
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Source intake task not
found for source feed id experiments.TweetFeed1
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:101)
{noformat}

UPD: this issue is caused by regression in 284590ed9c30349058fdc448852ebb6dc698912f

  was:
Run the following code, which creates and connects to a feed using socket adapter fails during
feed connect:
{noformat}
drop dataverse experiments if exists;
create dataverse experiments;
use dataverse experiments;

create type TwitterUserType as closed {
    screen-name: string,
    lang: string,
    friends_count: int32,
    statuses_count: int32,
    name: string,
    followers_count: int32
}

create type TweetMessageType as closed {
    tweetid: int64,
    user: TwitterUserType,
    sender-location: point,
    send-time: datetime,
    referred-topics: {{ string }},
    message-text: string
}

create dataset Tweets(TweetMessageType) primary key tweetid;

create feed TweetFeed using socket_adapter
(
    ("sockets"="127.0.0.1:10001"),
    ("address-type"="IP"),
    ("type-name"="TweetMessageType"),
    ("format"="adm")
);

set wait-for-completion-feed "false";

connect feed TweetFeed to dataset Tweets;
{noformat}
pushRuntime creation fails with the error:
{noformat}
SEVERE: Initialization of the feed adaptor failed with exception org.apache.hyracks.api.exceptions.HyracksDataException:
Source intake task not found for source feed id experiments.TweetFeed1
java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization
of the feed adapter failed
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:76)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivity.createPushRuntime(SuperActivity.java:168)
	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:134)
	at org.apache.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:132)
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization of the feed
adapter failed
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:111)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.init(SuperActivityOperatorNodePushable.java:95)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:74)
	... 3 more
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Source intake task not
found for source feed id experiments.TweetFeed1
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:101)
	... 5 more
java.lang.RuntimeException: java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:177)
	at org.apache.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:132)
Caused by: java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:76)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivity.createPushRuntime(SuperActivity.java:168)
	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:134)
	... 1 more
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization of the feed
adapter failed
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:111)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.init(SuperActivityOperatorNodePushable.java:95)
	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:74)
	... 3 more
Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Source intake task not
found for source feed id experiments.TweetFeed1
	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:101)
{noformat}

UPD: this issue is caused by regression in 284590ed9c30349058fdc448852ebb6dc698912f


> Socket feed connection fails
> ----------------------------
>
>                 Key: ASTERIXDB-1301
>                 URL: https://issues.apache.org/jira/browse/ASTERIXDB-1301
>             Project: Apache AsterixDB
>          Issue Type: Bug
>          Components: Feeds
>            Reporter: Ildar Absalyamov
>            Assignee: Abdullah Alamoudi
>
> Run the following code, which creates a feed using socket adapter fails during feed connect:
> {noformat}
> drop dataverse experiments if exists;
> create dataverse experiments;
> use dataverse experiments;
> create type TwitterUserType as closed {
>     screen-name: string,
>     lang: string,
>     friends_count: int32,
>     statuses_count: int32,
>     name: string,
>     followers_count: int32
> }
> create type TweetMessageType as closed {
>     tweetid: int64,
>     user: TwitterUserType,
>     sender-location: point,
>     send-time: datetime,
>     referred-topics: {{ string }},
>     message-text: string
> }
> create dataset Tweets(TweetMessageType) primary key tweetid;
> create feed TweetFeed using socket_adapter
> (
>     ("sockets"="127.0.0.1:10001"),
>     ("address-type"="IP"),
>     ("type-name"="TweetMessageType"),
>     ("format"="adm")
> );
> set wait-for-completion-feed "false";
> connect feed TweetFeed to dataset Tweets;
> {noformat}
> pushRuntime creation fails with the error:
> {noformat}
> SEVERE: Initialization of the feed adaptor failed with exception org.apache.hyracks.api.exceptions.HyracksDataException:
Source intake task not found for source feed id experiments.TweetFeed1
> java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:76)
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivity.createPushRuntime(SuperActivity.java:168)
> 	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:134)
> 	at org.apache.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:132)
> Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization of
the feed adapter failed
> 	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:111)
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.init(SuperActivityOperatorNodePushable.java:95)
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:74)
> 	... 3 more
> Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Source intake task
not found for source feed id experiments.TweetFeed1
> 	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:101)
> 	... 5 more
> java.lang.RuntimeException: java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
> 	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:177)
> 	at org.apache.hyracks.control.common.work.WorkQueue$WorkerThread.run(WorkQueue.java:132)
> Caused by: java.lang.IllegalStateException: org.apache.hyracks.api.exceptions.HyracksDataException:
Initialization of the feed adapter failed
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:76)
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivity.createPushRuntime(SuperActivity.java:168)
> 	at org.apache.hyracks.control.nc.work.StartTasksWork.run(StartTasksWork.java:134)
> 	... 1 more
> Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Initialization of
the feed adapter failed
> 	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:111)
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.init(SuperActivityOperatorNodePushable.java:95)
> 	at org.apache.hyracks.api.rewriter.runtime.SuperActivityOperatorNodePushable.<init>(SuperActivityOperatorNodePushable.java:74)
> 	... 3 more
> Caused by: org.apache.hyracks.api.exceptions.HyracksDataException: Source intake task
not found for source feed id experiments.TweetFeed1
> 	at org.apache.asterix.external.operators.FeedCollectOperatorDescriptor.createPushRuntime(FeedCollectOperatorDescriptor.java:101)
> {noformat}
> UPD: this issue is caused by regression in 284590ed9c30349058fdc448852ebb6dc698912f



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message