Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 26, 2018

• ScheduleAfterDebounceTime should catch all Throwable to avoid losing unhandled Errors

  Show description for b0603c3
  

  thunderstumpges

  authored and

  prateekm

  committed
  b0603c3

  Copy full SHA for b0603c3

Commits on Mar 23, 2018

• Making event hub configs Samza compliant

  Show description for 272aa32
  

  srinipunuru

  authored and

  xinyuiscool

  committed
  272aa32

  Copy full SHA for 272aa32

Commits on Mar 22, 2018

• Add stream-table join support for samza sql

  Show description for 956cf41
  

  atoomula

  authored and

  xinyuiscool

  committed
  956cf41

  Copy full SHA for 956cf41

Commits on Mar 21, 2018

• SAMZA-1623: include avro as the file suffix for hdfs producer

  Show description for 2d7b0f5
  

  lhaiesp

  authored and

  xinyuiscool

  committed
  2d7b0f5

  Copy full SHA for 2d7b0f5

Commits on Mar 16, 2018

• SAMZA-1608 : Add hidden config to enable explicit stream creation in StreamAppender due to bug.

  Show description for 30c6a89
  

  dnishimura

  authored and

  prateekm

  committed
  30c6a89

  Copy full SHA for 30c6a89

• SAMZA-1622: avro writer to support generic record

  Show description for 924a78d
  

  lhaiesp

  authored and

  xinyuiscool

  committed
  924a78d

  Copy full SHA for 924a78d

Commits on Mar 15, 2018

• SAMZA-1615: Fix a couple of issues in ControlMessageSender

  Show description for 9f86821
  xinyuiscool

  committed
  9f86821

  Copy full SHA for 9f86821

Commits on Mar 14, 2018

• SAMZA-1611: BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets

  Show description for 3f9b967
  

  atoomula

  authored and

  jagadish-v0

  committed
  3f9b967

  Copy full SHA for 3f9b967

Commits on Mar 13, 2018

• SAMZA-1618: fix HdfsFileSystemAdapter to get files recursively

  Show description for 49e5073
  

  lhaiesp

  authored and

  xinyuiscool

  committed
  49e5073

  Copy full SHA for 49e5073

Commits on Mar 9, 2018

• SAMZA-1610: Implementation of remote table provider

  Show description for 2be7061
  

  pdu-mn1

  authored and

  jagadish-v0

  committed
  2be7061

  Copy full SHA for 2be7061

• Infinite loop when trying to use SamzaSqlApplicationRunner in yarn mode

  Show description for 1971d59
  

  srinipunuru

  authored and

  xinyuiscool

  committed
  1971d59

  Copy full SHA for 1971d59

• SAMZA-1589: Reduce failure retry duration in KafkaCheckpointManager.writeCheckpoint

  Show description for 6492826
  

  shanthoosh

  authored and

  jagadish-v0

  committed
  6492826

  Copy full SHA for 6492826

Commits on Mar 7, 2018

• SAMZA-1607: Handle ZkNoNodeExistsException in zkUtils.readProcessorData

  Show description for 89dc18e
  

  shanthoosh

  authored and

  xinyuiscool

  committed
  89dc18e

  Copy full SHA for 89dc18e

• SAMZA-1602: Moving class StreamAssert from src/test to src/main

  Show description for f7b0d38
  

  Sanil15

  authored and

  xinyuiscool

  committed
  f7b0d38

  Copy full SHA for f7b0d38

• SAMZA-1498: Support arbitrary system clock timer in operators

  Show description for aa05865
  xinyuiscool

  committed
  aa05865

  Copy full SHA for aa05865

Commits on Mar 6, 2018

• SAMZA-1600: remove the combination of cleanup policy "compact,delete"…

  Show description for 78ee982
  

  nickpan47

  authored and

  jagadish-v0

  committed
  78ee982

  Copy full SHA for 78ee982

• SAMZA-1460: StreamAppender does not explicitly create logging topic

  Show description for 810d8bd
  

  dnishimura

  authored and

  jagadish-v0

  committed
  810d8bd

  Copy full SHA for 810d8bd

Commits on Mar 4, 2018

• Misc. minor cleanup.

  Show description for 1dfc5ce
  

  prateekm

  authored and

  jagadish-v0

  committed
  1dfc5ce

  Copy full SHA for 1dfc5ce

• SAMZA-1598: Cleanup README.md file

  Show description for bc0a47b
  

  dnishimura

  authored and

  jagadish-v0

  committed
  bc0a47b

  Copy full SHA for bc0a47b

Commits on Mar 1, 2018

• SAMZA-1596: Staging directory name has to be formatted in config

  Show description for ed7e4af
  

  Zedmor

  authored and

  jagadish-v0

  committed
  ed7e4af

  Copy full SHA for ed7e4af

Commits on Feb 27, 2018

• SAMZA-1597: Expose an interface for throttling

  

  weisong44

  authored and

  jagadish-v0

  committed
  963bd30

  Copy full SHA for 963bd30

Commits on Feb 23, 2018

• SAMZA-1595: Fix scalacCompileOptions format to build with zinc scala compiler.

  Show description for 6af104e
  

  shanthoosh

  authored and

  xinyuiscool

  committed
  6af104e

  Copy full SHA for 6af104e

Commits on Feb 22, 2018

• SAMZA-1594: Remove ScalaCompileOptions to make samza codebase build with gradle version > 3.0.

  Show description for 47881a2
  

  shanthoosh

  authored and

  xinyuiscool

  committed
  47881a2

  Copy full SHA for 47881a2

• SAMZA-1593: Upgrade gradle nexus plugin.

  Show description for 526c1d2
  

  shanthoosh

  authored and

  xinyuiscool

  committed
  526c1d2

  Copy full SHA for 526c1d2

Commits on Feb 21, 2018

• Fixes to get the build working with Scala 2.10 build

  Show description for 6270e40
  

  srinipunuru

  authored and

  jagadish-v0

  committed
  6270e40

  Copy full SHA for 6270e40

Commits on Feb 16, 2018

• SAMZA-1555: Move creation of checkpoint and changelog streams to the Job Coordinators

  Show description for 6dc89e1
  

  dnishimura

  authored and

  nickpan47

  committed
  6dc89e1

  Copy full SHA for 6dc89e1

• SAMZA-1588: Add random jitter to monitor’s scheduling interval.

  Show description for 718c666
  

  shanthoosh

  authored and

  prateekm

  committed
  718c666

  Copy full SHA for 718c666

Commits on Feb 15, 2018

• Support source types where the last part of the source is not the streamName

  Show description for c3e6b55
  

  srinipunuru

  authored and

  xinyuiscool

  committed
  c3e6b55

  Copy full SHA for c3e6b55

Commits on Feb 14, 2018

• SAMZA-1568: Handle ZkInterruptedException in zkclient.close.

  Show description for 4123b16
  

  shanthoosh

  authored and

  jagadish-v0

  committed
  4123b16

  Copy full SHA for 4123b16

Commits on Feb 13, 2018

• SAMZA-1572: Add fixed retries on failure in KafkaCheckpointManager.

  Show description for 002e131
  

  shanthoosh

  authored and

  jagadish-v0

  committed
  002e131

  Copy full SHA for 002e131

Commits on Feb 1, 2018

• SAMZA-1489: TaskInstance should commit offset before it closes() if auto commit is enabled

  Show description for c51693b
  

  lindong28

  authored and

  jagadish-v0

  committed
  c51693b

  Copy full SHA for c51693b

• SAMZA-1552: Host affinity improvements - Improve matching of hosts to allocated resources

  Show description for 03e5026
  jagadish-v0

  committed
  03e5026

  Copy full SHA for 03e5026

Commits on Jan 26, 2018

• SAMZA-1578: Fix watermark bug found by BEAM tests

  Show description for 7e68e4b
  xinyuiscool

  committed
  7e68e4b

  Copy full SHA for 7e68e4b

• Added some logging to stdout for easier parsing by tools.

  Show description for 9674836
  

  prateekm

  authored and

  jagadish-v0

  committed
  9674836

  Copy full SHA for 9674836

• SAMZA-1548; Add start() and stop() to SystemAdmin

  Show description for 75e70e5
  

  lindong28

  authored and

  prateekm

  committed
  75e70e5

  Copy full SHA for 75e70e5

Pagination

Previous

Next