flink connector打印gql

seafish · 2022 年3 月 2 日 01:31

nebula版本 2.6.0 flink connector 版本 2.6.0
本地调试，怎么看到写入时的gql语句？

darionyaphet · 2022 年3 月 7 日 08:25

简单看了一下源码，您把日志等级调为 debug 应该就可以打印出执行语句了

具体代码在这个位置，请移步：

vesoft-inc/nebula-flink-connector/blob/master/connector/src/main/java/org.apache.flink/connector/nebula/sink/NebulaEdgeBatchExecutor.java#L70

    
      
                  break;
              case UPDATE:
                  statement = nebulaEdges.getUpdateStatement();
                  break;
              case DELETE:
                  statement = nebulaEdges.getDeleteStatement();
                  break;
              default:
                  throw new IllegalArgumentException("write mode is not supported");
          }
          LOG.debug("write statement={}", statement);
          
          
// execute ngql statement
          ResultSet execResult = null;
          try {
              execResult = session.execute(statement);
          } catch (Exception e) {
              LOG.error("write data error, ", e);
              nebulaEdgeList.clear();
              return statement;
          }

system · 2022 年4 月 6 日 08:25

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。