We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[ec2-user@ip-172-31-36-248 generator]$ go run main.go -f ./benchmarks/small/timeplus_latency.yaml failed to parse log level: not a valid logrus Level: "" logger initialization with level 4 INFO[0000]/home/ec2-user/chameleon/generator/plugins/console/sink.go:19 github.com/timeplus-io/chameleon/generator/plugins/console.init.0() sink plugin console has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/kafka/init.go:15 github.com/timeplus-io/chameleon/generator/plugins/kafka.init.0() sink plugin kafka has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/kafka/init.go:22 github.com/timeplus-io/chameleon/generator/plugins/kafka.init.0() observer plugin kafka has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/ksql/init.go:15 github.com/timeplus-io/chameleon/generator/plugins/ksql.init.0() sink plugin ksql has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/ksql/init.go:22 github.com/timeplus-io/chameleon/generator/plugins/ksql.init.0() observer plugin ksql has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/materialize/init.go:15 github.com/timeplus-io/chameleon/generator/plugins/materialize.init.0() sink plugin materialize has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/materialize/init.go:22 github.com/timeplus-io/chameleon/generator/plugins/materialize.init.0() observer plugin materialize has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/rocketmq/init.go:15 github.com/timeplus-io/chameleon/generator/plugins/rocketmq.init.0() sink plugin rocketmq has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/rocketmq/init.go:22 github.com/timeplus-io/chameleon/generator/plugins/rocketmq.init.0() observer plugin rocketmq has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/splunk/init.go:15 github.com/timeplus-io/chameleon/generator/plugins/splunk.init.0() sink plugin splunk has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/splunk/init.go:22 github.com/timeplus-io/chameleon/generator/plugins/splunk.init.0() observer plugin splunk has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/timeplus/init.go:15 github.com/timeplus-io/chameleon/generator/plugins/timeplus.init.0() sink plugin timeplus has been registered INFO[0000]/home/ec2-user/chameleon/generator/plugins/timeplus/init.go:22 github.com/timeplus-io/chameleon/generator/plugins/timeplus.init.0() observer plugin timeplus has been registered INFO[0000]/home/ec2-user/chameleon/generator/server/main.go:90 github.com/timeplus-io/chameleon/generator/server.Run() run test case from file ./benchmarks/small/timeplus_latency.yaml INFO[0000]/home/ec2-user/chameleon/generator/job/job.go:92 github.com/timeplus-io/chameleon/generator/job.NewJobFromFile() using configuration : &{test {300 10 100 0 0 [{ordertime timestamp [] [] 0 0 } {orderid generate [] [] 0 0 O{number:1,1000}} {itemid generate [] [] 0 0 I{number:1,1000}} {orderunits float [] [0 10] 0 0 } {city generate [] [] 0 0 {city}} {state generate [] [] 0 0 {state}} {zipcode generate [] [] 0 0 {zip}} {time timestamp_int [] [] 2006-01-02 15:04:05.000000 0 0 } {timestamp timestamp_int [] [] 0 0 } {value int [] [0 1000] 0 0 }] false} [{timeplus map[address:http://localhost:8000 apikey:OgTcKISs6PCK0isAKXMYlNRpI6RgCBvcQWcJbXapNzqMSO4WjoHU1DKbSZl-]}] {timeplus map[address:http://localhost:8000 apikey:OgTcKISs6PCK0isAKXMYlNRpI6RgCBvcQWcJbXapNzqMSO4WjoHU1DKbSZl- metric:latency query:select * from test where value=9 time_column:time time_format:2006-01-02T15:04:05.000-07:00]} 180} INFO[0001]/home/ec2-user/chameleon/generator/server/main.go:94 github.com/timeplus-io/chameleon/generator/server.Run() start job INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:153 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start observer INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 0 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 7 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 4 INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:275 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).Observe() TimeplusObserver start observing INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 3 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 6 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 2 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 1 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:160 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() get 10 stream from source INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:115 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency() start observing latecny INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 8 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 0 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 9 INFO[0001]/home/ec2-user/chameleon/generator/source/generator.go:145 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() start generate routine with index 5 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 1 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 2 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 3 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 4 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 5 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 6 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 7 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 8 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:168 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() start stream 9 INFO[0001]/home/ec2-user/chameleon/generator/job/job.go:198 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() wait for timeout 180 time index is 7 event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.668994206329e+12 1.668994206226e+12 9 2022-11-21T01:30:06.332Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -11.919169ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.668994206431e+12 1.668994206226e+12 9 2022-11-21T01:30:06.433Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -10.06936ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.668994206431e+12 1.668994206226e+12 9 2022-11-21T01:30:06.433Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -10.134098ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.66899420643e+12 1.668994206226e+12 9 2022-11-21T01:30:06.433Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -11.164825ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.66899420643e+12 1.668994206226e+12 9 2022-11-21T01:30:06.433Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -11.194306ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.66899420643e+12 1.668994206226e+12 9 2022-11-21T01:30:06.433Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -11.219389ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.668994206633e+12 1.668994206226e+12 9 2022-11-21T01:30:06.637Z 1970-01-01T00:00:00Z] INFO[0001]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -8.1379ms event is [2022-11-21T01:30:06.226Z O43 I258 7.8495617 Baton Rouge North Dakota 37391 1.668994206635e+12 1.668994206226e+12 9 2022-11-21T01:30:06.637Z 1970-01-01T00:00:00Z] ... INFO[0181]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:145 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency.func1() observe latency -13.697919ms INFO[0181]/home/ec2-user/chameleon/generator/job/job.go:202 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() timeout and exit data generating INFO[0181]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:290 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).Stop() call timeplus stop observing INFO[0181]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:292 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).Stop() set stopped INFO[0181]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:157 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).observeLatency() stop observing latecny INFO[0181]/home/ec2-user/chameleon/generator/plugins/timeplus/observer.go:295 github.com/timeplus-io/chameleon/generator/plugins/timeplus.(*TimeplusObserver).Stop() stop observing INFO[0181]/home/ec2-user/chameleon/generator/job/job.go:207 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() timeout INFO[0181]/home/ec2-user/chameleon/generator/job/job.go:211 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() wait observer finish INFO[0181]/home/ec2-user/chameleon/generator/job/job.go:213 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() observer finished INFO[0181]/home/ec2-user/chameleon/generator/job/job.go:216 github.com/timeplus-io/chameleon/generator/job.(*Job).Start() job finished WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 0 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 6 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 1 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 5 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 4 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 3 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 2 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 8 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 7 WARN[0181]/home/ec2-user/chameleon/generator/source/generator.go:149 github.com/timeplus-io/chameleon/generator/source.(*GeneratorEngine).run() run generator finished 9 [ec2-user@ip-172-31-36-248 generator]$ [ec2-user@ip-172-31-36-248 generator]$ ls -lah total 176K drwxrwxr-x 20 ec2-user ec2-user 4.0K Nov 16 07:38 . drwxrwxr-x 7 ec2-user ec2-user 176 Nov 14 07:41 .. -rw-rw-r-- 1 ec2-user ec2-user 34 Nov 14 07:41 .gitignore -rw-rw-r-- 1 ec2-user ec2-user 320 Nov 14 07:41 Dockerfile -rw-rw-r-- 1 ec2-user ec2-user 1.3K Nov 14 07:41 Makefile -rw-rw-r-- 1 ec2-user ec2-user 5.1K Nov 14 07:41 README.md -rw-rw-r-- 1 ec2-user ec2-user 43K Nov 14 07:41 architecture.png drwxrwxr-x 5 ec2-user ec2-user 46 Nov 14 07:41 benchmarks drwxrwxr-x 2 ec2-user ec2-user 21 Nov 14 07:41 cmd drwxrwxr-x 2 ec2-user ec2-user 38 Nov 14 07:41 common drwxrwxr-x 2 ec2-user ec2-user 23 Nov 14 07:41 config -rw-rw-r-- 1 ec2-user ec2-user 497 Nov 14 07:41 config.txt drwxrwxr-x 8 ec2-user ec2-user 96 Nov 14 07:41 deployment drwxrwxr-x 2 ec2-user ec2-user 61 Nov 14 07:41 docs -rw-rw-r-- 1 ec2-user ec2-user 4.4K Nov 16 03:09 go.mod -rw-rw-r-- 1 ec2-user ec2-user 92K Nov 16 03:09 go.sum drwxrwxr-x 2 ec2-user ec2-user 37 Nov 14 07:41 handlers drwxrwxr-x 2 ec2-user ec2-user 38 Nov 14 07:41 job drwxrwxr-x 2 ec2-user ec2-user 39 Nov 16 03:09 log -rw-rw-r-- 1 ec2-user ec2-user 102 Nov 14 07:41 main.go drwxrwxr-x 2 ec2-user ec2-user 60 Nov 16 03:09 metrics drwxrwxr-x 2 ec2-user ec2-user 45 Nov 14 07:41 observer drwxrwxr-x 9 ec2-user ec2-user 111 Nov 14 07:41 plugins drwxrwxr-x 4 ec2-user ec2-user 30 Nov 14 07:41 samples drwxrwxr-x 2 ec2-user ec2-user 21 Nov 14 07:41 server drwxrwxr-x 2 ec2-user ec2-user 45 Nov 14 07:41 sink drwxrwxr-x 2 ec2-user ec2-user 46 Nov 14 07:41 source drwxrwxr-x 2 ec2-user ec2-user 166 Nov 14 07:41 test drwxrwxr-x 2 ec2-user ec2-user 37 Nov 14 07:41 utils [ec2-user@ip-172-31-36-248 generator]$
No any report created.
The text was updated successfully, but these errors were encountered:
gangtao
No branches or pull requests
No any report created.
The text was updated successfully, but these errors were encountered: