docs: public synchronized void setFlushInterval(long delay, long seconds) {
          if (m_flush != null) {
              m_flush.cancel(false);
              m_flush = null;
          }
          if (seconds > 0) {
              m_flush = m_ses.scheduleAtFixedRate(new Runnable() {
                  @Override
                  public void run() {
                      try {
                          flush();
                      } catch (Exception e) {
                          loaderLog.error("Failed to flush loader buffer, some tuples may not be inserted.", e);
                      }
                  }
              }, delay, seconds, TimeUnit.SECONDS);
          }
      }