Commits

Breadcrumbs

History for

ondevelop

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 3, 2014

• Fix test case: actually use a test parameter

  miguno

  committedDec 3, 2014
  20a6559

Commits on Dec 2, 2014

• KafkaStormSpec: use our own embedded ZooKeeper instance instead of Storm's

  miguno

  committedDec 2, 2014
  095f146

Commits on Sep 30, 2014

• Rename sparkConsumerParallelism to sparkProcessingParallelism to clarify meaning

  miguno

  committedSep 30, 2014
  b57c8bb

• Clarify repartition()

  miguno

  committedSep 30, 2014
  564e5d6

• Derive required #cores for Spark from #partitions of Kafka input topic

  miguno

  committedSep 30, 2014
  891d50b

• Add link to Tuning Guide

  miguno

  committedSep 30, 2014
  657c09d

• Increase test timeouts to help Travis CI builds

  miguno

  committedSep 30, 2014
  2b61fbf

Commits on Sep 29, 2014

• Clarify how to create map of topics

  miguno

  committedSep 29, 2014
  09cca52

• Use Int instead of Integer to configure #partitions and replication factor

  miguno

  committedSep 29, 2014
  3f476ae

• Fix code comment

  miguno

  committedSep 29, 2014
  26c6c9d

• Clarify comment on parallelism

  miguno

  committedSep 29, 2014
  8dc4afe

• Clarify test output

  miguno

  committedSep 29, 2014
  57da5f7

• Add Spark Streaming example that reads from Kafka and writes to Kafka

  miguno

  committedSep 29, 2014
  83a389a

• Move Storm-related classes to sub-packages

  miguno

  committedSep 29, 2014
  6a8a617

Commits on Sep 26, 2014

• Improve and consolidate the Kafka + ZooKeeper setup

  miguno

  committedSep 26, 2014
  70dad90

Commits on Sep 17, 2014

• Consolidate logging to use our own Logging traits (based on logback)

  miguno

  committedSep 17, 2014
  efde9df

• Disable ZK retries in Kafka spout for our Kafka/Storm test topology

  miguno

  committedSep 17, 2014
  08bdaeb

Commits on Aug 14, 2014

• Remove type annotations for Injection's

  miguno

  committedAug 14, 2014
  de6eac4

Commits on Jul 11, 2014

• Rename KafkaConsumer to KafkaConsumerApp

  miguno

  committedJul 11, 2014
  a6be1f2

• Clarify test variables

  miguno

  committedJul 11, 2014
  9ec6e74

• Remove redundant braces

  miguno

  committedJul 11, 2014
  03458d4

• Clarify which variables are actually important

  miguno

  committedJul 11, 2014
  b8cd8f3

Commits on Jul 2, 2014

• Randomize the port used by the embedded Kafka broker

  miguno

  committedJul 2, 2014
  cf0e974

Commits on Jun 30, 2014

• Auto-format code

  miguno

  committedJun 30, 2014
  9b16e9e

• KafkaStormSpec: print Storm cluster config before running integration test

  miguno

  committedJun 30, 2014
  c198dba

• Max 120 chars per line

  miguno

  committedJun 30, 2014
  f2cdb37

• Improve sleep-related debug messages

  miguno

  committedJun 30, 2014
  0ab5b09

• Auto-format code

  miguno

  committedJun 30, 2014
  6f2fdd1

• Simplify expression

  miguno

  committedJun 30, 2014
  7620887

• Reorder imports

  miguno

  committedJun 30, 2014
  200756a

• Explain how to tell Storm 0.9.3+ to use a different ZK instance for testing

  miguno

  committedJun 30, 2014
  eaf59f2

• Remove setting STORM_LOCAL_MODE_ZMQ because it is already set correctly by default

  miguno

  committedJun 30, 2014
  a578f19

• Move implicit Injection (Bijection) higher up as it's more like an import

  miguno

  committedJun 30, 2014
  9d005e2

• KafkaStormSpec: use before/afterEach instead of before/afterAll

  miguno

  committedJun 30, 2014
  4e0fc7a

• Remove redundant time unit information from log messages

  miguno

  committedJun 30, 2014
  b6468b5

Pagination

PreviousNext