asterixdb-notifications mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ASTERIXDB-1310) Creating feed with autogenerated key fails
Date Sat, 25 Mar 2017 00:58:42 GMT

    [ https://issues.apache.org/jira/browse/ASTERIXDB-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941413#comment-15941413
] 

ASF subversion and git services commented on ASTERIXDB-1310:
------------------------------------------------------------

Commit c2d296f54b553225e5b1a4aa48c45eb71e65b50f in asterixdb's branch refs/heads/master from
[~idleft]
[ https://git-wip-us.apache.org/repos/asf?p=asterixdb.git;h=c2d296f ]

ASTERIXDB-1310 Autogenerated uuid

Added test case for how to use autogenerated uuid with feed properly.

Change-Id: Ief4fba8a7227a40c5d22293758cbdf4575b14401
Reviewed-on: https://asterix-gerrit.ics.uci.edu/1601
Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
BAD: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Steven Jacobs <sjaco002@ucr.edu>
Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>


> Creating feed with autogenerated key fails
> ------------------------------------------
>
>                 Key: ASTERIXDB-1310
>                 URL: https://issues.apache.org/jira/browse/ASTERIXDB-1310
>             Project: Apache AsterixDB
>          Issue Type: Bug
>          Components: Data Model, Feeds
>            Reporter: Ildar Absalyamov
>            Assignee: Xikui Wang
>
> Attempt to create a feed with autogenerated primary key fails:
> {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,
>     tweetid: uuid,
>     user: TwitterUserType,
>     sender-location: point,
>     send-time: datetime,
>     referred-topics: {{ string }},
>     message-text: string
> }
> create dataset Tweets(TweetMessageType) primary key tweetid autogenerated;
> create feed TweetFeed using socket_adapter
> (
>     ("sockets"="127.0.0.1:10001"),
>     ("address-type"="IP"),
>     ("type-name"="TweetMessageType"),
>     ("format"="adm"),
>     ("duration"="1200")
> );
> set wait-for-completion-feed "false";
> connect feed TweetFeed1 to dataset Tweets;
> {noformat}
> Stacktrace:
> {noformat}
> SEVERE: Exception in executing Feed Connection Request experiments.TweetFeed1: [SOURCE_FEED_INTAKE_STAGE]
Apply ()
> Exception in thread "pool-7-thread-1" java.lang.RuntimeException: org.apache.hyracks.algebricks.common.exceptions.AlgebricksException:
Duplicate field "uuid" encountered
> 	at org.apache.asterix.api.common.FeedWorkCollection$SubscribeFeedWork$SubscribeFeedWorkRunnable.run(FeedWorkCollection.java:101)
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> 	at java.lang.Thread.run(Thread.java:745)
> Caused by: org.apache.hyracks.algebricks.common.exceptions.AlgebricksException: Duplicate
field "uuid" encountered
> 	at org.apache.asterix.om.typecomputer.impl.RecordMergeTypeComputer.mergedNestedType(RecordMergeTypeComputer.java:132)
> 	at org.apache.asterix.om.typecomputer.impl.RecordMergeTypeComputer.computeType(RecordMergeTypeComputer.java:105)
> 	at org.apache.asterix.dataflow.data.common.AqlExpressionTypeComputer.getTypeForFunction(AqlExpressionTypeComputer.java:86)
> 	at org.apache.asterix.dataflow.data.common.AqlExpressionTypeComputer.getType(AqlExpressionTypeComputer.java:57)
> 	at org.apache.hyracks.algebricks.core.algebra.typing.AbstractTypeEnvironment.getType(AbstractTypeEnvironment.java:45)
> 	at org.apache.asterix.om.typecomputer.impl.NotNullTypeComputer.computeType(NotNullTypeComputer.java:50)
> 	at org.apache.asterix.dataflow.data.common.AqlExpressionTypeComputer.getTypeForFunction(AqlExpressionTypeComputer.java:86)
> 	at org.apache.asterix.dataflow.data.common.AqlExpressionTypeComputer.getType(AqlExpressionTypeComputer.java:57)
> 	at org.apache.hyracks.algebricks.core.algebra.operators.logical.AssignOperator.computeOutputTypeEnvironment(AssignOperator.java:95)
> 	at org.apache.hyracks.algebricks.core.rewriter.base.AlgebricksOptimizationContext.computeAndSetTypeEnvironmentForOperator(AlgebricksOptimizationContext.java:270)
> 	at org.apache.asterix.optimizer.rules.IntroduceAutogenerateIDRule.rewritePost(IntroduceAutogenerateIDRule.java:123)
> 	at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:125)
> 	at org.apache.hyracks.algebricks.core.rewriter.base.AbstractRuleController.rewriteOperatorRef(AbstractRuleController.java:99)
> 	at org.apache.hyracks.algebricks.compiler.rewriter.rulecontrollers.SequentialOnceRuleController.rewriteWithRuleCollection(SequentialOnceRuleController.java:44)
> 	at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.runOptimizationSets(HeuristicOptimizer.java:95)
> 	at org.apache.hyracks.algebricks.core.rewriter.base.HeuristicOptimizer.optimize(HeuristicOptimizer.java:82)
> 	at org.apache.hyracks.algebricks.compiler.api.HeuristicCompilerFactoryBuilder$1$1.optimize(HeuristicCompilerFactoryBuilder.java:87)
> 	at org.apache.asterix.api.common.APIFramework.compileQuery(APIFramework.java:289)
> 	at org.apache.asterix.aql.translator.QueryTranslator.rewriteCompileQuery(QueryTranslator.java:1895)
> 	at org.apache.asterix.aql.translator.QueryTranslator.handleSubscribeFeedStatement(QueryTranslator.java:2353)
> 	at org.apache.asterix.aql.translator.QueryTranslator.compileAndExecute(QueryTranslator.java:371)
> 	at org.apache.asterix.api.common.FeedWorkCollection$SubscribeFeedWork$SubscribeFeedWorkRunnable.run(FeedWorkCollection.java:92)
> 	... 3 more
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message