Commits

Branch selector

master

User selector

clockfly

All time

Commit history

Commits on Nov 13, 2014

• STORM-537: update the changelog

  clockfly

  committed
  64f06c7View commit details

  Copy full SHA for 64f06c7

  Browse repository at this point

Commits on Nov 12, 2014

• Merge remote branch 'origin/master'

  clockfly

  committed
  e15dbe2View commit details

  Copy full SHA for e15dbe2

  Browse repository at this point

• Merge branch 'storm-537-infinite-reconnection' of https://github.com/Sergeant007/storm into STORM-537

  clockfly

  committed
  9406500View commit details

  Copy full SHA for 9406500

  Browse repository at this point

Commits on Nov 4, 2014

• add sean zhong into committor list

  clockfly

  committed
  7602f43View commit details

  Copy full SHA for 7602f43

  Browse repository at this point

• Merge branch 'patch-3' of https://github.com/lukedemi/storm

  clockfly

  committed
  7832412View commit details

  Copy full SHA for 7832412

  Browse repository at this point

• Merge branch 'fix_storm-kafka_pom_example' of https://github.com/patricklucas/storm

  clockfly

  committed
  ff23d64View commit details

  Copy full SHA for ff23d64

  Browse repository at this point

• Merge branch 'STORM-492' of https://github.com/HeartSaVioR/storm into STORM-492

  clockfly

  committed
  1b8a32eView commit details

  Copy full SHA for 1b8a32e

  Browse repository at this point

• Merge branch 'STORM-493' of https://github.com/chrisz/incubator-storm into STORM-493

  clockfly

  committed
  a1e1c1eView commit details

  Copy full SHA for a1e1c1e

  Browse repository at this point

• Merge branch 'STORM-307' of https://github.com/wurstmeister/incubator-storm into STORM-307

  clockfly

  committed
  93c4d7eView commit details

  Copy full SHA for 93c4d7e

  Browse repository at this point

• Merge branch 'python-basicbolt-fail-tuple' of https://github.com/forter/incubator-storm into STORM-529

  clockfly

  committed
  cffe7dfView commit details

  Copy full SHA for cffe7df

  Browse repository at this point

Commits on Jun 12, 2014

• STORM-342: add exception as cause when re-thrown

  clockfly

  committed
  8b57097View commit details

  Copy full SHA for 8b57097

  Browse repository at this point

Commits on Jun 10, 2014

• STORM-342: rename the read-write lock

  clockfly

  committed
  6946c34View commit details

  Copy full SHA for 6946c34

  Browse repository at this point

• STORM-342: Message loss, executor hang, or message disorder due to contention in Disruptor queue under multi-thread mode.

  clockfly

  committed
  72b1f59View commit details

  Copy full SHA for 72b1f59

  Browse repository at this point

Commits on Jun 7, 2014

• STORM-297: use acked spout to avoid topology be shutting down before bolt finish.

  clockfly

  committed
  23f5724View commit details

  Copy full SHA for 23f5724

  Browse repository at this point

• Revert "STORM-297: wait for the bolt to finish before killing the topology, otherwise netty client may be killed message before all bolts finish."

  Show description for f7a7802
  clockfly

  committed
  f7a7802View commit details

  Copy full SHA for f7a7802

  Browse repository at this point

• STORM-297: wait for the bolt to finish before killing the topology, otherwise netty client may be killed message before all bolts finish.

  clockfly

  committed
  5f7520aView commit details

  Copy full SHA for 5f7520a

  Browse repository at this point

• STORM-297: avoid call IConneciton.send() when there is no message in the iterator.

  clockfly

  committed
  b4422f1View commit details

  Copy full SHA for b4422f1

  Browse repository at this point

Commits on Jun 4, 2014

• STORM-297: rename "worker.receiver.thread.count" to "topology.worker.receiver.thread.count"

  clockfly

  committed
  f6915d4View commit details

  Copy full SHA for f6915d4

  Browse repository at this point

Commits on Jun 3, 2014

• STORM-297: fix flusher bug, dead loop

  clockfly

  committed
  0bca173View commit details

  Copy full SHA for 0bca173

  Browse repository at this point

• STORM-297: add test case to test multiple receiver thread should reserve message order

  clockfly

  committed
  426d143View commit details

  Copy full SHA for 426d143

  Browse repository at this point

Commits on May 20, 2014

• STORM-297: fix UT regression, when topology.workers is not specified.

  clockfly

  committed
  20b4f8bView commit details

  Copy full SHA for 20b4f8b

  Browse repository at this point

• STORM-297: Add a comment about why using java collection directly in clojure

  clockfly

  committed
  9f9a2a5View commit details

  Copy full SHA for 9f9a2a5

  Browse repository at this point

• STORM-297: give timer thread a meaningful name

  clockfly

  committed
  04b4907View commit details

  Copy full SHA for 04b4907

  Browse repository at this point

• STORM-297: tune the client scheduler pool size

  clockfly

  committed
  f18d98fView commit details

  Copy full SHA for f18d98f

  Browse repository at this point

• STORM-297: Use a shared pool for netty client flusher threads.

  clockfly

  committed
  deba558View commit details

  Copy full SHA for deba558

  Browse repository at this point

• STORM-297: Use a shared pool for netty client flusher threads.

  clockfly

  committed
  9eecaf8View commit details

  Copy full SHA for 9eecaf8

  Browse repository at this point

• STORM-297: avoid duplicate Channel Null Check

  clockfly

  committed
  baa3106View commit details

  Copy full SHA for baa3106

  Browse repository at this point

• STORM-297, remove config option netty.blocking

  clockfly

  committed
  44e47e8View commit details

  Copy full SHA for 44e47e8

  Browse repository at this point

• STORM-297: rename StormClientHandler to StormClientErrorHandler, as all we do it to check errors in the class

  clockfly

  committed
  1baf9b7View commit details

  Copy full SHA for 1baf9b7

  Browse repository at this point

• STORM-297, add timeout when trying to send pending batches in close()

  clockfly

  committed
  d85c470View commit details

  Copy full SHA for d85c470

  Browse repository at this point

• STORM-297: use primitive type int instead of Integer

  clockfly

  committed
  fe68fd9View commit details

  Copy full SHA for fe68fd9

  Browse repository at this point

• STORM-297: remove param thread-name when we know we are consuming from a disruptor queue, just use queue name as thread name will suffice

  clockfly

  committed
  6b9da08View commit details

  Copy full SHA for 6b9da08

  Browse repository at this point

• STORM-297: remove config storm.messaging.netty.blocking as we want async to be the default

  clockfly

  committed
  19e72e8View commit details

  Copy full SHA for 19e72e8

  Browse repository at this point

• STORM-297: log server error

  clockfly

  committed
  7b88cf3View commit details

  Copy full SHA for 7b88cf3

  Browse repository at this point

• STORM-297: Use recv(int flags, int clientId) to replace recv(int flags) in IConnection interface

  clockfly

  committed
  c5c3571View commit details

  Copy full SHA for c5c3571

  Browse repository at this point