Uploaded image for project: 'Apache AsterixDB'
  1. Apache AsterixDB
  2. ASTERIXDB-1301

Socket feed connection fails

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: ING - Ingestion
    • Labels:
      None

      Description

      Run the following code, which creates a feed using socket adapter fails during feed connect:

      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;
      

      pushRuntime creation fails with the error:

      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)
      

      UPD: this issue is caused by regression in 284590ed9c30349058fdc448852ebb6dc698912f

        Attachments

          Activity

            People

            • Assignee:
              amoudi Abdullah Alamoudi
              Reporter:
              iabsalyamov Ildar Absalyamov
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: