Mailing-List: contact notifications-help@asterixdb.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@asterixdb.apache.org
Date: Mon, 27 Mar 2017 03:18:41 +0000 (UTC)
From: "Chen Luo (JIRA)" <jira@apache.org>
To: notifications@asterixdb.incubator.apache.org
Message-ID: <JIRA.13059264.1490584678000.127270.1490584721554@Atlassian.JIRA>
In-Reply-To: <JIRA.13059264.1490584678000@Atlassian.JIRA>
References: <JIRA.13059264.1490584678000@Atlassian.JIRA> <JIRA.13059264.1490584678637@jira-lw-us.apache.org>
Subject: [jira] [Created] (ASTERIXDB-1861) Port not open after creating feed
 in single server mode
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Mon, 27 Mar 2017 03:18:48 -0000

Chen Luo created ASTERIXDB-1861:
-----------------------------------

             Summary: 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)