[jira] [Created] (FLINK-5077) testStreamTableSink falls unstable

Boris Osipov created FLINK-5077: --- Summary: testStreamTableSink falls unstable Key: FLINK-5077 URL: https://issues.apache.org/jira/browse/FLINK-5077 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5076) Shutting down TM when shutting down new mini cluster

Biao Liu created FLINK-5076: --- Summary: Shutting down TM when shutting down new mini cluster Key: FLINK-5076 URL: https://issues.apache.org/jira/browse/FLINK-5076 Project: Flink Issue Type:

[jira] [Created] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

Tzu-Li (Gordon) Tai created FLINK-5075: -- Summary: Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite Key: FLINK-5075 URL:

[jira] [Created] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper

shuai.xu created FLINK-5074: --- Summary: Implement a RunningJobRegistry based on Zookeeper Key: FLINK-5074 URL: https://issues.apache.org/jira/browse/FLINK-5074 Project: Flink Issue Type: Task

[Discuss] State Backend use external HBase storage

Hi, All At present flink have three state backend: memory, file system, rocksdb. MemoryStateBackend will tansform the snapshot to jobManager, 5MB limited default. Even setting it bigger, that not suitable for very big state storage. HDFS can meet the reliability guarantee, but It's slow. File

[jira] [Created] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

Till Rohrmann created FLINK-5073: Summary: ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread Key: FLINK-5073 URL: https://issues.apache.org/jira/browse/FLINK-5073

[jira] [Created] (FLINK-5072) MetricFetcher Ask Timeout

Ufuk Celebi created FLINK-5072: -- Summary: MetricFetcher Ask Timeout Key: FLINK-5072 URL: https://issues.apache.org/jira/browse/FLINK-5072 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

Gyula Fora created FLINK-5071: - Summary: YARN: yarn.containers.vcores config not respected when checking for vcores Key: FLINK-5071 URL: https://issues.apache.org/jira/browse/FLINK-5071 Project: Flink

[jira] [Created] (FLINK-5070) Unable to use Scala's BeanProperty with classes

Jakub Nowacki created FLINK-5070: Summary: Unable to use Scala's BeanProperty with classes Key: FLINK-5070 URL: https://issues.apache.org/jira/browse/FLINK-5070 Project: Flink Issue Type:

Re: [VOTE] Release Apache Flink 1.1.4 (RC1)

+1 for cancelling RC1. I would also like to merge FLINK-5013 (Kinesis connector not working on old EMR versions) to be included in 1.1.4. The PR (https://github.com/apache/flink/pull/2787) has been reviewed and can be merged soon. Best, Gordon On November 15, 2016 at 6:56:42 PM, Stefan

Re: [VOTE] Release Apache Flink 1.1.4 (RC1)

+1 for canceling. > Am 15.11.2016 um 10:49 schrieb Till Rohrmann : > > +1 for Ufuk's proposal to cancel the vote in favour of a new RC. +1 for > including FLINK-5065. I'm currently backporting the fix. > > On Tue, Nov 15, 2016 at 9:08 AM, Ufuk Celebi

Re: [VOTE] Release Apache Flink 1.1.4 (RC1)

+1 for Ufuk's proposal to cancel the vote in favour of a new RC. +1 for including FLINK-5065. I'm currently backporting the fix. On Tue, Nov 15, 2016 at 9:08 AM, Ufuk Celebi wrote: > Furthermore, I think this issue is a blocker: > >

[jira] [Created] (FLINK-5069) Pending checkpoint statistics gauge

zhuhaifeng created FLINK-5069: - Summary: Pending checkpoint statistics gauge Key: FLINK-5069 URL: https://issues.apache.org/jira/browse/FLINK-5069 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-14: Loops API and Termination

Hi Paris, I like the proposed changes to the iteration API, this cleans up things in the Java API without any strict restriction I think (it was never a problem in the Scala API). The termination algorithm based on the proposed scoped loops seems to be fairly simple and looks good :) Cheers,

[jira] [Created] (FLINK-5068) YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error

Gyula Fora created FLINK-5068: - Summary: YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error Key: FLINK-5068 URL: https://issues.apache.org/jira/browse/FLINK-5068 Project:

Re: [VOTE] Release Apache Flink 1.1.4 (RC1)

Furthermore, I think this issue is a blocker: https://issues.apache.org/jira/browse/FLINK-5065: Resource leaks in case of lost checkpoint messages – Ufuk On 14 November 2016 at 19:15:49, Ufuk Celebi (u...@apache.org) wrote: > -1 > > (1) We found an issue with the task cancellation safety net