[jira] [Created] (FLINK-11388) Add an OSS RecoverableWriter

wujinhu created FLINK-11388: --- Summary: Add an OSS RecoverableWriter Key: FLINK-11388 URL: https://issues.apache.org/jira/browse/FLINK-11388 Project: Flink Issue Type: Task Components: Str

[jira] [Created] (FLINK-11387) Flink task can not restart from failed after running two days.

jiwei created FLINK-11387: - Summary: Flink task can not restart from failed after running two days. Key: FLINK-11387 URL: https://issues.apache.org/jira/browse/FLINK-11387 Project: Flink Issue Type:

Re: [jira] [Created] (FLINK-11311) StreamSource implements StreamOperator interface multiple times.

Hi all, Could any committer help me to review this issue? PR is now available on Github: https://github.com/apache/flink/pull/7492 Benchao Li (JIRA) 于2019年1月13日周日 下午10:23写道： > Benchao Li created FLINK-11311: > -- > > Summary: StreamSource implements

[FLINK-6626] Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

Hi Team, Anyone working on this jira ticket? Regards, Tarush

[jira] [Created] (FLINK-11384) Remove legacy MesosTaskManager

TisonKun created FLINK-11384: Summary: Remove legacy MesosTaskManager Key: FLINK-11384 URL: https://issues.apache.org/jira/browse/FLINK-11384 Project: Flink Issue Type: Sub-task Compone

[jira] [Created] (FLINK-11386) Remove legacy ContaineredJobManager

TisonKun created FLINK-11386: Summary: Remove legacy ContaineredJobManager Key: FLINK-11386 URL: https://issues.apache.org/jira/browse/FLINK-11386 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-11385) Remove legacy MesosJobManager

TisonKun created FLINK-11385: Summary: Remove legacy MesosJobManager Key: FLINK-11385 URL: https://issues.apache.org/jira/browse/FLINK-11385 Project: Flink Issue Type: Bug Components: M

[jira] [Created] (FLINK-11383) Dispatcher does not clean up blobs of failed submissions

Till Rohrmann created FLINK-11383: - Summary: Dispatcher does not clean up blobs of failed submissions Key: FLINK-11383 URL: https://issues.apache.org/jira/browse/FLINK-11383 Project: Flink Is

Re: Data not getting passed between operators

Hey, Could You please format Your snippet? It is very hard to understand what is going on in there. Best Regards, Dom. śr., 16 sty 2019 o 13:05 Ramya Ramamurthy napisał(a): > Hi > > I have a Flink 1.7 with Kafka 0.11 and ES 6.5 setup. > > I can see the Flink Kafka Consumer consuming messages, bu

?????? [QUESTION] about FsCheckpointStateOutputStream#createStream max10 times create outStream

Ok, I understand it. thanks -- -- ??: "sewen"; : 2019??1??17??(??) 8:28 ??: "dev"; : Re: [QUESTION] about FsCheckpointStateOutputStream#createStream max10 times create outStream The reason it tries 10 times is tha

Re: [QUESTION] about FsCheckpointStateOutputStream#createStream max 10 times create outStream

The reason it tries 10 times is that - it is mainly meant to catch collisions on paths - if it fails for 10 times, there is a very high chance something more fundamental is broken - we did not want to repeat an infinite number of times, to avoid infinite loops and system hanging On Thu, Jan

[QUESTION] about FsCheckpointStateOutputStream#createStream max 10 times create outStream

Hi all, I have a question about FsCheckpointStateOutputStream#createStream method, is it necessary to attempt max 10 times to create outStream? here's the FsCheckpointStateOutputStream#createStream link https://github.com/apache/flink/blob/322e479d540a74e45a9b5e38eb17b4eb3a4c6e9e/flink-run

[jira] [Created] (FLINK-11382) Disable MetricFetcher if interval is configured to 0

Chesnay Schepler created FLINK-11382: Summary: Disable MetricFetcher if interval is configured to 0 Key: FLINK-11382 URL: https://issues.apache.org/jira/browse/FLINK-11382 Project: Flink

[jira] [Created] (FLINK-11381) JOIN LATERAL with a table was not support

Hongtao Zhang created FLINK-11381: - Summary: JOIN LATERAL with a table was not support Key: FLINK-11381 URL: https://issues.apache.org/jira/browse/FLINK-11381 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

vinoyang created FLINK-11380: Summary: YarnFlinkResourceManagerTest test case crashed Key: FLINK-11380 URL: https://issues.apache.org/jira/browse/FLINK-11380 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

Haibo Suen created FLINK-11379: -- Summary: "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD Key: FLINK-11379 URL: https://issues.apache.org/jira/browse/FLINK-11379 Project

[jira] [Created] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems.

Martijn created FLINK-11378: --- Summary: Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems. Key: FLINK-11378 URL: https://issues.apache.org/jira/browse/FLINK-11378 Project: Flink