[
https://issues.apache.org/jira/browse/ASTERIXDB-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abdullah Alamoudi reassigned ASTERIXDB-1449:
--------------------------------------------
Assignee: Xikui Wang (was: Abdullah Alamoudi)
> Exception in executing Feed Connection
> --------------------------------------
>
> Key: ASTERIXDB-1449
> URL: https://issues.apache.org/jira/browse/ASTERIXDB-1449
> Project: Apache AsterixDB
> Issue Type: Bug
> Components: ING - Ingestion
> Environment: master 0716dc062d8cf6be45a0f8ad7b09ffc7ad681f64
> Reporter: Jianfeng Jia
> Assignee: Xikui Wang
> Priority: Major
>
> The ddl is here
> {code}
> create dataverse test if not exists;
> use dataverse test
> create type typeAppVersionIn as closed {
> app_id: int32,
> package_name: string,
> name: string,
> version: string,
> developer: string,
> app_type: string,
> category: string,
> m2_category: string,
> permissions: string,
> permission_weight: int32,
> notification_score: int32,
> analytic_provider: string?,
> ignore_category: string?,
> icon_link: string?,
> not_on_play: string?,
> create_device_id: int64,
> create_date: string,
> update_date: string
> }
> create type typeAppVersionOut as closed {
> app_id: int32,
> package_name: string,
> name: string,
> version: string,
> developer: string,
> app_type: string,
> category: string,
> icon_link: string?,
> create_device_id: int64,
> create_date: datetime
> }
> create function appTransfer($record) {
> {
> "app_id" : $record.app_id,
> "package_nam": $record.package_name,
> "name" : $record.name,
> "version": $record.version,
> "developer": $record.developer,
> "app_type": $record.app_type,
> "category": $record.category,
> "icon_link": $record.icon_link,
> "create_device_id": $record.create_device_id,
> "create_date":parse-datetime($record.create_date, "M/D/Y h:m")
> }
> }
> create feed appVersionFeed
> using localfs
> (("type-name"="typeAppVersionIn"),
> ("path"="172.17.0.3:///xiz/hackathon/application_versions.csv"),
> ("format"="delimited-text"),
> ("delimiter"=",")
> )
> apply function appTransfer
> create dataset appVersion(typeAppVersionOut) primary key app_id;
> set wait-for-completion-feed "true";
> connect feed appVersionFeed to dataset appVersion;
> {code}
> The web interface receives no response and the cc log shows following error
> but no more details:
> {code}
> INFO: Executing: JobStart
> May 16, 2016 3:32:54 PM
> org.apache.asterix.app.external.FeedJobNotificationHandler
> registerFeedIntakeJob
> INFO: Registered feed intake [JID:127] for feed test.appVersionFeed
> May 16, 2016 3:32:54 PM
> org.apache.hyracks.control.cc.scheduler.ActivityClusterPlanner
> planActivityCluster
> INFO: Plan for org.apache.hyracks.api.job.ActivityCluster@32940a4a
> May 16, 2016 3:32:54 PM
> org.apache.hyracks.control.cc.scheduler.ActivityClusterPlanner
> planActivityCluster
> INFO: Built 1 Task Clusters
> May 16, 2016 3:32:54 PM
> org.apache.hyracks.control.cc.scheduler.ActivityClusterPlanner
> planActivityCluster
> INFO: Tasks: [TID:ANID:ODID:0:0:0]
> May 16, 2016 3:32:54 PM
> org.apache.hyracks.control.common.work.WorkQueue$WorkerThread run
> INFO: Executing: GetJobInfo
> May 16, 2016 3:32:54 PM
> org.apache.hyracks.control.common.work.WorkQueue$WorkerThread run
> INFO: Executing: ApplicationMessage: nodeID: nc1
> May 16, 2016 3:32:54 PM org.apache.asterix.messaging.CCMessageBroker
> receivedMessage
> INFO: Received message: FEED_PROVIDER_READY
> May 16, 2016 3:32:54 PM org.apache.asterix.app.external.FeedJoint setState
> INFO: Feed joint test.appVersionFeed: [INTAKE][ACTIVE] is now ACTIVE
> May 16, 2016 3:32:54 PM
> org.apache.asterix.app.external.FeedWorkCollection$SubscribeFeedWork$FeedSubscribeWorkEventListener
> workCompleted
> WARNING: Feed subscription request Feed Connection Request
> test.appVersionFeed: [INTAKE] Apply (appTransfer) completed
> May 16, 2016 3:32:54 PM org.apache.asterix.app.external.FeedJoint
> handlePendingConnectionRequest
> INFO: Submitted feed connection request Feed Connection Request
> test.appVersionFeed: [INTAKE] Apply (appTransfer) at feed joint
> test.appVersionFeed: [INTAKE][ACTIVE]
> May 16, 2016 3:32:54 PM org.apache.asterix.external.feed.watch.FeedJobInfo
> setState
> INFO: JID:127 [INTAKE] is in ACTIVE state.
> May 16, 2016 3:32:54 PM org.apache.asterix.aql.translator.QueryTranslator
> handleSubscribeFeedStatement
> INFO: Subscriber Feed Statement
> :org.apache.asterix.lang.aql.statement.SubscribeFeedStatement@2172e612
> May 16, 2016 3:32:54 PM
> org.apache.asterix.lang.aql.statement.SubscribeFeedStatement initialize
> INFO: Connect feed statement translated to
> use dataverse test;
> set import-private-functions 'true';
> set feed-policy-name 'BasicFT';
> insert into dataset appVersion ( for $x in feed-collect
> ('test','appVersionFeed','appVersionFeed','INTAKE','appVersion','typeAppVersionIn')
> let $y1:=({^M
> "app_id" : $record.app_id,^M
> "package_nam": $record.package_name,^M
> "name" : $record.name,^M
> "version": $record.version,^M
> "developer": $record.developer,^M
> "app_type": $record.app_type,^M
> "category": $record.category,^M
> "icon_link": $record.icon_link,^M
> "create_device_id": $record.create_device_id,^M
> "create_date":parse-datetime($record.create_date, "M/D/Y h:m")^M
> })
>
>
> return $y1);
> May 16, 2016 3:32:54 PM
> org.apache.asterix.app.external.FeedWorkCollection$SubscribeFeedWork$SubscribeFeedWorkRunnable
> run
> SEVERE: Exception in executing Feed Connection Request test.appVersionFeed:
> [INTAKE] Apply (appTransfer)
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
