[
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)
