diff --git a/internal/datanode/flow_graph_node.go b/internal/datanode/flow_graph_node.go
index 2fa133cd79..f91036f76c 100644
--- a/internal/datanode/flow_graph_node.go
+++ b/internal/datanode/flow_graph_node.go
@@ -34,12 +34,12 @@ type (
 	InputNode = flowgraph.InputNode
 )
 
-var flowGraphRetryOpt = retry.Attempts(5)
+var flowGraphRetryOpt = retry.Attempts(20)
 
 var fgRetryOptVal atomic.Value
 
 func init() {
-	setFlowGraphRetryOpt(retry.Attempts(5))
+	setFlowGraphRetryOpt(retry.Attempts(20))
 }
 
 // setFlowGraphRetryOpt set retry option for flowgraph