storm-server/src/main/java/org/apache/storm/LocalCluster.java (13 lines):
	- line 859: // TODO Auto-generated method stub
	- line 865: // TODO Auto-generated method stub
	- line 872: // TODO Auto-generated method stub
	- line 878: // TODO Auto-generated method stub
	- line 885: // TODO Auto-generated method stub
	- line 963: // TODO Auto-generated method stub
	- line 990: // TODO Auto-generated method stub
	- line 1007: // TODO Auto-generated method stub
	- line 1014: // TODO Auto-generated method stub
	- line 1021: // TODO Auto-generated method stub
	- line 1027: // TODO Auto-generated method stub
	- line 1033: // TODO Auto-generated method stub
	- line 1039: // TODO Auto-generated method stub


storm-clojure/src/clj/org/apache/storm/util.clj (5 lines):
	- line 103: ;TODO: We're keeping this function around until all the code using it is properly tranlated to java
	- line 104: ;TODO: by properly having the for loop IN THE JAVA FUNCTION that originally used this function.
	- line 111: ;TODO: We're keeping this function around until all the code using it is properly tranlated to java
	- line 112: ;TODO: by properly having the for loop IN THE JAVA FUNCTION that originally used this function.
	- line 117: ;TODO: Once all the other clojure functions (100+ locations) are translated to java, this function becomes moot.


storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java (4 lines):
	- line 96: //TODO: add a method for drpc stream, needs to know how to automatically do return results, etc
	- line 580: // TODO: consider adding a shuffle grouping after the spout to avoid so much routing of the args/return-info all over the place
	- line 834: // TODO: in the future, want a way to include this logic in the spout itself,
	- line 894: // TODO: handle regular rich spout without batches (need lots of updates to support this throughout)


flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java (3 lines):
	- line 222: //TODO support multiple levels of includes
	- line 243: //TODO move this logic to the model class
	- line 272: //TODO streams should be uniquely identifiable


storm-client/src/jvm/org/apache/storm/trident/operation/impl/PreservingFieldsOrderJoinerMultiReducer.java (3 lines):
	- line 62: //TODO: do the inner join incrementally, emitting the cross join with this tuple, against all other sides
	- line 63: //TODO: only do cross join if at least one tuple in each side
	- line 155: //TODO: DRY this code up with what's in ChainedAggregatorImpl


storm-client/src/jvm/org/apache/storm/trident/operation/impl/JoinerMultiReducer.java (3 lines):
	- line 57: //TODO: do the inner join incrementally, emitting the cross join with this tuple, against all other sides
	- line 58: //TODO: only do cross join if at least one tuple in each side
	- line 123: //TODO: DRY this code up with what's in ChainedAggregatorImpl


storm-webapp/src/main/java/org/apache/storm/daemon/drpc/DRPCServer.java (3 lines):
	- line 58: //TODO in the future this might be better in a common webapp location
	- line 109: //TODO a better way to do this would be great.
	- line 185: //TODO this is causing issues...


flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java (3 lines):
	- line 249: //TODO check for null grouping args
	- line 668: // TODO more collection content type checking
	- line 726: // TODO more collection content type checking


storm-core/src/native/worker-launcher/impl/utils/cJSON.c (3 lines):
	- line 1738: /* FIXME: Can overflow here. Cannot be fixed without breaking the API */
	- line 2887: /* TODO This has O(n^2) runtime, which is horrible! */
	- line 2901: * TODO: Do this the proper way, this is just a fix for now */


storm-core/src/native/worker-launcher/impl/oci/oci_launch_cmd.c (2 lines):
	- line 234: // TODO: seccomp validation
	- line 359: // TODO: Need to add mount source/dest whitelist checking here.


storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/DRPCResource.java (2 lines):
	- line 47: //TODO put in some better exception mapping...
	- line 48: //TODO move populateContext to a filter...


storm-server/src/main/java/org/apache/storm/utils/ServerConfigUtils.java (2 lines):
	- line 88: /* TODO: make sure test these two functions in manual tests */
	- line 139: String[] subStrings = fname.split(Pattern.quote(FILE_SEPARATOR)); // TODO: does this work well on windows?


storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java (2 lines):
	- line 163: //TODO: add logging that not all tuples were received
	- line 271: // TODO: Need to be able to set the tick tuple time to the message timeout, ideally without parameterization


storm-client/src/jvm/org/apache/storm/trident/topology/MasterBatchCoordinator.java (2 lines):
	- line 211: //TODO: make this strategy configurable?... right now it goes if anyone is ready
	- line 255: // TODO: replace json with a better form of encoding


storm-client/src/jvm/org/apache/storm/dependency/DependencyUploader.java (1 line):
	- line 152: // FIXME: we can filter by listKeys() with local blobstore when STORM-1986 is going to be resolved


dev-tools/github/__init__.py (1 line):
	- line 56: # TODO def review_comments


storm-client/src/jvm/org/apache/storm/serialization/SerializationFactory.java (1 line):
	- line 192: // TODO: de-duplicate this logic with the code in nimbus


storm-core/src/jvm/org/apache/storm/utils/TopologySpoutLag.java (1 line):
	- line 42: // FIXME: This class can be moved to webapp once UI porting is done.


storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java (1 line):
	- line 153: //TODO: this isn't right... it's not in the map anymore


sql/storm-sql-external/storm-sql-redis/src/jvm/org/apache/storm/sql/redis/RedisDataSourcesProvider.java (1 line):
	- line 183: // TODO: this assumes key is only from the one field


storm-client/src/jvm/org/apache/storm/trident/state/map/CachedBatchReadsMap.java (1 line):
	- line 34: // TODO: can optimize further by only querying backing map for keys not in the cache


storm-client/src/jvm/org/apache/storm/trident/operation/impl/GlobalBatchToPartition.java (1 line):
	- line 20: // TODO: take away knowledge of storm's internals here


storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/LogviewerServer.java (1 line):
	- line 151: //TODO this is causing issues...


flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java (1 line):
	- line 267: //TODO figure out how we want to deal with overrides. Users may want to add streams even when overriding other


storm-client/src/jvm/org/apache/storm/security/auth/ClientAuthUtils.java (1 line):
	- line 186: //TODO this can only ever be null if someone is doing something odd with mocking


sql/storm-sql-external/storm-sql-hdfs/src/jvm/org/apache/storm/sql/hdfs/HdfsDataSourcesProvider.java (1 line):
	- line 111: //TODO we should handle '\n'. ref DelimitedRecordFormat


storm-client/src/jvm/org/apache/storm/security/auth/ThriftClient.java (1 line):
	- line 192: //TODO get this from type instead of hardcoding to Nimbus.


sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/CachedSchemas.java (1 line):
	- line 27: // TODO this class is reserved for supporting messages with different schemas.


storm-server/src/main/java/org/apache/storm/scheduler/resource/ResourceAwareScheduler.java (1 line):
	- line 274: * TODO: This method is only used for testing . It's subject to change if we plan to use this info elsewhere.


storm-server/src/main/java/org/apache/storm/ProcessSimulator.java (1 line):
	- line 78: //TODO once everything is in java this should not be possible any more


storm-clojure/src/clj/org/apache/storm/thrift.clj (1 line):
	- line 108: ;TODO: when translating this function, you should replace the map-val with a proper for loop HERE


storm-client/src/jvm/org/apache/storm/task/GeneralTopologyContext.java (1 line):
	- line 169: // TODO: jsonify StormTopology


storm-server/src/main/java/org/apache/storm/container/cgroup/CgroupManager.java (1 line):
	- line 235: // TODO : Add support for pinning on Windows host


flux/flux-core/src/main/java/org/apache/storm/flux/Flux.java (1 line):
	- line 153: // TODO conditionally load properties from a file our resource


storm-dist/binary/final-package/src/main/assembly/binary.xml (1 line):
	- line 324: <!-- TODO this should be a generated file from "target" -->


storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/DRPCExceptionMapper.java (1 line):
	- line 58: //TODO I would love to standardize this...


storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java (1 line):
	- line 102: * TODO: should worker even take the topologyId as input? this should be deducible from cluster state (by searching through assignments)


storm-core/src/native/worker-launcher/impl/oci/oci.c (1 line):
	- line 227: // TODO: This assumption works for loopback mounts but would not work for


storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/FIFOSchedulingPriorityStrategy.java (1 line):
	- line 46: //TODO need a good way to only do this once...


storm-client/src/jvm/org/apache/storm/trident/Stream.java (1 line):
	- line 97: // TODO: need to be able to replace existing fields with the function fields (like Cascading Fields.REPLACE)


storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java (1 line):
	- line 142: //TODO: wrap this to set the stream name


storm-client/src/jvm/org/apache/storm/metric/FileBasedEventLogger.java (1 line):
	- line 112: //TODO: file rotation