You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@asterixdb.apache.org by "Xikui Wang (JIRA)" <ji...@apache.org> on 2017/07/07 07:14:00 UTC
[jira] [Updated] (ASTERIXDB-1978) Type inference exception after
RemoveUnusedAssignAndAggregateRule
[ https://issues.apache.org/jira/browse/ASTERIXDB-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xikui Wang updated ASTERIXDB-1978:
----------------------------------
Description:
The original exception is observed in the BAD extension. However, with following query running on AsterixDB, NullPointerException will be thrown during the query optimization.
{noformat}
drop dataverse Starbucks if exists;
create dataverse Starbucks;
use Starbucks;
create type StarbucksType as {
id: string,
location: point
};
create type FollowersType as {
user_id: string,
twitter_id: string,
followers: [string]
};
create dataset Starbucks(StarbucksType)
primary key id
create dataset Followers(FollowersType)
primary key user_id
create type TwitterUser as closed {
id: int64,
id_str: string,
screen_name: string
};
create type Tweet as open {
id: int64,
user: TwitterUser,
timestamp_ms: string
}
create dataset Tweets (Tweet)
primary key id;
use Starbucks;
create function StarbucksFriends(userId) {
(select distinct tweet.user.screen_name, tweet.coordinates.coordinates, tweet.timestamp_ms
from Tweets tweet join (
select w
from Followers f
unnest f.followers w
where f.user_id = userId
) id on tweet.user.id_str = id.w
where tweet.coordinates is not null and (datetime_from_unix_time_in_ms(bigint(tweet.timestamp_ms)) > current_datetime() - day_time_duration("PT24H"))
union all
select star.Starbucks
from (select distinct s as Starbucks
from Starbucks s, Tweets tweet, Followers follower
where tweet.coordinates is not null
and tweet.user.id_str = follower.twitter_id
and follower.user_id = userId
and spatial_intersect(create_circle(create_point(tweet.coordinates.coordinates[0], tweet.coordinates.coordinates[1]), .01), create_circle(s.location, 5.0))) star)};
use Starbucks;
create type SubType as open{
subscriptionId: int64,
BrokerName: string,
DataverseName: string,
param0: string
}
create type ResType as open {
id: int64
}
create dataset starsSubscriptions(SubType) primary key subscriptionId;
create dataset starsResults(ResType) primary key id;
use Starbucks;
SET inline_with "false"
insert into Starbucks.starsResults as a (
with channelExecutionTime as current_datetime()
select result, channelExecutionTime, sub.subscriptionId as subscriptionId,current_datetime() as deliveryTime
from Starbucks.starsSubscriptions sub,
Metadata.Broker b,
Starbucks.StarbucksFriends(sub.param0) result
where b.BrokerName = sub.BrokerName
and b.DataverseName = sub.DataverseName
) returning a;
{noformat}
was:
The original exception is spotted in the BAD extension. However, with following query running on AsterixDB, NullPointerException will be thrown during the query optimization.
{noformat}
drop dataverse Starbucks if exists;
create dataverse Starbucks;
use Starbucks;
create type StarbucksType as {
id: string,
location: point
};
create type FollowersType as {
user_id: string,
twitter_id: string,
followers: [string]
};
create dataset Starbucks(StarbucksType)
primary key id
create dataset Followers(FollowersType)
primary key user_id
create type TwitterUser as closed {
id: int64,
id_str: string,
screen_name: string
};
create type Tweet as open {
id: int64,
user: TwitterUser,
timestamp_ms: string
}
create dataset Tweets (Tweet)
primary key id;
use Starbucks;
create function StarbucksFriends(userId) {
(select distinct tweet.user.screen_name, tweet.coordinates.coordinates, tweet.timestamp_ms
from Tweets tweet join (
select w
from Followers f
unnest f.followers w
where f.user_id = userId
) id on tweet.user.id_str = id.w
where tweet.coordinates is not null and (datetime_from_unix_time_in_ms(bigint(tweet.timestamp_ms)) > current_datetime() - day_time_duration("PT24H"))
union all
select star.Starbucks
from (select distinct s as Starbucks
from Starbucks s, Tweets tweet, Followers follower
where tweet.coordinates is not null
and tweet.user.id_str = follower.twitter_id
and follower.user_id = userId
and spatial_intersect(create_circle(create_point(tweet.coordinates.coordinates[0], tweet.coordinates.coordinates[1]), .01), create_circle(s.location, 5.0))) star)};
use Starbucks;
create type SubType as open{
subscriptionId: int64,
BrokerName: string,
DataverseName: string,
param0: string
}
create type ResType as open {
id: int64
}
create dataset starsSubscriptions(SubType) primary key subscriptionId;
create dataset starsResults(ResType) primary key id;
use Starbucks;
SET inline_with "false"
insert into Starbucks.starsResults as a (
with channelExecutionTime as current_datetime()
select result, channelExecutionTime, sub.subscriptionId as subscriptionId,current_datetime() as deliveryTime
from Starbucks.starsSubscriptions sub,
Metadata.Broker b,
Starbucks.StarbucksFriends(sub.param0) result
where b.BrokerName = sub.BrokerName
and b.DataverseName = sub.DataverseName
) returning a;
{noformat}
> Type inference exception after RemoveUnusedAssignAndAggregateRule
> -----------------------------------------------------------------
>
> Key: ASTERIXDB-1978
> URL: https://issues.apache.org/jira/browse/ASTERIXDB-1978
> Project: Apache AsterixDB
> Issue Type: Bug
> Reporter: Xikui Wang
>
> The original exception is observed in the BAD extension. However, with following query running on AsterixDB, NullPointerException will be thrown during the query optimization.
> {noformat}
> drop dataverse Starbucks if exists;
> create dataverse Starbucks;
> use Starbucks;
> create type StarbucksType as {
> id: string,
> location: point
> };
> create type FollowersType as {
> user_id: string,
> twitter_id: string,
> followers: [string]
> };
> create dataset Starbucks(StarbucksType)
> primary key id
> create dataset Followers(FollowersType)
> primary key user_id
> create type TwitterUser as closed {
> id: int64,
> id_str: string,
> screen_name: string
> };
> create type Tweet as open {
> id: int64,
> user: TwitterUser,
> timestamp_ms: string
> }
> create dataset Tweets (Tweet)
> primary key id;
> use Starbucks;
> create function StarbucksFriends(userId) {
> (select distinct tweet.user.screen_name, tweet.coordinates.coordinates, tweet.timestamp_ms
> from Tweets tweet join (
> select w
> from Followers f
> unnest f.followers w
> where f.user_id = userId
> ) id on tweet.user.id_str = id.w
> where tweet.coordinates is not null and (datetime_from_unix_time_in_ms(bigint(tweet.timestamp_ms)) > current_datetime() - day_time_duration("PT24H"))
> union all
> select star.Starbucks
> from (select distinct s as Starbucks
> from Starbucks s, Tweets tweet, Followers follower
> where tweet.coordinates is not null
> and tweet.user.id_str = follower.twitter_id
> and follower.user_id = userId
> and spatial_intersect(create_circle(create_point(tweet.coordinates.coordinates[0], tweet.coordinates.coordinates[1]), .01), create_circle(s.location, 5.0))) star)};
> use Starbucks;
> create type SubType as open{
> subscriptionId: int64,
> BrokerName: string,
> DataverseName: string,
> param0: string
> }
> create type ResType as open {
> id: int64
> }
> create dataset starsSubscriptions(SubType) primary key subscriptionId;
> create dataset starsResults(ResType) primary key id;
> use Starbucks;
> SET inline_with "false"
> insert into Starbucks.starsResults as a (
> with channelExecutionTime as current_datetime()
> select result, channelExecutionTime, sub.subscriptionId as subscriptionId,current_datetime() as deliveryTime
> from Starbucks.starsSubscriptions sub,
> Metadata.Broker b,
> Starbucks.StarbucksFriends(sub.param0) result
> where b.BrokerName = sub.BrokerName
> and b.DataverseName = sub.DataverseName
> ) returning a;
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)