{"push_id":1174808930,"size":12,"distinct_size":12,"ref":"refs/heads/temp-location","head":"14e50c46d23b82cbb6e2b9faec7869e8fda68d1f","before":"7116de61542e2954541f11e775232c63d940df7b","commits":[{"sha":"008be9107eb06e97b9fab305427e3bfd4edf6def","author":{"name":"Scott Wegner","email":"33f9eae64f7ae31295cdf43ca21ada514ccfbd0e@google.com"},"message":"Disable exec-maven-plugin cleanupDaemonThreads\n\nexec-maven-plugin has a bad interaction with DataflowPipelineRunner\nwhen waiting on daemon threads. When running example pipelines,\nMaven will emit a warning saying background threads are alive\nafter being aborted. This looks to users like an error while there's\nactually no harm to it. Disabling cleanupDaemonThreads suppresses\nthis warning.","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/008be9107eb06e97b9fab305427e3bfd4edf6def"},{"sha":"8be97d8b5e6fa9bdf0166dcc33c336cf176afa10","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Shutdown the InProcessPipelineRunner after Terminating Abnormally\n\nEnsure that the executor service is shutdown, and the monitor is not\nrescheduled, after an exception is thrown.","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/8be97d8b5e6fa9bdf0166dcc33c336cf176afa10"},{"sha":"f8169b5c52472a2329a1f94ea9ed96bcbd29c1c1","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Base PAssert on GBK instead of side inputs\n\nPreviously PAssert - hence all RunnableOnService/NeedsRunner\ntests - required side input support. This created a very steep\non ramp for new runners.\n\nGroupByKey is a bit more fundamental and most backends will be\nable to group by key in the global window very quickly. So switching\nthe primitive used to gather all the contents of a PCollection for\nassertions should make it a bit easier to get early feedback during\nrunner development.","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/f8169b5c52472a2329a1f94ea9ed96bcbd29c1c1"},{"sha":"11d0d52af5169f56797d3ebcbe0cdc9044c5933c","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Fix TriggerExampleTest","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/11d0d52af5169f56797d3ebcbe0cdc9044c5933c"},{"sha":"e4ca252142b7fdff48f3434d4022d4de015efd33","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Switch Spark streaming tests to custom assertions\n\nThe current use of PAssert in the streaming tests for\nthe Spark runner work via coincidence. PAssert does not\ntruly support non-global windowing. The switch from\nside inputs to GBK, with no change in semantics but hopefully\nan easier on-ramp for new runners, incidentally broke\nthese tests. Soon, PAssert will support windowing, triggers,\nand unbounded PCollections. Until then, this change\nwrites a slightly custom assertion transform for these tests.","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/e4ca252142b7fdff48f3434d4022d4de015efd33"},{"sha":"8ebfee70d07698ac07a6d190ab5f56f50f8aebcd","author":{"name":"Kenneth Knowles","email":"7ee59cbbb0cfc706bc0a9605e2d68fae3354c025@google.com"},"message":"Spark runner: Assign windows when re-windowing into global window\n\nPreviously, window assignment was elided when the window was the\nglobal window. But when the source windows are not the global window,\nthis elision is not correct. Now window assignment is run except\nwhen both the source *and* the destination window are the global window\n(which remains a common case in globally windowed batch tests\nusing PAssert).","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/8ebfee70d07698ac07a6d190ab5f56f50f8aebcd"},{"sha":"9617b4a8af6657d7ae0a679a0d6743deda457240","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Use a DirectExecutor for Watermark Callbacks\n\nThis fixes a resource leak where the executor service is not properly\nshut down with the rest of the DirectRunner.","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/9617b4a8af6657d7ae0a679a0d6743deda457240"},{"sha":"2dd595f9fd08b7086ccc5da6555609ffe6072e66","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Execute NeedsRunner tests in the Direct Runner","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/2dd595f9fd08b7086ccc5da6555609ffe6072e66"},{"sha":"cda3c06cd17547556f882ffe3c341e48e52fa1ae","author":{"name":"Pei He","email":"17c994c0b8f5c9ef72564c0b717afcb0ddc06269@google.com"},"message":"Remove defaulting tempLocation to stagingLocation","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/cda3c06cd17547556f882ffe3c341e48e52fa1ae"},{"sha":"794e44bcaa37c01f4bc7bb06b88ff88e7006f717","author":{"name":"Pei He","email":"17c994c0b8f5c9ef72564c0b717afcb0ddc06269@google.com"},"message":"Add GcpTempLocation, and use it as the default stagingLocation","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/794e44bcaa37c01f4bc7bb06b88ff88e7006f717"},{"sha":"b0b64ec5d26ca59ced95b7ba043b17554e2afa15","author":{"name":"Pei He","email":"17c994c0b8f5c9ef72564c0b717afcb0ddc06269@google.com"},"message":"Add BigQueryTempLocation","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/b0b64ec5d26ca59ced95b7ba043b17554e2afa15"},{"sha":"14e50c46d23b82cbb6e2b9faec7869e8fda68d1f","author":{"name":"Pei He","email":"17c994c0b8f5c9ef72564c0b717afcb0ddc06269@google.com"},"message":"Fix the WordCountIT by settting the tempLocation","distinct":true,"url":"https://api.github.com/repos/peihe/incubator-beam/commits/14e50c46d23b82cbb6e2b9faec7869e8fda68d1f"}]}
{"actor":{"display_login":"peihe"}}