Esper выбрасывает ом даже после использования ограничителя скорости на выходе - PullRequest
Новая
       25

Esper выбрасывает ом даже после использования ограничителя скорости на выходе

0 голосов
/ 16 октября 2019

Мы создаем почасовой контекст в esper и используем @hint с ограничителем скорости вывода. Но у нас все еще не хватает памяти в определенных событиях. XMX -12 G

В некоторых случаях, если мы имеем плохое сжатие, это означает, например, что мы получили данные для 6 ГБ, которые не агрегированы, и, следовательно, это оказывается плохое сжатие от esper.

Я хочу ограничить размер также на esper, поэтому, если мы установим ограничение до ежечасного контекста, я могу сбросить этот большой кусок данных, для которых сжатие плохое.

Это похоже на то, как вы нажалипочасовой контекст или размер для очистки выходных данных.

Мой запрос esper 

 private static final String HOURLY_CONTEXT =
  "create context HourlyRollup start(0,*,*,*,*,0) end(59,*,*,*,*,59)";
  private static final String HINT = "@Hint('enable_outputlimit_opt') ";

private static final String HOURLY_STATEMENT = HINT+
      "context HourlyRollup "
          + "select count(*) as xcount,hourlyFloor(min(from_time)),a,b,c,d,e,f,"
          + "g,h,sum(h),sum(i),j,k,l,"
          + "m,n,y,o,p,q,r "
          + "from io.common.Bean where Dir in (-5,-3,0,1) "
          + "group by a,b,c,d,e,f,g,Direction,h,"
          + "i,j,k,l,m,l,n,o,p output all "+"when terminated";
...