(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 ... 806807808809810811812 ... 1066

Topics (37296)

Replies

Last Post

Views

[jira] [Created] (FLINK-7676) ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7672) Publish Kinesis connector to Maven Central? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7671) JobManagerCleanupITCase failed in build by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

LocalStreamEnvironment - configuration doesn't seem to be used in RichFunction operators by Michael Kobit

by Michael Kobit

[jira] [Created] (FLINK-7670) typo in docs runtime section by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question: Flink documentation contribution only to flink-docs-release-1.3 (not flink-docs-release-1.4) by Kewei Shang

by Kewei Shang

[jira] [Created] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7667) Add serializable AccessExecutionGraph implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-21 - Improve object Copying/Reuse Mode for Streaming Runtime by Stephan Ewen

by Aljoscha Krettek-2

[jira] [Created] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7665) Use wait/notify in ContinuousFileReaderOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7664) Replace FlinkFutureException by CompletionException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7663) Allow AbstractRestHandler to handle bad requests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7662) Remove unnecessary packaged licenses by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Dropping Scala 2.10 by Aljoscha Krettek-2

by Federico D'Ambrosio

[jira] [Created] (FLINK-7661) Add credit field in PartitionRequest message by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7658) Support COLLECT Aggregate function in Flink TABLE API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7654) Update RabbitMQ Java client to 4.x by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7650) Port JobCancellationHandler to new REST endpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7649) Port JobStoppingHandler to new REST endpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7648) Port TaskManagersHandler to new REST endpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7646) Restart failed jobs with configurable parallelism range by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 806807808809810811812 ... 1066