fjy
dc169d9fcd
hide decrement and update close logic to call decrement
2013-08-01 13:24:56 -07:00
fjy
e92e0c35a4
put all concurrency test back into server manager test, introduce better concurrency for reference counting
2013-08-01 13:13:03 -07:00
fjy
b86258cc14
fix broken master UT based on changes that were discarded as part of a pull req
2013-08-01 10:44:39 -07:00
fjy
2f8351b314
fix broken ut
2013-08-01 09:41:36 -07:00
Jan Rudert
73d5ff4b94
Merge branch 'master' of github.com:metamx/druid into HEAD
2013-08-01 18:00:29 +02:00
Jan Rudert
de61937167
reverted accident change
2013-08-01 17:58:32 +02:00
Jan Rudert
31c048ccb6
use hadoop cdh4-4.1.1 and protobuf 2.4.0
2013-08-01 17:27:33 +02:00
fjy
a4edc2221d
fix RTR comments
2013-07-31 15:28:52 -07:00
fjy
215d147a69
Merge branch 'worker-resource' of github.com:metamx/druid into worker-resource
2013-07-31 15:23:49 -07:00
fjy
e2b5cd6067
Merge branch 'master' of github.com:metamx/druid into worker-resource
...
Conflicts:
indexing-service/src/main/java/com/metamx/druid/indexing/worker/executor/ExecutorNode.java
2013-07-31 15:23:13 -07:00
fjy
f76540c16c
move reference counting classes out of server manager and more tests for concurrency
2013-07-31 15:14:39 -07:00
Dhruv Parthasarathy
cf3e6da799
fixed git ignore
2013-07-31 11:44:37 -07:00
Dhruv Parthasarathy
dd689ca828
changed urls
2013-07-31 11:43:24 -07:00
fjy
5d1fe50703
additional ut for reference counting
2013-07-30 17:55:57 -07:00
fjy
404b84823e
reference count to make sure we arent accessing any instances of a closed mmapped segment
2013-07-30 17:36:56 -07:00
Gian Merlino
eaddce06d5
Call TaskRunner.bootstrap immediately after starting it
2013-07-30 15:26:11 -07:00
cheddar
843b6650a2
Merge pull request #206 from metamx/peontimeout
...
Add a timeout in LoadQueuePeon to fail an assign if it takes too long
2013-07-30 15:08:46 -07:00
fjy
e7c6dd8112
get and reset failed assign count
2013-07-30 14:50:24 -07:00
fjy
35d8a82879
move the close method to the segment object
2013-07-30 12:24:01 -07:00
cheddar
1c5c2e0ef5
Merge pull request #205 from metamx/compress-curator
...
Toggle between compressed and non compressed service discovery
2013-07-30 11:33:43 -07:00
cheddar
66adef5d64
Merge pull request #179 from zanox/master
...
Fix path used when storing segments to HDFS
2013-07-30 11:13:29 -07:00
fjy
f55e12040f
fix according to code review
2013-07-29 18:39:14 -07:00
Dhruv Parthasarathy
b8940b4524
added support for dynamicConfigs for Master
2013-07-29 18:16:57 -07:00
Dhruv Parthasarathy
4e4d582e07
formatted files
2013-07-29 18:10:08 -07:00
Dhruv Parthasarathy
ac0f0afdbf
turned Iterable to ArrayList, fixed potential null pointer in reservoir sampling
2013-07-29 18:07:49 -07:00
fjy
6a96c1fb76
fix according to code review comments
2013-07-29 17:56:19 -07:00
Dhruv Parthasarathy
b0d9889c83
added web console for changing dynamicConfigs
2013-07-29 17:49:09 -07:00
fjy
af6db21264
fix configs based on code review
2013-07-29 17:04:27 -07:00
fjy
091dce11c8
Add a timeout in LQP to fail an assign if it takes too long
2013-07-29 15:47:05 -07:00
fjy
50836798fa
toggle between compressed and non compressed service discovery
2013-07-29 15:40:45 -07:00
fjy
1226190279
add the ability to close mmapped files
2013-07-29 15:22:34 -07:00
fjy
ad65c8111d
fix logs
2013-07-29 11:41:42 -07:00
Dhruv Parthasarathy
31ffed466c
first set of changes
2013-07-29 11:39:24 -07:00
Jan Rudert
bba83ec532
introduced a ByteBufferInputRowParser to keep the old StringInputRowParser in places outside the KafkaFireHose
2013-07-29 11:59:08 +02:00
fjy
4ae8395538
1) on bootstrap, load all initial data and do a compare with bootstrapped tasks, delete any that are extra out there
...
2) change autoscaling logic such that it only works with remote task runnrs
3) zk workers use their own status caches to determine what they are running
2013-07-26 14:32:08 -07:00
Dhruv Parthasarathy
ba4a9c28a7
removed unecessary line
2013-07-26 10:52:50 -07:00
Dhruv Parthasarathy
1e4f64b119
redid testing
2013-07-26 10:50:06 -07:00
fjy
a1262760b2
Merge branch 'master' into worker-resource
2013-07-26 10:02:15 -07:00
fjy
b0090a1de6
[maven-release-plugin] prepare for next development iteration
2013-07-25 17:26:44 -07:00
fjy
6868153905
[maven-release-plugin] prepare release druid-0.5.22
2013-07-25 17:26:36 -07:00
cheddar
a6bc63732d
Merge pull request #199 from metamx/indexing-service-mods
...
Improve robustness and usability of RealtimeIndexTask and some code cleanup in the Indexing Service
2013-07-25 17:09:15 -07:00
fjy
cf0cb3b703
[maven-release-plugin] prepare for next development iteration
2013-07-25 16:55:28 -07:00
fjy
8297f068c3
[maven-release-plugin] prepare release druid-0.5.21
2013-07-25 16:55:20 -07:00
Dhruv Parthasarathy
05219689e8
added close methods on inputSupplier tests
2013-07-25 16:52:29 -07:00
fjy
f68a68112f
[maven-release-plugin] prepare for next development iteration
2013-07-25 16:21:59 -07:00
fjy
b6e8d11aec
[maven-release-plugin] prepare release druid-0.5.20
2013-07-25 16:21:49 -07:00
fjy
217894d44a
Merge branch 'master' into worker-resource
...
Conflicts:
pom.xml
2013-07-25 16:18:42 -07:00
Gian Merlino
4dd42c7177
RemoteTaskActionClient: Log service uri when submitting action
2013-07-25 14:48:25 -07:00
Gian Merlino
20acd6f450
RealtimePlumberSchool: Persist and merge immediately upon finishJob
2013-07-25 14:38:07 -07:00
Gian Merlino
5d44f0f15b
ForkingTaskRunner: Use guava Closer to closer stuff
2013-07-25 14:37:45 -07:00