[jira] [Created] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5465: - Summary: RocksDB fails with segfault while calling AbstractRocksDBState.clear() Key: FLINK-5465 URL: https://issues.apache.org/jira/browse/FLINK-5465 Project:

[jira] [Created] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5464: - Summary: MetricQueryService throws NullPointerException on JobManager Key: FLINK-5464 URL: https://issues.apache.org/jira/browse/FLINK-5464 Project: Flink

[jira] [Created] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5463: - Summary: RocksDB.disposeInternal does not react to interrupts, blocks task cancellation Key: FLINK-5463 URL: https://issues.apache.org/jira/browse/FLINK-5463

[jira] [Created] (FLINK-5462) Flink job fails due to java.util.concurrent.CancellationException while snapshotting

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5462: - Summary: Flink job fails due to java.util.concurrent.CancellationException while snapshotting Key: FLINK-5462 URL: https://issues.apache.org/jira/browse/FLINK-5462

[jira] [Created] (FLINK-5461) Remove Superflous TypeInformation Declaration

2017-01-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-5461: - Summary: Remove Superflous TypeInformation Declaration Key: FLINK-5461 URL: https://issues.apache.org/jira/browse/FLINK-5461 Project: Flink Issue Type:

[jira] [Created] (FLINK-5460) Add documentation how to use Flink with Docker

2017-01-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5460: --- Summary: Add documentation how to use Flink with Docker Key: FLINK-5460 URL: https://issues.apache.org/jira/browse/FLINK-5460 Project: Flink Issue Type:

[jira] [Created] (FLINK-5459) Add documentation how to debug classloading and event time issues

2017-01-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5459: --- Summary: Add documentation how to debug classloading and event time issues Key: FLINK-5459 URL: https://issues.apache.org/jira/browse/FLINK-5459 Project: Flink

[jira] [Created] (FLINK-5457) Create documentation for Asynchronous I/O

2017-01-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5457: --- Summary: Create documentation for Asynchronous I/O Key: FLINK-5457 URL: https://issues.apache.org/jira/browse/FLINK-5457 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5456) Add docs about new state and checkpointing interfaces

2017-01-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5456: --- Summary: Add docs about new state and checkpointing interfaces Key: FLINK-5456 URL: https://issues.apache.org/jira/browse/FLINK-5456 Project: Flink Issue

[jira] [Created] (FLINK-5455) Create documentation how to upgrade jobs and Flink framework versions

2017-01-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5455: --- Summary: Create documentation how to upgrade jobs and Flink framework versions Key: FLINK-5455 URL: https://issues.apache.org/jira/browse/FLINK-5455 Project: Flink

[jira] [Created] (FLINK-5454) Add Documentation about how to tune Checkpointing for large state

2017-01-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5454: --- Summary: Add Documentation about how to tune Checkpointing for large state Key: FLINK-5454 URL: https://issues.apache.org/jira/browse/FLINK-5454 Project: Flink

Flink CEP development is stalling

2017-01-11 Thread Ivan Mushketyk
Hi Flink devs, Roughly half a year ago I implemented several PRs for Flink-CEP[1][2][3] but since then there were no progress with the reviews. What is frustrating about this situation is that Flink customers are asking for features in these PRs. For example customers commented on [1] and [2]

[jira] [Created] (FLINK-5453) REST API request reference incomplete

2017-01-11 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5453: --- Summary: REST API request reference incomplete Key: FLINK-5453 URL: https://issues.apache.org/jira/browse/FLINK-5453 Project: Flink Issue Type:

[jira] [Created] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5452: - Summary: Make table unit tests pass under cluster mode Key: FLINK-5452 URL: https://issues.apache.org/jira/browse/FLINK-5452 Project: Flink Issue Type:

[jira] [Created] (FLINK-5451) Extend JMX metrics documentation section

2017-01-11 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5451: --- Summary: Extend JMX metrics documentation section Key: FLINK-5451 URL: https://issues.apache.org/jira/browse/FLINK-5451 Project: Flink Issue Type:

[jira] [Created] (FLINK-5450) WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5450: - Summary: WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window Key: FLINK-5450 URL:

[jira] [Created] (FLINK-5449) Time drift in MetricRegistry

2017-01-11 Thread Andrey (JIRA)
Andrey created FLINK-5449: - Summary: Time drift in MetricRegistry Key: FLINK-5449 URL: https://issues.apache.org/jira/browse/FLINK-5449 Project: Flink Issue Type: Bug Components: Metrics

[jira] [Created] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

2017-01-11 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5448: -- Summary: Fix typo in StateAssignmentOperation Exception Key: FLINK-5448 URL: https://issues.apache.org/jira/browse/FLINK-5448 Project: Flink Issue Type:

[jira] [Created] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL

2017-01-11 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5447: --- Summary: Sync documentation of built-in functions for Table API with SQL Key: FLINK-5447 URL: https://issues.apache.org/jira/browse/FLINK-5447 Project: Flink

[jira] [Created] (FLINK-5446) System metrics reference incomplete

2017-01-11 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5446: --- Summary: System metrics reference incomplete Key: FLINK-5446 URL: https://issues.apache.org/jira/browse/FLINK-5446 Project: Flink Issue Type:

[jira] [Created] (FLINK-5445) flink kafka consumer should support rate control

2017-01-11 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-5445: - Summary: flink kafka consumer should support rate control Key: FLINK-5445 URL: https://issues.apache.org/jira/browse/FLINK-5445 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5444) Flink UI uses absolute URLs.

2017-01-11 Thread Joerg Schad (JIRA)
Joerg Schad created FLINK-5444: -- Summary: Flink UI uses absolute URLs. Key: FLINK-5444 URL: https://issues.apache.org/jira/browse/FLINK-5444 Project: Flink Issue Type: Bug Reporter:

[jira] [Created] (FLINK-5443) Create a path to migrate from the Rolling to the BucketingSink.

2017-01-11 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5443: - Summary: Create a path to migrate from the Rolling to the BucketingSink. Key: FLINK-5443 URL: https://issues.apache.org/jira/browse/FLINK-5443 Project: Flink

[jira] [Created] (FLINK-5442) Add test to fix ordinals of serialized enum StateDescriptor.Type

2017-01-11 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-5442: - Summary: Add test to fix ordinals of serialized enum StateDescriptor.Type Key: FLINK-5442 URL: https://issues.apache.org/jira/browse/FLINK-5442 Project: Flink