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

ASF GitHub Bot commented on METRON-937:
---------------------------------------

Github user nickwallen commented on the issue:

    https://github.com/apache/incubator-metron/pull/570
  
    travis!
    
    ```
    -------------------------------------------------------
     T E S T S
    -------------------------------------------------------
    Running org.apache.metron.pcap.integration.PcapTopologyIntegrationTest
    Formatting using clusterid: testClusterID
    Processing: ip_dst_addr => 207.28.210.1
    Processing: protocol => foo
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Processing: ip_dst_port => 22
    Ended
    2017-05-09 14:39:20 ERROR ReadClusterState:345 - Error trying to shutdown 
workers in Thread[SLOT_1027,5,main]
    java.lang.IllegalStateException: It took over 60000ms to shut down slot 
Thread[SLOT_1027,5,main]
        at 
org.apache.storm.daemon.supervisor.ReadClusterState$1.call(ReadClusterState.java:294)
        at 
org.apache.storm.daemon.supervisor.ReadClusterState$1.call(ReadClusterState.java:292)
        at 
org.apache.storm.daemon.supervisor.ReadClusterState$3.call(ReadClusterState.java:307)
        at 
org.apache.storm.daemon.supervisor.ReadClusterState$3.call(ReadClusterState.java:304)
        at 
org.apache.storm.daemon.supervisor.ReadClusterState.shutdownAllWorkers(ReadClusterState.java:333)
        at 
org.apache.storm.daemon.supervisor.Supervisor.shutdownAllWorkers(Supervisor.java:330)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:483)
        at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
        at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
        at 
org.apache.storm.testing$kill_local_storm_cluster.invoke(testing.clj:204)
        at org.apache.storm.LocalCluster$_shutdown.invoke(LocalCluster.clj:66)
        at org.apache.storm.LocalCluster.shutdown(Unknown Source)
        at 
org.apache.metron.integration.components.FluxTopologyComponent.stop(FluxTopologyComponent.java:159)
    ```


> Pycapa - Consume Messages from Begin, End, or Stored Offsets
> ------------------------------------------------------------
>
>                 Key: METRON-937
>                 URL: https://issues.apache.org/jira/browse/METRON-937
>             Project: Metron
>          Issue Type: Improvement
>            Reporter: Nick Allen
>            Assignee: Nick Allen
>
> Enable Pycapa to consume packets from either the beginning, ending or stored 
> offsets for a topic.



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

Reply via email to