Sign in
apache
/
gobblin
/
HEAD
9151f93
Insert Final summary issue entry in issues table (#4125)
by NamsB7
· 3 days ago
master
ddd9468
Propagate file system job properties to Work units (#4124)
by thisisArjit
· 3 days ago
51773ab
[GOBBLIN-2211] Implement Error Classification based on execution issues (#4121)
by NamsB7
· 6 days ago
c6e2112
Fix AvroCompactionTaskTest & OrcCompactionTaskTest (#4122)
by thisisArjit
· 2 weeks ago
5da75ce
[GOBBLIN-2208] Acl preservation fix (#4117)
by vsinghal85
· 2 months ago
1c6c24f
[GOBBLIN-2207] Make temporal unique classifier GaaS attempt aware (#4116)
by pratapaditya04
· 3 months ago
8d71c89
[GOBBLIN-2206] Revert extra execute bit getting set in ManifestDistcp (#4115)
by Vivek Rai
· 3 months ago
be7c1a7
[GOBBLIN-2200] Onboard a new job executionId to deprecate Azkaban executionId (#4108)
by pratapaditya04
· 3 months ago
b535daf
Add data quality field in GaaSJobObservabilityEventSchema (#4114)
by vsinghal85
· 3 months ago
4cfa2f7
[GOBBLIN-2203] Add Support for Delete Manifests in Iceberg Full Table Replication (#4112)
by Vivek Rai
· 3 months ago
0548766
change aggregation temporality to DELTA instead of CUMULATIVE (#4111)
by Vivek Rai
· 3 months ago
4a4c171
Checkstyle fix (#4110)
by vsinghal85
· 4 months ago
60a9d31
DagProcessingThread bug fix (#4109)
by vsinghal85
· 4 months ago
a978b29
[GOBBLIN-2199] Support dynamic container scaling based on target completion time & WU count (#4106)
by Prateek Khandelwal
· 4 months ago
8b250d4
[GOBBLIN-2147] Added lookback time fetch in partitioned filesource (#4044)
by Vivek Rai
· 5 months ago
a37a241
Prevent dagProcessingEngine thread termination by handling exceptions gracefully (#4105)
by Prateek Khandelwal
· 5 months ago
e64f707
[GOBBLIN-2190] Added param to create Activityoptions without HeartbeatTimeout (#4103)
by Vivek Rai
· 5 months ago
1d93982
[GOBBLIN-2190] Added SUBMITGTE activity to ActivityType enum (#4102)
by Vivek Rai
· 5 months ago
f2bcdc7
[GOBBLIN-2190] Implement ActivityType & add HeartBeat for Temporal Activities (#4093)
by Vivek Rai
· 5 months ago
eb60a2c
[GOBBLIN-2189] Implemented ContainerCompletion callback in DynamicScalingYarnService
by Vivek Rai
· 5 months ago
db9cf7e
corrected log statement
by Vivek Rai
· 5 months ago
dee3fe4
added a comment
by Vivek Rai
· 5 months ago
8dde23a
Upgrade hadoop-azure-datalake dependency (#4099)
by abhishekmjain
· 5 months ago
23c4481
[GOBBLIN-2194] Close temporal metrics scope on job completion (#4097)
by abhishekmjain
· 5 months ago
f341c1e
addressed comments
by Vivek Rai
· 5 months ago
861916a
removed extra spaces
by Vivek Rai
· 6 months ago
729bebb
added test for non-replacement case
by Vivek Rai
· 6 months ago
29891fd
added test for handle container completion
by Vivek Rai
· 6 months ago
4c7b019
fixed typo
by Vivek Rai
· 6 months ago
90b7e6c
addressed review comments
by Vivek Rai
· 6 months ago
adef734
Add metrics support for Temporal Workflow (#4095)
by abhishekmjain
· 6 months ago
7a80eb7
addressed review comments
by Vivek Rai
· 6 months ago
09a3e21
[GOBBLIN-2191] Shutdown GobblinJobLauncher executor (#4094)
by abhishekmjain
· 6 months ago
e69a77e
improved dummy tests
by Vivek Rai
· 6 months ago
e584e5b
[GOBBLIN-2182] Cleanup workdir in Gobblin-on-Temporal execution (#4085)
by Vivek Rai
· 6 months ago
089e2e0
fix updating workforce plan while containerCompletion
by Vivek Rai
· 7 months ago
e8f7574
initial dynamicscalingyarnservice changes for handleContainerCompletion
by Vivek Rai
· 7 months ago
a0cef28
[GOBBLIN-2188] Define `Initializer.AfterInitializeMemento` for GoT to tunnel state from `GenerateWorkUnits` to `CommitActivity` (#4091)
by Kip Kohn
· 7 months ago
87c8ab4
[GOBBLIN-2187] Prevent NaN while generating `WorkUnitsSizeSummary.Distillation` (#4090)
by Vivek Rai
· 7 months ago
3269764
[GOBBLIN-2186] Emit GoT GTEs to time `WorkUnit` prep and to record volume of Work Discovery (#4089)
by Kip Kohn
· 7 months ago
7dbeebf
[GOBBLIN-2185] Recommend GoT Dynamic Auto-Scaling using heuristics based on `WorkUnitsSizeSummary` (#4087)
by Kip Kohn
· 7 months ago
faecb35
[GOBBLIN-2181] Ensure `DagTask::conclude` after a non-transient exception (#4084)
by vsinghal85
· 8 months ago
2595f6c
[GOBBLIN-2177] Avoid shutting down QueueProcessor on non-InterruptedException (#4080)
by abhishekmjain
· 8 months ago
0bf770c
[GOBBLIN-2175] Support partial commit with Gobblin-on-Temporal execution (#4078)
by pratapaditya04
· 8 months ago
f4728fb
[GOBBLIN-2178] Remove (deprecated and unused) `GaaSObservabilityEventExperimental` (#4081)
by Swapnil
· 8 months ago
003590e
[GOBBLIN-2179] Enhance GoT observability with `WorkUnitsSizeSummary` and `WorkUnitSizeInfo` (#4082)
by Kip Kohn
· 8 months ago
7309060
[GOBBLIN-2174] Define `DynamicScalingYarnService` for the GoT workforce via `ScalingDirective`s (#4077)
by Vivek Rai
· 8 months ago
2142d22
[GOBBLIN-2176] Set default `java.net.Authenticator` in Temporal worker containers (#4079)
by abhishekmjain
· 8 months ago
e5d897e
[GOBBLIN-2173] Disallow adhoc flows sharing the same FlowId within epsilon (#4076)
by vsinghal85
· 8 months ago
4e38b2f
[GOBBLIN-2170] Define Gobblin-on-Temporal dynamic `ScalingDirective`s with parser and `FsScalingDirectiveSource` (#4068)
by Kip Kohn
· 8 months ago
4bb0c40
[GOBBLIN-2172] Enable launching GoT YARN AM and workers with proxy HTTPS host+port (#4075)
by abhishekmjain
· 9 months ago
13a6926
[GOBBLIN-2171] Streamline log messages for easier debugging of GaaS multi-active DAG processing (#4074)
by Kip Kohn
· 9 months ago
edaf474
[GOBBLIN-2169] avoid npe while overwrite if table has no previous snapshot (#4071)
by Vivek Rai
· 9 months ago
b4e4d4a
[GOBBLIN-2163] Add Iceberg-Distcp table metadata validation (for partition copy) (#4064)
by Vivek Rai
· 9 months ago
4b639f6
[GOBBLIN-2159] Support partition level copy in Iceberg-Distcp (#4058)
by Vivek Rai
· 9 months ago
916d570
[GOBBLIN-2167] Allow filtering of Hive datasets by underlying HDFS folder location (#4069)
by William Lo
· 9 months ago
e3baf91
[GOBBLIN-2166] Add azkaban exec props for GoT jobs as RMAppSummaryEvent app. tags (#4067)
by abhishekmjain
· 9 months ago
4f60423
[GOBBLIN-2162] Only load added jars in the cache (#4062)
by William Lo
· 9 months ago
2afab69
[GOBBLIN-2165] Support partial commit semantic from CopyDataPublisher (#4066)
by William Lo
· 10 months ago
d4c9c35
Add default value for OpenTelemetry attribute (#4065)
by Prateek Khandelwal
· 10 months ago
20c4341
[GOBBLIN-2148] Add temporal workflow cancel support (#4045)
by abhishekmjain
· 10 months ago
4776135
[GOBBLIN-2161] Read logExporter classname from config property (#4063)
by Prateek Khandelwal
· 10 months ago
2bc5638
[GOBBLIN-2161] Support for configuring openTelemetry metric exporter as logExporter (#4061)
by Prateek Khandelwal
· 10 months ago
4fa6c51
[GOBBLIN-2157] Copy table properties in iceberg distcp (#4056)
by William Lo
· 10 months ago
a07a4f1
[GOBBLIN-2135] Cache Gobblin YARN application jars (#4030)
by William Lo
· 11 months ago
8a8d230
[GOBBLIN-2153] Added search attributes to Temporal workflows (#4052)
by pratapaditya04
· 11 months ago
72306bb
[GOBBLIN-2156] log error after each failed AzkabanClient retry (#4055)
by Arjun Singh Bora
· 11 months ago
c3d16b2
[GOBBLIN-2155] Fix bug where empty delete activity result was not jackson deserializ… (#4054)
by William Lo
· 11 months ago
35a4d8e
bring back the old toString method for DagId (#4053)
by Arjun Singh Bora
· 11 months ago
f9b80ac
[GOBBLIN-2151] ignore flows that are running beyond job start and flow finish deadline when doing the concurrency check (#4050)
by Arjun Singh Bora
· 11 months ago
f6eeb53
[GOBBLIN-2152] Cleanup activity gobblin temporal (#4047)
by William Lo
· 11 months ago
833fed3
[GOBBLIN-2136] consolidate various resource handlers for flowconfigs (#4041)
by Arjun Singh Bora
· 11 months ago
f839130
fixing an issue of not able to connect to db (#4051)
by Arjun Singh Bora
· 11 months ago
45ad13e
[GOBBLIN-2136] Byebye dag manager (#4031)
by Arjun Singh Bora
· 11 months ago
f40bb44
[GOBBLIN-2150] calculate flow status correctly (#4048)
by Arjun Singh Bora
· 11 months ago
0ea2414
[GOBBLIN-2149] Add logs in OpenTelemetry for debugging (#4046)
by abhishekmjain
· 11 months ago
2695699
[GOBBLIN-2143] handle concurrent ReevaluateDagProc for cancelled dag nodes correctly (#4038)
by Arjun Singh Bora
· 11 months ago
f6ba473
[GOBBLIN-2145] fix bug in getting flow status (#4040)
by Arjun Singh Bora
· 11 months ago
444f266
[GOBBLIN-2144] Prevent `GenerateWorkUnitsImpl` from inadvertently cleaning up temp/staging dirs (#4039)
by Kip Kohn
· 11 months ago
b28b468
[GOBBLIN-2142] fix bug in determining if a dag is finished or not (#4037)
by Arjun Singh Bora
· 11 months ago
7c8127c
[GOBBLIN-2141] Simulate directly on trash class (#4036)
by William Lo
· 11 months ago
d58bbc0
use a newer api in guava (#4034)
by Arjun Singh Bora
· 11 months ago
a214282
[GOBBLIN-2131] process all dag actions during startup parallely (#4024)
by pratapaditya04
· 11 months ago
e857c00
[GOBBLIN-2133] provide job future before calling SpecProducer::cancelJob (#4027)
by Arjun Singh Bora
· 12 months ago
ac5d6ee
[GOBBLIN-2132] set flow event field in dag and also emit GTE when flow is submitted (#4026)
by Arjun Singh Bora
· 12 months ago
0542794
[GOBBLIN-2129] avoid throwing unnessary exception that is polluting logs (#4023)
by Arjun Singh Bora
· 12 months ago
bdbf43a
[GOBBLIN-2130] avoid race condition b/w add dag node and delete dag (#4021)
by Arjun Singh Bora
· 12 months ago
eaed582
[GOBBLIN-2128] Fix bugs in setpermission step where it does not properly add records… (#4020)
by William Lo
· 12 months ago
ca7ad90
reevaluate dag proc should accept pending_retry status if it is a retry (#4019)
by Arjun Singh Bora
· 12 months ago
977928e
[GOBBLIN-2127] do not emit GaaSObservabilityEvent for a failed job that is going to be retried (#4018)
by Arjun Singh Bora
· 12 months ago
4543e02
Remove setpermission step for pre-existing folders (#4017)
by William Lo
· 12 months ago
e501b62
[GOBBLIN-2118]Reduce no of network calls while fetching kafka offsets during startup (#4009)
by Arpit Varshney
· 12 months ago
a55c89c
[GOBBLIN-2124] only retry transient exceptions (#4016)
by Arjun Singh Bora
· 12 months ago
805ab64
[GOBBLIN-2121] redirect kill requests to dag proc engine (#4015)
by Arjun Singh Bora
· 12 months ago
a46d74e
[GOBBLIN-2123] create reevaluate dag action for jobs in state PENDING_RETRY (#4013)
by Arjun Singh Bora
· 12 months ago
442b5b2
serialize/deserialize curretnAttemps and currentGeneration in dag node (#4014)
by Arjun Singh Bora
· 12 months ago
78c8891
[GOBBLIN-2087] Enhance DatasetHiveSchemaContainsNonOptionalUnion to suport Optional database name (#3972)
by pawanbtej
· 1 year ago
981ec4f
[GOBBLIN-2079] Separate GaaSJobObservabilityEvents to both flow and job level events (#3962)
by William Lo
· 1 year ago
bdea71e
update job_name column size (#4011)
by Arjun Singh Bora
· 1 year ago
dd34ba9
Mark dagActionsConclude correctly (#4010)
by umustafi
· 1 year ago
Next »