diff --git a/drivers/default/src/main/java/org/onosproject/driver/pipeline/OltPipeline.java b/drivers/default/src/main/java/org/onosproject/driver/pipeline/OltPipeline.java
index 5bf2f75..dd72436 100644
--- a/drivers/default/src/main/java/org/onosproject/driver/pipeline/OltPipeline.java
+++ b/drivers/default/src/main/java/org/onosproject/driver/pipeline/OltPipeline.java
@@ -227,15 +227,9 @@
                 return;
             }
             if (ipProto.protocol() == IPv4.PROTOCOL_IGMP) {
-
-                if (vlanId.isEmpty() || vlanPcp.isEmpty()) {
-                    log.warn("Missing IGMP vlan or pcp");
-                    fail(filter, ObjectiveError.BADPARAMS);
-                    return;
-                }
                 provisionIgmp(filter, ethType, ipProto, output,
-                              (L2ModificationInstruction) vlanId.get(),
-                              (L2ModificationInstruction) vlanPcp.get());
+                              vlanId.orElse(null),
+                              vlanPcp.orElse(null));
             } else if (ipProto.protocol() == IPv4.PROTOCOL_UDP) {
                 UdpPortCriterion udpSrcPort = (UdpPortCriterion)
                         filterForCriterion(filter.conditions(), Criterion.Type.UDP_SRC);
@@ -949,7 +943,7 @@
     private void provisionIgmp(FilteringObjective filter, EthTypeCriterion ethType,
                                IPProtocolCriterion ipProto,
                                Instructions.OutputInstruction output,
-                               L2ModificationInstruction vlan, L2ModificationInstruction pcp) {
+                               Instruction vlan, Instruction pcp) {
 
         Instruction meter = filter.meta().metered();
         Instruction writeMetadata = filter.meta().writeMetadata();