(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 ... 682683684685686687688 ... 785

Topics (27475)

Replies

Last Post

Views

[jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Fwd: DATA TRANSFORMATION PROBLEM by JOHN MILLER

by JOHN MILLER

[jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3116) Remove RecordOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3110) Add support for the partition-centric iterations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Distributed DataFrame - ddf.io by Nam-Luc Tran

by Henry Saputra

[jira] [Created] (FLINK-3109) Join two streams with two different cache time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3100) Signal handler prints error on normal shutdown of cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3099) Create Script for Starting WebClient on Windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3097) Add support for custom functions in Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

could you please add me Contributor list? by jun aoki

by jun aoki

[jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3093) Introduce annotations for interface stability by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3092) Scala API quick start word count example is broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FOSDEM 2016 - take action by 4th of December 2015 by Roman Shaposhnik

by Roman Shaposhnik

Either not NotSerializableException and InvalidTypesException by Vasiliki Kalavri

by Vasiliki Kalavri

1 ... 682683684685686687688 ... 785