Skip to content

v0.7.3
Compare
Choose a tag to compare
@gianm gianm released this 10 Feb 02:45
· 93 commits to master since this release
v0.7.3
c5b8894

New features:

  • Flink module (#92)
  • Add buildV9Directly to tuning object, defaults to false (#99)
  • Tranquilizer.flush() to make batch / micro-batch oriented workflows easier (#110)
  • Standardize on configuration files and use of Tranquilizer (#112)
  • Console sender (#117)

Improvements:

  • Adjust spark/flink examples to use event-time-based Timestamper (#100)
  • Changes to make configuration files easier to use (#101)

Bug fixes:

  • Fix transient KafkaConsumerTest failures (#105)
  • Fix DruidBeam exception at TRACE logging level (#106)
  • Kafka: Switch to kafka 0.8.2.2 for compatibility (#109)
  • IndexService: close should return a future, and should not attempt to close a client that has not been created yet (#111)
  • Spark: Recommend using singleton Beam (#115)
  • Target Java 7 (#118)
  • Fix javadoc generation (#120)
Assets 2
Loading