diff --git a/platform/android/MapboxGLAndroidSDK/src/main/java/com/mapbox/mapboxsdk/style/sources/CustomGeometrySource.java b/platform/android/MapboxGLAndroidSDK/src/main/java/com/mapbox/mapboxsdk/style/sources/CustomGeometrySource.java
index e10be1d4ba1..1ff1eeacc38 100644
--- a/platform/android/MapboxGLAndroidSDK/src/main/java/com/mapbox/mapboxsdk/style/sources/CustomGeometrySource.java
+++ b/platform/android/MapboxGLAndroidSDK/src/main/java/com/mapbox/mapboxsdk/style/sources/CustomGeometrySource.java
@@ -51,7 +51,7 @@ public CustomGeometrySource(String id, GeometryTileProvider provider) {
   public CustomGeometrySource(String id, GeometryTileProvider provider, GeoJsonOptions options) {
     this.provider = provider;
     executor = Executors.newFixedThreadPool(4);
-    initialize(this, id, options);
+    initialize(id, options);
   }
 
   /**
@@ -103,7 +103,7 @@ public List<Feature> querySourceFeatures(@Nullable Filter.Statement filter) {
     return features != null ? Arrays.asList(features) : new ArrayList<Feature>();
   }
 
-  protected native void initialize(CustomGeometrySource self, String sourceId, Object options);
+  protected native void initialize(String sourceId, Object options);
 
   private native Feature[] querySourceFeatures(Object[] filter);
 
@@ -127,7 +127,7 @@ private void fetchTile(int z, int x, int y) {
     TileID tileID = new TileID(z, x, y);
     cancelledTileRequests.put(tileID, cancelFlag);
     GeometryTileRequest request = new GeometryTileRequest(tileID, provider, this, cancelFlag);
-    executor.submit(request);
+    executor.execute(request);
   }
 
   @WorkerThread
diff --git a/platform/android/src/style/sources/custom_geometry_source.cpp b/platform/android/src/style/sources/custom_geometry_source.cpp
index 205fe55ed9f..a60b962e45b 100644
--- a/platform/android/src/style/sources/custom_geometry_source.cpp
+++ b/platform/android/src/style/sources/custom_geometry_source.cpp
@@ -5,7 +5,6 @@
 // Java -> C++ conversion
 #include "../android_conversion.hpp"
 #include "../conversion/filter.hpp"
-//#include "../conversion/geojson.hpp"
 
 // C++ -> Java conversion
 #include "../../conversion/conversion.hpp"
@@ -21,7 +20,10 @@ namespace android {
     // This conversion is expected not to fail because it's used only in contexts where
     // the value was originally a GeoJsonOptions object on the Java side. If it fails
     // to convert, it's a bug in our serialization or Java-side static typing.
-    static style::CustomGeometrySource::Options convertCustomGeometrySourceOptions(jni::JNIEnv& env, jni::Object<> options, style::TileFunction fetchFn, style::TileFunction cancelFn) {
+    static style::CustomGeometrySource::Options convertCustomGeometrySourceOptions(jni::JNIEnv& env,
+                                                                                   jni::Object<> options,
+                                                                                   style::TileFunction fetchFn,
+                                                                                   style::TileFunction cancelFn) {
         using namespace mbgl::style::conversion;
         if (!options) {
             return style::CustomGeometrySource::Options();
@@ -36,14 +38,14 @@ namespace android {
         return *result;
     }
 
-    CustomGeometrySource::CustomGeometrySource(jni::JNIEnv& env, jni::Object<CustomGeometrySource> _obj, jni::String sourceId, jni::Object<> options)
+    CustomGeometrySource::CustomGeometrySource(jni::JNIEnv& env,
+                                               jni::String sourceId,
+                                               jni::Object<> options)
         : Source(env, std::make_unique<mbgl::style::CustomGeometrySource>(
-            jni::Make<std::string>(env, sourceId),
-            convertCustomGeometrySourceOptions(env,
-                options,
-                std::bind(&CustomGeometrySource::fetchTile, this, std::placeholders::_1),
-                std::bind(&CustomGeometrySource::cancelTile, this, std::placeholders::_1))) ),
-        javaPeer(_obj.NewGlobalRef(env))  {
+                         jni::Make<std::string>(env, sourceId),
+                         convertCustomGeometrySourceOptions(env, options,
+                                 std::bind(&CustomGeometrySource::fetchTile, this, std::placeholders::_1),
+                                 std::bind(&CustomGeometrySource::cancelTile, this, std::placeholders::_1)))) {
     }
 
     CustomGeometrySource::CustomGeometrySource(jni::JNIEnv& env,
@@ -56,19 +58,31 @@ namespace android {
 
     void CustomGeometrySource::fetchTile (const mbgl::CanonicalTileID& tileID) {
         android::UniqueEnv _env = android::AttachEnv();
+
         static auto fetchTile = javaClass.GetMethod<void (jni::jint, jni::jint, jni::jint)>(*_env, "fetchTile");
+
         assert(javaPeer);
-        javaPeer->Call(*_env, fetchTile, (int)tileID.z, (int)tileID.x, (int)tileID.y);
+
+        auto peer = jni::Cast(*_env, *javaPeer, javaClass);
+        peer.Call(*_env, fetchTile, (int)tileID.z, (int)tileID.x, (int)tileID.y);
     };
 
     void CustomGeometrySource::cancelTile(const mbgl::CanonicalTileID& tileID) {
         android::UniqueEnv _env = android::AttachEnv();
+
         static auto cancelTile = javaClass.GetMethod<void (jni::jint, jni::jint, jni::jint)>(*_env, "cancelTile");
+
         assert(javaPeer);
-        javaPeer->Call(*_env, cancelTile, (int)tileID.z, (int)tileID.x, (int)tileID.y);
+
+        auto peer = jni::Cast(*_env, *javaPeer, javaClass);
+        peer.Call(*_env, cancelTile, (int)tileID.z, (int)tileID.x, (int)tileID.y);
     };
 
-    void CustomGeometrySource::setTileData(jni::JNIEnv& env, jni::jint z, jni::jint x, jni::jint y, jni::Object<geojson::FeatureCollection> jFeatures) {
+    void CustomGeometrySource::setTileData(jni::JNIEnv& env,
+                                           jni::jint z,
+                                           jni::jint x,
+                                           jni::jint y,
+                                           jni::Object<geojson::FeatureCollection> jFeatures) {
         using namespace mbgl::android::geojson;
 
         // Convert the jni object
@@ -81,6 +95,7 @@ namespace android {
     void CustomGeometrySource::invalidateTile(jni::JNIEnv&, jni::jint z, jni::jint x, jni::jint y) {
         source.as<mbgl::style::CustomGeometrySource>()->CustomGeometrySource::invalidateTile(CanonicalTileID(z, x, y));
     }
+
     void CustomGeometrySource::invalidateBounds(jni::JNIEnv& env, jni::Object<LatLngBounds> jBounds) {
         auto bounds = LatLngBounds::getLatLngBounds(env, jBounds);
         source.as<mbgl::style::CustomGeometrySource>()->CustomGeometrySource::invalidateRegion(bounds);
@@ -114,7 +129,7 @@ namespace android {
         // Register the peer
         jni::RegisterNativePeer<CustomGeometrySource>(
             env, CustomGeometrySource::javaClass, "nativePtr",
-            std::make_unique<CustomGeometrySource, JNIEnv&, jni::Object<CustomGeometrySource>, jni::String, jni::Object<>>,
+            std::make_unique<CustomGeometrySource, JNIEnv&, jni::String, jni::Object<>>,
             "initialize",
             "finalize",
             METHOD(&CustomGeometrySource::querySourceFeatures, "querySourceFeatures"),
diff --git a/platform/android/src/style/sources/custom_geometry_source.hpp b/platform/android/src/style/sources/custom_geometry_source.hpp
index 00d8dc918f3..1dc1c07b4fa 100644
--- a/platform/android/src/style/sources/custom_geometry_source.hpp
+++ b/platform/android/src/style/sources/custom_geometry_source.hpp
@@ -22,10 +22,7 @@ class CustomGeometrySource : public Source {
 
     static void registerNative(jni::JNIEnv&);
 
-    CustomGeometrySource(jni::JNIEnv&,
-                       jni::Object<CustomGeometrySource>,
-                       jni::String,
-                       jni::Object<>);
+    CustomGeometrySource(jni::JNIEnv&, jni::String, jni::Object<>);
 
     CustomGeometrySource(jni::JNIEnv&, mbgl::style::Source&, AndroidRendererFrontend&);
 
@@ -44,7 +41,6 @@ class CustomGeometrySource : public Source {
 private:
     jni::Object<Source> createJavaPeer(jni::JNIEnv&);
 
-    jni::UniqueObject<CustomGeometrySource> javaPeer;
 }; // class CustomGeometrySource
 
 } // namespace android