{"push_id":1333540865,"size":261,"distinct_size":1,"ref":"refs/heads/global_window_timers","head":"8d659fec13982c982d58d8abd1007197bc443c61","before":"2a02d1247758db2904148b327f2e0aba8cf1098d","commits":[{"sha":"f08f21cdf4c067745a10b31a6481ed470f97dadc","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"FileBasedSink: improve parallelism in GCS copy/remove","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/f08f21cdf4c067745a10b31a6481ed470f97dadc"},{"sha":"a8b2d6cc9fd1c2bf9757fc8efd8c30b5df6dcbb9","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #826","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/a8b2d6cc9fd1c2bf9757fc8efd8c30b5df6dcbb9"},{"sha":"b1123417a6b55fba1560fa68096d0b5551efa960","author":{"name":"Ismaël Mejía","email":"862cbae56f453a9d2791ee75012cddcd4a5f7527@gmail.com"},"message":"[BEAM-574] Remove log when new records have not been read yet (KafkaIO)","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/b1123417a6b55fba1560fa68096d0b5551efa960"},{"sha":"b380a677b2823897b1ecc1b903e0775d794423e0","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #859","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/b380a677b2823897b1ecc1b903e0775d794423e0"},{"sha":"c64e9dca8cc8ab9424ac29894ed6bf9358dd9fdf","author":{"name":"Daniel Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@users.noreply.github.com"},"message":"Write: Remove invalid import","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/c64e9dca8cc8ab9424ac29894ed6bf9358dd9fdf"},{"sha":"835f601a9f08b2118e9ce3cc20fca025f86ec3fc","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #870","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/835f601a9f08b2118e9ce3cc20fca025f86ec3fc"},{"sha":"3b221732a298111e0612caa61b7acf69d13dd2d2","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"JUnit tests: add @RunWith annotation","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/3b221732a298111e0612caa61b7acf69d13dd2d2"},{"sha":"f17e7303a9ad6d7c4bf39f1657564b168adb1d84","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #873","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/f17e7303a9ad6d7c4bf39f1657564b168adb1d84"},{"sha":"ddbfcdb6d36815e00c266be11d727135d75913f0","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Remove ParDoTest Suppression in Google Cloud Dataflow\n\nThis reenables the lifecycle tests now that they are properly supported.\n\nUpdate the container image.","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/ddbfcdb6d36815e00c266be11d727135d75913f0"},{"sha":"a87015bfe18138a5302a45712d3a6c581408c316","author":{"name":"Dan Halperin","email":"0291491adc84a7497e89df29893a36b10448bbd8@google.com"},"message":"Closes #876","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/a87015bfe18138a5302a45712d3a6c581408c316"},{"sha":"d94bffdd20f7bb2f380c807f84c5405552a40f71","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Fix Emission in startBundle/finishBundle in Flink Wrappers","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/d94bffdd20f7bb2f380c807f84c5405552a40f71"},{"sha":"1de76b7a5169a46ef9f14406e5a6e1284832f7f9","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[BEAM-253] Unify Flink-Streaming Operator Wrappers\n\nThis also replaces the custom Flink StateInternals by proper Flink\nPartitioned StateInternals.","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/1de76b7a5169a46ef9f14406e5a6e1284832f7f9"},{"sha":"ff34f9e81867a656e4d9dd0987063c58cbb1de88","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Fix Checkstyle Errors in FlinkStreamingTransformTranslators","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/ff34f9e81867a656e4d9dd0987063c58cbb1de88"},{"sha":"dfbdc6c2bbef5e749bfc1800f97d21377f0c713d","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[BEAM-102] Add Side Inputs in Flink Streaming Runner\n\nThis adds a generic SideInputHandler in runners-core that is only used\nby the Flink runner right now but can be used by other runner\nimplementations.","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/dfbdc6c2bbef5e749bfc1800f97d21377f0c713d"},{"sha":"4aba224e44f3ef6c96d1836d9434bbc2e3daad0c","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Allow DoFn Reuse in ParDoTest.TestDoFnWithContext","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/4aba224e44f3ef6c96d1836d9434bbc2e3daad0c"},{"sha":"ea3a46c7896c954084fc581a06e1f3ef68a3f3d0","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Don't Suppress Throwable in PAssert in Streaming Mode","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/ea3a46c7896c954084fc581a06e1f3ef68a3f3d0"},{"sha":"df2874d02c7e3ad6660e488b3f847a2d6d830953","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Fix Flink Runner Pom for Batch RunnableOnService tests","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/df2874d02c7e3ad6660e488b3f847a2d6d830953"},{"sha":"f9fac642967a51aadc69b1ec32832acae98b3375","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"Enable Flink Streaming Runner RunnableOnService tests","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/f9fac642967a51aadc69b1ec32832acae98b3375"},{"sha":"e302cab06640e016fcb24e03376ac84149f2ed2b","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Fix combine tests with Accumulation Mode\n\nThese tests were not written in such a way as to succeed if the trigger\nfired multiple times.","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/e302cab06640e016fcb24e03376ac84149f2ed2b"},{"sha":"d4b024baecb99a259a79918c0554b85efc148120","author":{"name":"Thomas Groh","email":"9f4d47704b29055ce957a3a60147bcec3e488e81@google.com"},"message":"Use AllPanes as the PaneExtractor in IterableAssert\n\nThis ensures that tests with triggering in the global window which assert\non the entire PCollection (not a singleton iterable) will succeed over the\nentire PCollection","distinct":false,"url":"https://api.github.com/repos/tgroh/incubator-beam/commits/d4b024baecb99a259a79918c0554b85efc148120"}]}
{"actor":{"display_login":"tgroh"}}