diff --git a/src/main/java/net/minecraftforge/fluids/BlockFluidClassic.java b/src/main/java/net/minecraftforge/fluids/BlockFluidClassic.java
index 71b67fa0b1..3cd307bfe8 100644
--- a/src/main/java/net/minecraftforge/fluids/BlockFluidClassic.java
+++ b/src/main/java/net/minecraftforge/fluids/BlockFluidClassic.java
@@ -171,7 +171,7 @@ public class BlockFluidClassic extends BlockFluidBase
 
     public boolean isSourceBlock(IBlockAccess world, BlockPos pos)
     {
-        return world.getBlockState(pos) == this && ((Integer)world.getBlockState(pos).getValue(LEVEL)).intValue() == 0;
+        return world.getBlockState(pos).getBlock() == this && ((Integer)world.getBlockState(pos).getValue(LEVEL)).intValue() == 0;
     }
 
     protected boolean[] getOptimalFlowDirections(World world, BlockPos pos)
@@ -348,4 +348,4 @@ public class BlockFluidClassic extends BlockFluidBase
     {
         return isSourceBlock(world, pos);
     }
-}
\ No newline at end of file
+}