[ 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 <jenk...@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu> BAD: Jenkins <jenk...@fulliautomatix.ics.uci.edu> Reviewed-by: Steven Jacobs <sjaco...@ucr.edu> Reviewed-by: abdullah alamoudi <bamou...@gmail.com> Integration-Tests: Jenkins <jenk...@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)