286 Commits

Author SHA1 Message Date
Xavier Léauté
7dbafa5453 fix task id 2014-02-25 13:49:39 -08:00
Xavier Léauté
e2defe8bf1 update copyright date 2014-02-25 13:44:15 -08:00
Xavier Léauté
2f61035585 add restore task 2014-02-25 13:41:40 -08:00
fjy
5d2367f0fd unit tests pass at this point 2014-02-20 15:52:12 -08:00
fjy
20cac8c506 not compiling yet but close 2014-02-19 15:54:27 -08:00
fjy
4b7c76762d unit tests passingn at this point, finished rt port maybe 2014-02-18 15:14:38 -08:00
fjy
3979eb270c Revert "Revert "Merge branch 'determine-partitions-improvements'""
This reverts commit 189b3e2b9bc3c79da9c98b805df624f024109469.
2014-02-14 12:58:56 -08:00
fjy
a8c4362d72 rejiggering druid api 2014-02-14 12:57:52 -08:00
fjy
189b3e2b9b Revert "Merge branch 'determine-partitions-improvements'"
This reverts commit 7ad228ceb580f9ca757e91b019bd8931f710f87a, reversing
changes made to 9c55e2b7794d37cd8713bbc0465aaad23e23472d.
2014-02-14 12:47:34 -08:00
nishantmonu51
7ad228ceb5 Merge branch 'determine-partitions-improvements'
Conflicts:
	pom.xml
2014-02-12 10:51:26 +05:30
Gian Merlino
b9556e2e2e SimpleResourceManagementStrategy: Fix log/return 2014-02-07 10:02:45 -08:00
Gian Merlino
5ec634e498 SimpleResourceManagementStrategy: Scale up to minWorkerCount when increased 2014-02-06 13:20:09 -08:00
fjy
0f6af72ea4 Merge branch 'master' into new-schema 2014-02-06 12:46:13 -08:00
fjy
af48273369 fix bug with dynamic configs in coordinator not working 2014-02-06 11:19:05 -08:00
nishantmonu51
bacc72415f correct locking and partitionsSpec 2014-02-05 03:17:47 +05:30
fjy
14d0e54327 first commit 2014-02-03 14:15:03 -08:00
Gian Merlino
994c7e3fa8 RemoteTaskActionClient: Retry on ChannelExceptions too 2014-02-03 08:16:51 -08:00
fjy
019be5c3b0 update jquery 2014-01-31 12:37:37 -08:00
nishantmonu51
97e5d68635 determine intervals working with determine partitions 2014-01-31 19:04:52 +05:30
fjy
0c789412bb add a workaround for jackson bug where jacksoninject fails when a null value is passed through json creator annotated constructor 2014-01-25 07:07:27 +08:00
fjy
2ff86984da fix broken ut 2014-01-21 10:47:45 -08:00
fjy
ebc66df27d use terminateWithIds in terminate 2014-01-20 16:58:53 -08:00
fjy
1d81ad2946 remove unused class 2014-01-20 16:45:54 -08:00
fjy
1ecc9d0f98 fix the edge case where autoscaling tries to terminate node without ip 2014-01-20 16:44:19 -08:00
nishantmonu51
3fb72aff93 rename maxPendingPersistBatches to maxPendingPersists 2014-01-17 12:59:21 +05:30
nishantmonu51
fb819abd6f make maxPendingPersistPeriod configurable 2014-01-17 11:01:55 +05:30
Gian Merlino
1331f2ce56 TaskStorage.add() now throws TaskExistsException, and the servlet respects it
The servlet will throw 400 rather than 500 when a task already exists, to
signify that the request has no hope of ever working.
2014-01-13 15:42:05 -08:00
Gian Merlino
a72c4429f7 RemoteTaskRunner: Fix NPE on cleanup due to missing withWorker 2014-01-13 15:41:04 -08:00
fjy
f3476f40e1 fix typo 2014-01-10 18:08:33 -08:00
fjy
f4e3f02c3b more exceptions 2014-01-10 18:06:42 -08:00
fjy
1ecc94cfb6 another attempt at index task 2014-01-10 17:56:22 -08:00
fjy
f0b4d0c1e4 fix small bug with unusable dims 2014-01-10 14:59:09 -08:00
fjy
fe50104053 fix the index task and more docs 2014-01-10 14:47:18 -08:00
nishantmonu51
da01c4a78a Add registration for backward compatibility 2014-01-10 02:02:06 +05:30
nishantmonu51
d28f9daccb Remove duplicate registration of service
If the serviceName does not contain ":" this leads to duplicate
registration of firehose with same name
2014-01-10 01:17:41 +05:30
Gian Merlino
9037141c00 IndexTask: Better logging at the end of each segment 2014-01-08 15:22:12 -08:00
Gian Merlino
2c53af4d66 ForkingTaskRunner: Upload task logs even when job fails 2014-01-08 14:46:18 -08:00
Gian Merlino
7f430d9fde RealtimeIndexTask: If a Throwable was thrown it is not a normalExit 2014-01-08 14:45:35 -08:00
Gian Merlino
83b4641e31 ForkingTaskRunnerConfig: Add java.io.tmpdir to allowedPrefixes 2014-01-07 16:12:24 -08:00
Gian Merlino
bf158102c4 IndexTask: Print metrics even if finishJob fails 2014-01-07 07:17:19 -08:00
Gian Merlino
26991b5a2a Indexing service: Fix termination related log message 2013-12-20 12:05:42 -08:00
Gian Merlino
4d83837e88 RealtimeIndexTask: Clean up imports and comments 2013-12-20 11:37:16 -08:00
Gian Merlino
17ad4ee2f0 Fix RemoteTaskRunnerTest 2013-12-20 11:23:28 -08:00
Gian Merlino
e5b8546d19 Autoscaling fixes.
- Initial targetWorkerCount must be subject to pool size limits
- Use consistent workerSetupData for the entire autoscaling run
- Don't call terminate() when we have nothing to terminate
- Terminate obsolete workers even faster
2013-12-20 11:17:01 -08:00
fjy
3ec2766cd3 Merge pull request #339 from metamx/autoscaling
Autoscaling: Move target count independent of actual count.
2013-12-20 10:04:26 -08:00
Gian Merlino
6224577ed1 Autoscaling: Terminate obsolete workers faster 2013-12-20 10:01:32 -08:00
Gian Merlino
4a722c0a6d Autoscaling changes from code review.
- Log and return immediately when workerSetupData is null
- Allow provisioning more nodes while other nodes are still provisioning
- Add tests for bumping up the minimum version
2013-12-20 08:59:35 -08:00
Gian Merlino
0ee6136ea3 NoopTask: Fix things that should be static. Add simple factory method. 2013-12-20 08:56:17 -08:00
Gian Merlino
3dd9a25546 Fix import 2013-12-19 16:18:16 -08:00
Gian Merlino
0ff7f0e8e0 TaskActionToolbox: Combine adjacent ifs 2013-12-19 16:16:34 -08:00