Comments (15)
Hello,
Sorry to hear you are having this problem. This date convention was scrapped in a really old version of the aggregators package, so I'm concerned that someone you've got an out of date repo. Can you confirm that the jar you are using is .9.2.6.9?
Thx,
Ian
from amazon-kinesis-aggregators.
Actually I am using the command line arguments that are on the main page on github, which actually invoke the AmazonKinesisAggregators.jar-complete.jar JAR and not the amazon-kinesis-aggregators-.9.2.6.9.jar. However, I can confirm that when I cloned the repo, I DO have the 9.2.6.9 JAR...
This is my command I am running:
java -cp AmazonKinesisAggregators.jar-complete.jar -Dconfig-file-path=json-aggregator.json -Dstream-name=TestStream -Dapplication-name=MyApp -Dregion=ap-southeast-2 com.amazonaws.services.kinesis.aggregators.consumer.AggregatorConsumer
from amazon-kinesis-aggregators.
OK - Can you paste an example of the input event?
from amazon-kinesis-aggregators.
are you talking about the input even from the "producer" application (i.e. the payload send to Kinesis) or the record in the DynamoDB table?
If you want to replicate this bug, just run the command with what I pasted earlier, the run the KCL producers sample console app, and put some messages into Kinesis.
from amazon-kinesis-aggregators.
Hi,
Yeah can repro now - couldnt before. Will have a fix to you shortly.
Ian
from amazon-kinesis-aggregators.
Woot, thanks Ian!!
from amazon-kinesis-aggregators.
Fixed in .9.2.7 - now available in the dist folder.
from amazon-kinesis-aggregators.
Also fixed an issue whereby the DevNullDataStore was not used. Now you should NOT get a DynamoDB table created with the configuration you've cited above.
from amazon-kinesis-aggregators.
Thanks Ian, I will be re-trying this very soon
from amazon-kinesis-aggregators.
Hi Ian, doesnt look like this worked... sorry, I pulled the latest and got the new distro's but now I get an error:
Sep 17, 2015 11:05:14 PM com.amazonaws.services.kinesis.aggregators.metrics.CloudWatchMetricsEmitter emit
SEVERE: Unable to Parse Date Value -
The command I am running is this:
java -cp AmazonKinesisAggregators.jar-complete.jar -Dconfig-file-path=json-aggregator.json -Dstream-name=MyStreamName -Dapplication-name=MyApp -Dregion=ap-southeast-2 com.amazonaws.services.kinesis.aggregators.consumer.AggregatorConsumer
It also doesnt look like its creating the tableName that I specified in the config
There is a table called MyApp (from the parameters above), and it has 2 rows, one for each shard in Kinesis (i assume).
Here is a bigger dump of the log when I add events to the Kinesis stream:
INFO: Aggregating 13 records for Kinesis Shard shardId-000000000001
Sep 17, 2015 11:11:54 PM com.amazonaws.services.kinesis.aggregators.StreamAggregator logInfo
INFO: [shardId-000000000001] Aggregation Complete - 13 Records and 13 Elements in 15 ms
Sep 17, 2015 11:11:54 PM com.amazonaws.services.kinesis.aggregators.cache.AggregateCache logInfo
INFO: [shardId-000000000001] Cache Flushed 3 modifications in 0ms
Sep 17, 2015 11:11:54 PM com.amazonaws.services.kinesis.aggregators.metrics.CloudWatchMetricsEmitter emit
SEVERE: Unable to Parse Date Value -
from amazon-kinesis-aggregators.
Ah yes I see - the FOREVER metric was not formatted properly. This should be fixed in .9.2.7.1.
As for the table, you will have a table called MyApp, which is created by the KCL for lease tracking, but when you use the DevNullDataStore you will not have any other tables in DynamoDB.
from amazon-kinesis-aggregators.
OK we have some progress :)
Looks like there is a new cloud watch metric called TestTable, which is good, but it says that the Calculation is SUM when I specified COUNT in the config file?
from amazon-kinesis-aggregators.
Hi,
Yes, that's correct. We have to SUM the eventCount, as this is the only way to add up all the eventCount entries for a period of time in CloudWatch.
Does that make sense?
Ian
from amazon-kinesis-aggregators.
Yeah, it makes sense, I just need to make sure I setup my reporting correctly with the config file to capture the volumes of traffic/events that I want to test under heavy load.
from amazon-kinesis-aggregators.
Closing now
from amazon-kinesis-aggregators.
Related Issues (11)
- Examples on S3 giving "access denied" HOT 1
- Dynamo tables created in wrong region. HOT 8
- Config file support for region HOT 1
- Publish to maven repository HOT 2
- process base64 encoded object from kinesis HOT 9
- DefaultIdempotencyCheck doesn't actually do anything HOT 2
- NoSuchMethodError: com.amazonaws.transform.JsonUnmarshallerContext.getCurrentToken() HOT 8
- FOREVER timeHorizon seems to set dateValue to * and issues this error... HOT 6
- Feature / Request for comment HOT 1
- Feature Request - Support for processing Dynamo DB Update Streams
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from amazon-kinesis-aggregators.