Commits

Commits on Jun 2, 2020

[BEAM-9869] adding self-contained Kafka service jar for testing
ihji
committedJun 2, 2020

Commits on May 29, 2020

[BEAM-10078] uniquify Dataflow specific jars when staging (apache#11814 )
ihji
committedMay 29, 2020
[BEAM-10125] adding cross-language KafkaIO integration test
ihji
committedMay 29, 2020

Commits on May 26, 2020

[BEAM-10077] using filename + hash instead of UUID for staging name
ihji
committedMay 26, 2020

Commits on May 22, 2020

[BEAM-10064] Fix google3 import error for BEAM-9383
ihji
committedMay 22, 2020

Commits on May 21, 2020

[BEAM-10052] check hash and avoid duplicated artifacts
ihji
committedMay 21, 2020

Commits on May 19, 2020

[BEAM-9383] Staging Dataflow artifacts from environment (apache#11039 )
ihji
committedMay 19, 2020

Commits on Apr 7, 2020

Merge pull request apache#11205 [BEAM-9578] Defer expensive artifact enumeration in Java.
ihji
committedApr 7, 2020

Commits on Mar 11, 2020

[BEAM-9056] Staging artifacts from environment
ihji
committedMar 11, 2020

Commits on Mar 2, 2020

[BEAM-9415] fix postcommit xvr tests
ihji
committedMar 2, 2020

Commits on Feb 21, 2020

[BEAM-9229] Adding dependency information to Environment proto (apache#10733 )
ihji
committedFeb 21, 2020

Commits on Feb 20, 2020

[BEAM-9341] postcommit xvr flink fix
ihji
committedFeb 20, 2020

Commits on Feb 19, 2020

[BEAM-9338] add postcommit XVR spark badges
ihji
committedFeb 19, 2020
[BEAM-9335] update hard-coded coder id when translating Java external transforms
ihji
committedFeb 19, 2020

Commits on Feb 3, 2020

[BEAM-9230] Enable CrossLanguageValidateRunner test for Spark runner
ihji
committedFeb 3, 2020

Commits on Jan 31, 2020

[BEAM-7961] Add tests for all runner native transforms and some widely used composite transforms to cross-language validates runner test suite
ihji
committedJan 31, 2020

Commits on Dec 27, 2019

[BEAM-9034] Update environment_id for ExternalTransform in Python SDK
ihji
committedDec 27, 2019

Commits on Dec 19, 2019

[BEAM-8902] parameterize input type of Java external transform
ihji
committedDec 19, 2019

Commits on Dec 11, 2019

[BEAM-8943] SDK harness servers don't shut down properly when SDK harness environment cleanup fails
ihji
committedDec 11, 2019

Commits on Dec 9, 2019

Commits on Dec 6, 2019

[BEAM-8903] handling --jar_packages experimental flag in PortableRunner for staging external dependencies used in expanded transforms
ihji
committedDec 6, 2019

Commits on Aug 22, 2019

[BEAM-8008] show error message from expansion service in Java External transform
ihji
committedAug 22, 2019

Commits on Aug 8, 2019

[BEAM-7924] Failure in Python 2 postcommit: crossLanguagePythonJavaFlink
ihji
committedAug 8, 2019

Commits on Aug 6, 2019

[BEAM-7915] show cross-language validate runner Flink badge on github PR template
ihji
committedAug 6, 2019
[BEAM-6683] add createCrossLanguageValidatesRunner task
ihji
committedAug 6, 2019

Commits on Aug 5, 2019

[BEAM-7667] report GCS throttling time to Dataflow autoscaler
ihji
committedAug 5, 2019

Commits on Aug 2, 2019

[BEAM-7877] Change the log level when deleting unknown temoprary files in FileBasedSink
ihji
committedAug 2, 2019
[BEAM-7846] add test for BEAM-7689
ihji
committedAug 2, 2019

Commits on Jul 31, 2019

[BEAM-7813] FileIO.write() doesn't fail when writing to invalid bucket
ihji
committedJul 31, 2019

Commits on Jul 9, 2019

[BEAM-7689] make a temporary directory unique for FileBaseSink
ihji
committedJul 9, 2019

Commits on Jun 26, 2019

[BEAM-7424] Retry HTTP 429 errors from GCS
ihji
committedJun 26, 2019

Commits on May 15, 2019

[BEAM-7103] Adding AvroCoderTranslator for cross-language data transfer
ihji
committedMay 15, 2019

Commits on May 14, 2019

[BEAM-7271] adding UTF8 String coder to Java SDK ModelCoder

ihji
authored and
mxm
committedMay 14, 2019

Commits on May 13, 2019

[BEAM-7253] test_with_jar_packages_invalid_file_name test fails on windows
ihji
committedMay 13, 2019