怎么获取dataset中元素数量？

Question

val inputMysql: DataSet[Row] = env.createInput(JDBCInputFormat.buildJDBCInputFormat()
      .setDrivername(addressProperties.mysqlDriver)
      .setDBUrl(addressProperties.mysqlConnect)
      .setUsername(addressProperties.mysqlUserName)
      .setPassword(addressProperties.mysqlPassWord)
      .setQuery("select TERMINAL_ID from TM_ALARM_EVENT where STATUS = '0' and TERMINAL_ID = '" + terminalID + "' and LEVEL = '3' and TYPE = '2'")
      .setRowTypeInfo(new RowTypeInfo(BasicTypeInfo.STRING_TYPE_INFO))
      .finish()
    )
    inputMysql.count()

直接调用count()方法放到flink集群上运行的时候会报错，java.lang.Exception: Could not create actor system，不知道怎么解，求帮助

Answer 1

env.excute 执行任务？