[ https://issues.apache.org/jira/browse/ASTERIXDB-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942578#comment-15942578 ]
Steven Jacobs commented on ASTERIXDB-1861: ------------------------------------------ Hi, I think you are missing the start feed command. This is a recent change to Asterix so might be missing from the documentation you used. After connecting to dataset, use the following command: start feed TweetFeed; > Port not open after creating feed in single server mode > ------------------------------------------------------- > > Key: ASTERIXDB-1861 > URL: https://issues.apache.org/jira/browse/ASTERIXDB-1861 > Project: Apache AsterixDB > Issue Type: Bug > Components: Feeds > Environment: single server mode, using default configurations from > ./opt/local/conf/ > Reporter: Chen Luo > Priority: Minor > > I'm using the single server mode with 1 CC node and 2 NC nodes (red and > blue). All configurations are default from /opt/local/conf/. However, after > creating a feed and connecting it to a dataset, the specified port is not > open, and no error message/ stacktrace is shown. > The following commands work fine (and the specified port is open) on > AsterixDB 0.9.0. > Steps to reproduce: > {code} > drop dataverse twitter if exists; > create dataverse twitter if not exists; > use dataverse twitter > create type typeUser if not exists as open { > id: int64, > name: string, > screen_name : string, > lang : string, > location: string, > create_at: date, > description: string, > followers_count: int32, > friends_count: int32, > statues_count: int64 > } > create type typePlace if not exists as open{ > country : string, > country_code : string, > full_name : string, > id : string, > name : string, > place_type : string, > bounding_box : rectangle > } > create type typeGeoTag if not exists as open { > stateID: int32, > stateName: string, > countyID: int32, > countyName: string, > cityID: int32?, > cityName: string? > } > create type typeTweet if not exists as open{ > create_at : datetime, > id: int64, > "text": string, > in_reply_to_status : int64, > in_reply_to_user : int64, > favorite_count : int64, > coordinate: point?, > retweet_count : int64, > lang : string, > is_retweet: boolean, > hashtags : {{ string }} ?, > user_mentions : {{ int64 }} ? , > user : typeUser, > place : typePlace?, > geo_tag: typeGeoTag > } > create dataset ds_tweet(typeTweet) if not exists primary key id > using compaction policy correlated-prefix > (("max-mergable-component-size"="1048576"),("max-tolerance-component-count"="10")) > with filter on create_at ; > // with filter on create_at; > //"using" "compaction" "policy" CompactionPolicy ( Configuration )? )? > create feed TweetFeed using socket_adapter > ( > ("sockets"="red:10001"), > ("address-type"="nc"), > ("type-name"="typeTweet"), > ("format"="adm") > ); > connect feed TweetFeed to dataset ds_tweet; > {code} > Then check port 10001 using nmap: > {code} > nmap -p 10001 localhost > {code} > It shows: > {code} > PORT STATE SERVICE > 10001/tcp closed scp-config > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)