[jira] [Created] (FLINK-8510) Provide access to Delivery envelope in RabbitMQ Source

2018-01-24 Thread Wojciech Luczkow (JIRA)
Wojciech Luczkow created FLINK-8510: --- Summary: Provide access to Delivery envelope in RabbitMQ Source Key: FLINK-8510 URL: https://issues.apache.org/jira/browse/FLINK-8510 Project: Flink Is

[jira] [Created] (FLINK-8509) Remove SqlGroupedWindowFunction from Flink repo

2018-01-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8509: - Summary: Remove SqlGroupedWindowFunction from Flink repo Key: FLINK-8509 URL: https://issues.apache.org/jira/browse/FLINK-8509 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-8508) Remove RexSimplify from Flink repo

2018-01-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8508: - Summary: Remove RexSimplify from Flink repo Key: FLINK-8508 URL: https://issues.apache.org/jira/browse/FLINK-8508 Project: Flink Issue Type: Task Compone

[jira] [Created] (FLINK-8507) Upgrade Calcite dependency to 1.16

2018-01-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8507: - Summary: Upgrade Calcite dependency to 1.16 Key: FLINK-8507 URL: https://issues.apache.org/jira/browse/FLINK-8507 Project: Flink Issue Type: Task Compone

[jira] [Created] (FLINK-8506) fullRestarts Gauge not incremented when jobmanager got killed

2018-01-24 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-8506: - Summary: fullRestarts Gauge not incremented when jobmanager got killed Key: FLINK-8506 URL: https://issues.apache.org/jira/browse/FLINK-8506 Project: Flink

[jira] [Created] (FLINK-8505) SlotManager can reach inconsistent state

2018-01-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8505: Summary: SlotManager can reach inconsistent state Key: FLINK-8505 URL: https://issues.apache.org/jira/browse/FLINK-8505 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8504) TaskExecutor does not properly deregisters JobManager from JobLeaderService

2018-01-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8504: Summary: TaskExecutor does not properly deregisters JobManager from JobLeaderService Key: FLINK-8504 URL: https://issues.apache.org/jira/browse/FLINK-8504 Project: Fl

[jira] [Created] (FLINK-8503) Port TaskManagerLogHandler to new REST endpoint

2018-01-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8503: Summary: Port TaskManagerLogHandler to new REST endpoint Key: FLINK-8503 URL: https://issues.apache.org/jira/browse/FLINK-8503 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-8502) Remove LibraryCacheManager from JobMaster

2018-01-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8502: Summary: Remove LibraryCacheManager from JobMaster Key: FLINK-8502 URL: https://issues.apache.org/jira/browse/FLINK-8502 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-8501) Use single BlobCacheService per TaskExecutor

2018-01-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8501: Summary: Use single BlobCacheService per TaskExecutor Key: FLINK-8501 URL: https://issues.apache.org/jira/browse/FLINK-8501 Project: Flink Issue Type: Improv

feedback request FLINK-8384 Dynamic Session Gaps

2018-01-24 Thread Dyana Rose
The PR for this has a question that I'd like some feedback on. https://github.com/apache/flink/pull/5295 The issue is, in order to be able to pass a typed event to the session gap extractor, the assigner needs to be generic. And if the assigner is generic, then the triggers need to be generic. An