Eric Tschetter
0b621c7bde
1) Expand logging of unregistering real-time segments to help diagnose strange zookeeper behavior
2013-04-06 11:10:36 -05:00
Fangjin Yang
8b100248a8
[maven-release-plugin] prepare for next development iteration
2013-04-01 17:17:50 -07:00
Fangjin Yang
bbb3991bc9
[maven-release-plugin] prepare release druid-0.3.33
2013-04-01 17:17:44 -07:00
Fangjin Yang
e8c6936aca
[maven-release-plugin] prepare for next development iteration
2013-04-01 14:28:43 -07:00
Fangjin Yang
1f342dc0f2
[maven-release-plugin] prepare release druid-0.3.32
2013-04-01 14:28:36 -07:00
Fangjin Yang
30465b5c26
[maven-release-plugin] prepare for next development iteration
2013-03-28 19:48:46 -07:00
Fangjin Yang
1515dddfe0
[maven-release-plugin] prepare release druid-0.3.31
2013-03-28 19:48:39 -07:00
Fangjin Yang
04a46fb74f
[maven-release-plugin] prepare for next development iteration
2013-03-28 19:21:14 -07:00
Fangjin Yang
36601ee3aa
[maven-release-plugin] prepare release druid-0.3.30
2013-03-28 19:21:07 -07:00
Fangjin Yang
9e54e11827
[maven-release-plugin] prepare for next development iteration
2013-03-27 11:55:48 -07:00
Fangjin Yang
8fee044c68
[maven-release-plugin] prepare release druid-0.3.29
2013-03-27 11:55:38 -07:00
Fangjin Yang
537f527960
Merge branch 'master' into stop_task
...
Conflicts:
merger/src/test/java/com/metamx/druid/merger/coordinator/RemoteTaskRunnerTest.java
2013-03-26 14:14:23 -07:00
Fangjin Yang
e785b87be0
[maven-release-plugin] prepare for next development iteration
2013-03-26 11:10:15 -07:00
Fangjin Yang
a97287fa50
[maven-release-plugin] prepare release druid-0.3.28
2013-03-26 11:10:04 -07:00
Fangjin Yang
f38566de7a
Merge branch 'master' of github.com:metamx/druid
2013-03-26 10:26:12 -07:00
Fangjin Yang
a7d836a0dd
fix NPE for master balancing; introduce max number of workers for indexing service
2013-03-26 10:25:52 -07:00
Eric Tschetter
42ca6aff4f
Merge branch 'master' of github.com:metamx/druid
2013-03-26 09:07:28 -05:00
Eric Tschetter
2306602e93
1) Remove zookeeper 3.4.3 dependency from merger
2013-03-26 09:06:11 -05:00
Fangjin Yang
f0f4eee787
Merge branch 'master' into stop_task
2013-03-25 13:31:03 -07:00
Fangjin Yang
efd57dcf38
[maven-release-plugin] prepare for next development iteration
2013-03-25 13:17:50 -07:00
Fangjin Yang
3d7a0ea2d3
[maven-release-plugin] prepare release druid-0.3.27
2013-03-25 13:17:43 -07:00
Gian Merlino
dcd10e69c7
WorkerTaskMonitor: Fix isTaskRunning check
2013-03-24 18:19:32 -07:00
Fangjin Yang
e4c8122f9c
Merge branch 'master' of github.com:metamx/druid into stop_task
2013-03-22 12:53:51 -07:00
Eric Tschetter
35cfd1f186
[maven-release-plugin] prepare for next development iteration
2013-03-21 13:14:20 -05:00
Eric Tschetter
3860710f11
[maven-release-plugin] prepare release druid-0.3.26
2013-03-21 13:14:14 -05:00
Fangjin Yang
a1dcdab54d
clean up shutdown
2013-03-20 10:51:16 -07:00
Gian Merlino
dc615ab795
RealtimePlumberSchool: Faster graceful shutdown
2013-03-19 18:29:00 -07:00
Gian Merlino
017278a5d5
IndexerCoordinatorResource: Un-break null returns
2013-03-19 18:18:33 -07:00
Gian Merlino
dfe91d3bf9
RealtimeIndexTask: Close firehose after finishing plumbing job
2013-03-19 18:02:23 -07:00
Gian Merlino
ed56bc52e9
RealtimeIndexTask: Better handle early shutdowns
2013-03-19 17:56:28 -07:00
Gian Merlino
76f4d12059
ForkingTaskRunner: Totally ridiculous graceful shutdown mechanism
2013-03-19 17:56:22 -07:00
Gian Merlino
6324225a4f
ExecutorMain: Shut down when our parent disappears
2013-03-19 16:32:01 -07:00
Gian Merlino
243e70a3c0
TaskConsumer: Less complainy when interrupted
2013-03-19 16:31:37 -07:00
Fangjin Yang
e5f46f2a66
fix more startup problems
2013-03-19 12:45:35 -07:00
Fangjin Yang
69a0e0e1a7
fix nodes not able to start
2013-03-19 12:35:02 -07:00
Fangjin Yang
d53822130b
Merge branch 'forking-task-runner' into stop_task
...
Conflicts:
merger/src/main/java/com/metamx/druid/merger/common/task/AbstractTask.java
merger/src/main/java/com/metamx/druid/merger/common/task/Task.java
merger/src/main/java/com/metamx/druid/merger/coordinator/http/IndexerCoordinatorResource.java
2013-03-19 12:23:20 -07:00
Fangjin Yang
30fdb2956d
intiial commit for stop task
2013-03-19 11:30:33 -07:00
Gian Merlino
ec566ee37a
Ability to run tasks in separate JVMs, and cancel tasks.
...
- ForkingTaskRunner spawns new JVMs for each task
- Added ExecutorMain, ExecutorNode to be the spawned JVM
- LocalTaskRunner renamed ExecutorServiceTaskRunner
- Add shutdown method to Task and TaskRunner
2013-03-19 11:01:03 -07:00
Gian Merlino
d1eb61d451
TaskAction:
...
- Add isAudited
- Generally straighten out Jackson annotations
2013-03-19 11:00:39 -07:00
Gian Merlino
922ed66a91
Task: Fix comments in preamble
2013-03-19 11:00:39 -07:00
Gian Merlino
b5e7bff927
TaskMasterLifecycle: Less noisy exit when interrupted
2013-03-19 11:00:38 -07:00
Gian Merlino
5f513be363
Merger: Replace TaskCallback with ListenableFuture<TaskStatus>
2013-03-19 11:00:38 -07:00
Gian Merlino
5c3db75a01
IndexGeneratorTask: Fix serialization
2013-03-19 11:00:38 -07:00
Gian Merlino
d163f07ae0
Task: preflight takes TaskActionClient instead of TaskToolbox
2013-03-19 11:00:36 -07:00
Eric Tschetter
f47319f118
[maven-release-plugin] prepare for next development iteration
2013-03-18 17:09:01 -05:00
Eric Tschetter
1066144b43
[maven-release-plugin] prepare release druid-0.3.25
2013-03-18 17:08:56 -05:00
Eric Tschetter
cba404a65d
[maven-release-plugin] prepare for next development iteration
2013-03-18 13:02:40 -05:00
Eric Tschetter
29a0a7e6c6
[maven-release-plugin] prepare release druid-0.3.24
2013-03-18 13:02:33 -05:00
Eric Tschetter
bbed862b0b
Merge branch 'master' of github.com:metamx/druid
2013-03-18 12:59:33 -05:00
Eric Tschetter
e3674368ab
1) Fix bug with the MergeTask not setting the binaryVersion field on DataSegments and causing the converter to run a lot.
2013-03-18 12:57:01 -05:00
Fangjin Yang
b9de751b32
[maven-release-plugin] prepare for next development iteration
2013-03-15 14:32:31 -07:00
Fangjin Yang
57655f19c4
[maven-release-plugin] prepare release druid-0.3.23
2013-03-15 14:32:24 -07:00
Eric Tschetter
72b82b1b1d
1) Remove logline that really shouldn't be there.
2013-03-15 15:50:37 -05:00
Eric Tschetter
7dacf952d6
[maven-release-plugin] prepare for next development iteration
2013-03-15 13:53:39 -05:00
Eric Tschetter
ff017fe72a
[maven-release-plugin] prepare release druid-0.3.22
2013-03-15 13:53:33 -05:00
Eric Tschetter
a933438e4e
1) Fix bugs with VersionConverterTask
...
2) Fix bugs with NPEs on indexing
2013-03-15 13:48:55 -05:00
Gian Merlino
f6752799bc
Merge branch 'master' into realtime-index-task
...
Conflicts:
merger/src/main/java/com/metamx/druid/merger/common/actions/SegmentInsertAction.java
2013-03-14 13:45:59 -07:00
Gian Merlino
e45a51714f
RealtimeIndexTask: Fix serde
2013-03-14 13:43:40 -07:00
Gian Merlino
b8c08f235a
Realtime:
...
- Move VersioningPolicy, RetryPolicy outside of RealtimePlumberSchool
- Move plumber stuff into its own package, since there's a lot of it
2013-03-14 12:56:25 -07:00
Gian Merlino
c34108418a
RealtimeIndexTask: Reword comments
2013-03-14 12:49:17 -07:00
Gian Merlino
9fe6a37f86
Realtime: Remove MetadataUpdater
2013-03-14 12:35:38 -07:00
Gian Merlino
055a98a89c
Merger: Fix VersionConverterTask version selection by making SegmentInsertAction more flexible
2013-03-14 10:37:59 -07:00
Gian Merlino
e5d5050c3f
RemoteTaskActionClient: Log retry timer on errors
2013-03-13 23:06:55 -07:00
Gian Merlino
df8e4d4061
Merge branch 'master' into realtime-index-task
2013-03-13 22:43:01 -07:00
Gian Merlino
a1c823402b
Merger: Make json exceptions while bootstrapping non-fatal
2013-03-13 22:42:29 -07:00
Gian Merlino
cf470b1ed4
Merger: Task serde without relying on jackson private-final-setter magic
2013-03-13 22:42:29 -07:00
Eric Tschetter
4c165b4880
1) Better logging of master doing version checking
...
2) Exception out when the scv cannot find its indexer
2013-03-13 19:15:29 -05:00
Eric Tschetter
2bd34f1454
[maven-release-plugin] prepare for next development iteration
2013-03-13 18:32:00 -05:00
Eric Tschetter
b7960e202d
[maven-release-plugin] prepare release druid-0.3.21
2013-03-13 18:31:55 -05:00
Eric Tschetter
32f8b09733
Merge branch 'master' of github.com:metamx/druid
2013-03-13 18:29:54 -05:00
Eric Tschetter
688e5e7417
1) Serialization of Tasks is important
2013-03-13 18:29:47 -05:00
Fangjin Yang
60e75d21ce
Merge branch 'master' of github.com:metamx/druid
2013-03-13 15:45:21 -07:00
Fangjin Yang
16de004fdc
fix json
2013-03-13 15:45:07 -07:00
Eric Tschetter
f1175389c4
[maven-release-plugin] prepare for next development iteration
2013-03-13 16:33:17 -05:00
Eric Tschetter
8aac482618
[maven-release-plugin] prepare release druid-0.3.20
2013-03-13 16:33:10 -05:00
Fangjin Yang
86c7ebe1e2
autoscaling will clear state if a node takes too long to create
2013-03-13 14:28:18 -07:00
Fangjin Yang
ac2d4e52da
bug fix for indexer coordinator not alerting when worker provisioning taking too long
2013-03-13 14:09:21 -07:00
Fangjin Yang
a49d0c5e4c
[maven-release-plugin] prepare for next development iteration
2013-03-11 17:20:16 -07:00
Fangjin Yang
97f828f6b1
[maven-release-plugin] prepare release druid-0.3.19
2013-03-11 17:20:09 -07:00
Gian Merlino
765e70bc8e
RemoteTaskActionClient: Better logging
2013-03-11 15:23:45 -07:00
Gian Merlino
34d6b3a7f0
Merger:
...
- RealtimeIndexTask: Drop locks on startup
- RealtimeIndexTask: Acquire lock before announcing a new segment
- Retry failed RemoteTaskActionClient submissions using a RetryPolicy
- Add comments to RealtimeIndexTask
2013-03-11 14:08:05 -07:00
Gian Merlino
6245e38981
RealtimeIndexTask-related stuff.
...
- New task: RealtimeIndexTask
- Add SegmentAnnouncer, ServerView, QueryRunnerFactoryConglomerate to TaskToolbox
- Tasks can advertise ability to answer queries (through returning non-null from
getQueryRunner)
- WorkerTaskMonitor (the thing on a worker that tracks running tasks) is now a
QuerySegmentWalker
- LockAcquireAction is now blocking
Assorted other changes.
- TaskAction.perform throws IOException
- TaskActions generally have better stringification
- Renamed TaskMonitor -> WorkerTaskMonitor
2013-03-11 11:22:36 -07:00
Gian Merlino
0e4db00d54
TaskQueue: Fix task ordering when bootstrapping
2013-03-11 11:15:19 -07:00
Gian Merlino
4643030716
TaskToolbox: Rename getTaskActionClientFactory -> getTaskActionClient
2013-03-07 22:38:28 -08:00
Gian Merlino
08bff3f472
Merger: Fix JacksonConfigManager initialization
2013-03-07 22:06:42 -08:00
Eric Tschetter
b979096d74
1) Building is good
2013-03-07 18:46:51 -06:00
Eric Tschetter
d1ffe93c5a
Merge remote branch 'origin/convert_task' into convert_task
...
Conflicts:
merger/src/main/java/com/metamx/druid/merger/coordinator/TaskMasterLifecycle.java
2013-03-07 18:12:31 -06:00
Eric Tschetter
f70f71243d
1) Stop polling in ConfigManager when stop is called
...
2) Remove WorkSetupManager in favor of just using ConfigManager
2013-03-07 17:45:57 -06:00
Eric Tschetter
1c3ef48f34
1) Adjust the Config stuff that WorkerSetupManager was using to be reusable
...
2) Use new ConfigManager to pull out a whitelist for the Master
2013-03-07 17:45:57 -06:00
Eric Tschetter
6864007c05
1) Remove Task parameter from other methods off of TaskToolbox that required it
...
2) Move getTaskDir() off of TaskConfig and onto TaskToolbox
3) Rename SegmentKiller interface to DataSegmentKiller
4) Change signature of "DataSegmentKiller.kill(Collection<DataSegment>) throws ServiceException" to just kill(DataSegment) throws SegmentLoadingException
5) Add various log messages
6) Update the version of the segment that has been converted
2013-03-07 17:44:06 -06:00
Eric Tschetter
c9b411c0ca
1) Remove the need for TaskActions to require a Task as a constructor parameter
2013-03-07 17:44:05 -06:00
Eric Tschetter
a11a34f87e
1) Initial commit: Converter Task
2013-03-07 17:44:05 -06:00
Eric Tschetter
ef4ccce30c
1) Stop polling in ConfigManager when stop is called
...
2) Remove WorkSetupManager in favor of just using ConfigManager
2013-03-07 17:43:37 -06:00
Eric Tschetter
9ffccb6803
1) Adjust the Config stuff that WorkerSetupManager was using to be reusable
...
2) Use new ConfigManager to pull out a whitelist for the Master
2013-03-07 12:59:59 -06:00
Fangjin Yang
1b9bbb2f2a
remove test code
2013-03-06 11:20:27 -08:00
Fangjin Yang
9d9efadf72
working indexer console
2013-03-06 10:38:40 -08:00
Eric Tschetter
6e95dd49b3
1) Remove Task parameter from other methods off of TaskToolbox that required it
...
2) Move getTaskDir() off of TaskConfig and onto TaskToolbox
3) Rename SegmentKiller interface to DataSegmentKiller
4) Change signature of "DataSegmentKiller.kill(Collection<DataSegment>) throws ServiceException" to just kill(DataSegment) throws SegmentLoadingException
5) Add various log messages
6) Update the version of the segment that has been converted
2013-03-05 13:30:50 -06:00
Fangjin Yang
b410f5e805
[maven-release-plugin] prepare for next development iteration
2013-03-05 13:30:49 -06:00
Fangjin Yang
c0ab1a503d
[maven-release-plugin] prepare release druid-0.3.18
2013-03-05 13:30:49 -06:00
Fangjin Yang
e51a01f85f
fix broken UT
2013-03-05 13:30:49 -06:00
Fangjin Yang
665f1909c6
fixing a bug with indexing service not correctly killing worker nodes
2013-03-05 13:30:49 -06:00
Fangjin Yang
75cefa05b5
[maven-release-plugin] prepare for next development iteration
2013-03-05 13:30:49 -06:00
Fangjin Yang
90637ab7b7
[maven-release-plugin] prepare release druid-0.3.16
2013-03-05 13:30:49 -06:00
Fangjin Yang
848d49ca87
fix bugs in balancing logic and removing auto-scaled node
2013-03-05 13:30:49 -06:00
Eric Tschetter
a9f7094ef3
1) Remove the need for TaskActions to require a Task as a constructor parameter
2013-03-04 18:10:32 -06:00
Fangjin Yang
10ec2288ee
Merge branch 'master' into indexing_console
2013-03-04 15:23:34 -08:00
Fangjin Yang
552b365194
[maven-release-plugin] prepare for next development iteration
2013-03-04 15:11:37 -08:00
Fangjin Yang
fdb3911794
[maven-release-plugin] prepare release druid-0.3.18
2013-03-04 15:11:28 -08:00
Fangjin Yang
91f54a72ee
fix broken UT
2013-03-04 15:09:55 -08:00
Fangjin Yang
571375a33e
fixing a bug with indexing service not correctly killing worker nodes
2013-03-04 14:40:02 -08:00
Fangjin Yang
d18c9f2b0a
Merge branch 'master' into indexing_console
2013-03-04 13:43:37 -08:00
Fangjin Yang
6977fe03bd
[maven-release-plugin] prepare for next development iteration
2013-03-04 13:08:26 -08:00
Fangjin Yang
d4f4e41320
[maven-release-plugin] prepare release druid-0.3.16
2013-03-04 13:08:09 -08:00
Fangjin Yang
88339fe99b
Merge branch 'master' of github.com:metamx/druid
2013-03-04 13:03:27 -08:00
Fangjin Yang
92ab51e70c
fix bugs in balancing logic and removing auto-scaled node
2013-03-04 13:03:15 -08:00
Eric Tschetter
d7379db6fe
1) Initial commit: Converter Task
2013-03-04 13:44:42 -06:00
Gian Merlino
4e2107fbee
Merger: Rename Task.getFixedInterval -> getImplicitLockInterval. Add more Task docs.
2013-03-04 11:23:36 -08:00
Fangjin Yang
ee38d096c7
[maven-release-plugin] prepare for next development iteration
2013-03-02 09:29:04 -08:00
Fangjin Yang
a90d204ba2
[maven-release-plugin] prepare release druid-0.3.15
2013-03-02 09:28:51 -08:00
Fangjin Yang
aa63e0b25b
account for duplicate events
2013-03-02 09:25:44 -08:00
Fangjin Yang
e5cc6d241d
cleaning up some code for RTR
2013-03-02 08:58:22 -08:00
Fangjin Yang
879b2475d4
[maven-release-plugin] prepare for next development iteration
2013-03-01 19:53:13 -08:00
Fangjin Yang
e3ba6efb80
[maven-release-plugin] prepare release druid-0.3.14
2013-03-01 19:53:07 -08:00
Fangjin Yang
bb83ddb564
fix bug with worker disappearance
2013-03-01 19:51:33 -08:00
Fangjin Yang
7f6747194d
[maven-release-plugin] prepare for next development iteration
2013-03-01 19:45:59 -08:00
Fangjin Yang
06a2a3a793
[maven-release-plugin] prepare release druid-0.3.13
2013-03-01 19:45:50 -08:00
Fangjin Yang
1995039fb9
additional logs
2013-03-01 19:44:14 -08:00
Fangjin Yang
e0700bb161
[maven-release-plugin] prepare for next development iteration
2013-03-01 19:28:34 -08:00
Fangjin Yang
38c8ffb552
[maven-release-plugin] prepare release druid-0.3.12
2013-03-01 19:28:28 -08:00
Fangjin Yang
cbe0555d00
better logging
2013-03-01 19:25:25 -08:00
Fangjin Yang
49e61d00fd
[maven-release-plugin] prepare for next development iteration
2013-03-01 19:05:46 -08:00
Fangjin Yang
7e316e3508
[maven-release-plugin] prepare release druid-0.3.11
2013-03-01 19:05:39 -08:00
Fangjin Yang
e21978603a
Merge branch 'master' of github.com:metamx/druid
2013-03-01 19:03:29 -08:00
Fangjin Yang
df532f021a
more logging
2013-03-01 19:03:16 -08:00
Gian Merlino
665d1723c0
Add TaskLockPosse#toString
2013-03-01 18:48:34 -08:00
Fangjin Yang
0b054cdd3d
better logging for indexing service
2013-03-01 18:43:40 -08:00
Fangjin Yang
e2b4163e31
[maven-release-plugin] prepare for next development iteration
2013-03-01 18:24:09 -08:00
Fangjin Yang
023199702e
[maven-release-plugin] prepare release druid-0.3.10
2013-03-01 18:24:03 -08:00
Fangjin Yang
a574da55ed
fix broken UT
2013-03-01 18:22:30 -08:00
Fangjin Yang
8a9655a19e
Merge branch 'master' of github.com:metamx/druid
2013-03-01 18:00:12 -08:00
Fangjin Yang
375e342d5f
remove deadlock problem in pending tasks
2013-03-01 18:00:02 -08:00
Gian Merlino
0092ad7efb
[maven-release-plugin] prepare for next development iteration
2013-03-01 16:57:47 -08:00
Gian Merlino
03ff72b7e2
[maven-release-plugin] prepare release druid-0.3.8
2013-03-01 16:57:38 -08:00
Fangjin Yang
c9cf091998
Merge branch 'master' of github.com:metamx/druid
2013-03-01 16:54:00 -08:00
Fangjin Yang
53021c2e35
more logging
2013-03-01 16:53:49 -08:00
Gian Merlino
998ed0a8de
[maven-release-plugin] prepare for next development iteration
2013-03-01 14:43:20 -08:00
Gian Merlino
89d5ddf2f7
[maven-release-plugin] prepare release druid-0.3.7
2013-03-01 14:43:13 -08:00
Gian Merlino
6b4f6bffce
DbTaskStorage: Fix getAuditLogs
2013-03-01 14:40:38 -08:00
Fangjin Yang
360c6a1df1
[maven-release-plugin] prepare for next development iteration
2013-03-01 13:55:07 -08:00
Fangjin Yang
a43dc44ebb
[maven-release-plugin] prepare release druid-0.3.6
2013-03-01 13:55:01 -08:00