proofpoint / discovery Goto Github PK

2012-06-08T18:48:40.254+0000 ERROR http-worker-5770 com.proofpoint.discovery.store.PersistentStore Corrupt entry [50, 48, 57, 49, 53, 51, 48, 57, 45, 52, 48, 51, 52, 45, 52, 52, 54, 48, 45, 57, 51, 51, 53, 45, 97, 52, 51, 51, 49, 48, 99, 101, 102, 99, 98, 56]
org.codehaus.jackson.JsonParseException: Input does not start with Smile format header (first byte = 0x0) and parser has REQUIRE_HEADER enabled: can not parse
at [Source: N/A; line: -1, column: -1]
at org.codehaus.jackson.smile.SmileParserBootstrapper.constructParser(SmileParserBootstrapper.java:129) ~[jackson-smile-1.9.5.jar:1.9.5]
at org.codehaus.jackson.smile.SmileFactory._createJsonParser(SmileFactory.java:320) ~[jackson-smile-1.9.5.jar:1.9.5]
at org.codehaus.jackson.smile.SmileFactory.createJsonParser(SmileFactory.java:239) ~[jackson-smile-1.9.5.jar:1.9.5]
at org.codehaus.jackson.smile.SmileFactory.createJsonParser(SmileFactory.java:29) ~[jackson-smile-1.9.5.jar:1.9.5]
at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1935) ~[jackson-mapper-asl-1.9.5.jar:1.9.5]
at com.proofpoint.discovery.store.PersistentStore$1.apply(PersistentStore.java:74) [main.jar:1.3]
at com.proofpoint.discovery.store.PersistentStore$1.apply(PersistentStore.java:69) [main.jar:1.3]
at com.google.common.collect.Iterators$8.next(Iterators.java:812) [guava-11.0.2.jar:na]
at com.google.common.collect.Iterators$7.computeNext(Iterators.java:648) [guava-11.0.2.jar:na]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) [guava-11.0.2.jar:na]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) [guava-11.0.2.jar:na]
at com.google.common.collect.Iterators$7.computeNext(Iterators.java:647) [guava-11.0.2.jar:na]
at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) [guava-11.0.2.jar:na]
at com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) [guava-11.0.2.jar:na]
at com.proofpoint.discovery.ReplicatedStaticStore.getAll(ReplicatedStaticStore.java:56) [main.jar:1.3]
at com.proofpoint.discovery.ReplicatedStaticStore.get(ReplicatedStaticStore.java:72) [main.jar:1.3]
at com.proofpoint.discovery.ServiceResource.getServices(ServiceResource.java:35) [main.jar:1.3]
at sun.reflect.GeneratedMethodAccessor34.invoke(Unknown Source) ~[na:na]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) ~[na:1.6.0_29]
at java.lang.reflect.Method.invoke(Method.java:597) ~[na:1.6.0_29]
at com.sun.jersey.spi.container.JavaMethodInvokerFactory$1.invoke(JavaMethodInvokerFactory.java:60) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.model.method.dispatch.AbstractResourceMethodDispatchProvider$TypeOutInvoker._dispatch(AbstractResourceMethodDispatchProvider.java:185) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.model.method.dispatch.ResourceJavaMethodDispatcher.dispatch(ResourceJavaMethodDispatcher.java:75) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.uri.rules.HttpMethodRule.accept(HttpMethodRule.java:288) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(RightHandPathRule.java:147) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.uri.rules.ResourceClassRule.accept(ResourceClassRule.java:108) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(RightHandPathRule.java:147) [jersey-server-1.9.1.jar:1.9.1]
at com.sun.jersey.server.impl.uri.rules.RootResourceClassesRule.accept(RootResourceClassesRule.java:84) [jersey-server-1.9.1.ja

Factor out keyspace & column family initialization from static/dynamic cassandra stores

Provide an ability for discovery servers to consume data from an inventory service indicating which service types (and possibly pools) that particular instances are supposed to be providing.

Refuse to accept an announcement from an instance unless the service type (and possibly pool) is in the set of service types/pools assigned to the instance in inventory.

To simplify creating test environments, want to be able to configure a discovery server with a parent environment, a set of discovery servers in that parent environment, and a set of service types.

The discovery server should refuse announcements for any service types in the set.

Any discovery queries for any service types in the set should return the same answers as the discovery servers in the parent environment do.

This allows clients in the test environment to consume a configured list of services from a parent environment instead of requiring an additional deployment of those services and their dependencies in the test environment.

Right now, it's a DateTime (ms), but Hector supports arbitrary resolution.