[jira] [Created] (ASTERIXDB-2126) Data won't feed into socket feed with a dataset filter

[Steven Jacobs (JIRA)]

Steven Jacobs created ASTERIXDB-2126:
----------------------------------------

             Summary: Data won't feed into socket feed with a dataset filter
                 Key: ASTERIXDB-2126
                 URL: https://issues.apache.org/jira/browse/ASTERIXDB-2126
             Project: Apache AsterixDB
          Issue Type: Bug
            Reporter: Steven Jacobs
            Assignee: Xikui Wang


The following DDL creates a feed successfully, but throws errors when data is 
attempted to be fed. Everything works correctly if the filter isn't create on 
the dataset.

drop dataverse channels if exists;
create dataverse channels;
use dataverse channels;

create type UserLocation as closed {
        recordId: integer,
        location: circle,
        userName: string,
        timeStamp: datetime
};
create dataset UserLocations(UserLocation)
primary key recordId with filter on timeStamp;
create feed LocationFeed using socket_adapter
(
    ("sockets"="127.0.0.1:10009"),
    ("address-type"="IP"),
    ("type-name"="UserLocation"),
    ("upsert-feed"="true"),
    ("format"="adm")
);
connect feed LocationFeed to dataset UserLocations;
start feed LocationFeed;

Here is the error in the logs:
java.lang.IllegalStateException: java.lang.IllegalStateException: resource 
(101,  956599034) not found
        at 
org.apache.asterix.transaction.management.service.logging.LogBuffer.internalFlush(LogBuffer.java:221)
        at 
org.apache.asterix.transaction.management.service.logging.LogBuffer.flush(LogBuffer.java:193)
        at 
org.apache.asterix.transaction.management.service.logging.LogFlusher.call(LogManager.java:704)
        at 
org.apache.asterix.transaction.management.service.logging.LogFlusher.call(LogManager.java:1)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        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: java.lang.IllegalStateException: resource (101,  956599034) not found
        at 
org.apache.asterix.transaction.management.service.locking.ConcurrentLockManager.unlock(ConcurrentLockManager.java:486)
        at 
org.apache.asterix.transaction.management.service.locking.ConcurrentLockManager.unlock(ConcurrentLockManager.java:473)
        at 
org.apache.asterix.transaction.management.service.logging.LogBuffer.batchUnlock(LogBuffer.java:242)
        at 
org.apache.asterix.transaction.management.service.logging.LogBuffer.internalFlush(LogBuffer.java:218)
        ... 7 more



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)