(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 615616617618619620621 ... 781

Topics (27306)

Replies

Last Post

Views

S3/S3A support by Vijay Srinivasaragha...

by Cliff Resnick

currentLowWatermark metric not reported for all tasks? by dan bress

by dan bress

[DISCUSS] add netty tcp/restful pushed source support by shijinkui

by Stephan Ewen

Use specific Task Manager for heavy computations by Mariano Gonzalez

by Stephan Ewen

[jira] [Created] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Support Suspending and Resuming of Flink Jobs by SHI Xiaogang

by Till Rohrmann

Assign issue by Nikolay Vasilishin

by Fabian Hueske-2

[jira] [Created] (FLINK-4812) Export currentLowWatermark metric also for sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4811) Checkpoint Overview should list failed checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4809) Operators should tolerate checkpoint failures by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4808) Allow skipping failed checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4806) ResourceManager stop listening JobManager's leader address by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4805) Stringify() crashes with Python3 (run with pyflink3) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4804) Grouping.first() function usage fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4802) distinct() implicitly uses 0th field, when called without a parameter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Type problem in RichFlatMapFunction when using GenericArray type by Martin Junghanns

by Timo Walther-2

[jira] [Created] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4799) Re-add build-target symlink to project root by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4797) Add Flink 1.1 savepoint backwards compatability by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4796) Extend SinkFunction to include also the event timestamp by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4795) CsvStringify crashes in case of tuple in tuple, t.e. ("a", True, (1,5)) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4794) partition_by_hash() crashes if no parameter is provided by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4792) Update documentation - QuickStart - FlinkML by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4791) Fix issues caused by expression reduction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4790) FlinkML - Error of type while using readCsvFile by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error. by Pavan kumar S

by Pavan kumar S

[jira] [Created] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4787) Add REST API call for cancel-with-savepoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 615616617618619620621 ... 781