(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 ... 640641642643644645646 ... 780

Topics (27277)

Replies

Last Post

Views

[jira] [Created] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4098) Iteration support in Python API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

UDP support in Streaming API by Janani Chakkaradhari

by Sarvani

kafka partition assignment by Michal Hariš

by Michal Hariš

[jira] [Created] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

offheap memory allocation and memory leak bug by CPC

by Till Rohrmann

[jira] [Created] (FLINK-4095) Add configDir argument to shell scripts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4094) Off heap memory deallocation might not work properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4093) Expose metric interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4092) Stringify map function's type conversion problem is breaking running provided example in documents by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

incremental Checkpointing , Rocksdb HA by chenqin

by chenqin

Scheduling task slots in round-robin by Gyula Fóra-2

by Gyula Fóra

[jira] [Created] (FLINK-4091) flink-connector-cassandra has conflicting guava version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4088) Add interface to save and load TableSources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4087) JMXReporter can't handle port conflicts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4086) Hide internal Expression methods from Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4085) Set Kinesis Consumer Agent to Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4082) Add Setting for LargeRecordHandler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports by Kostas Kloudas

by Kostas Kloudas

[jira] [Created] (FLINK-4081) FieldParsers should support empty strings by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Testing for FLINK-3839 by THORMAN, ROBERT D

by Robert Metzger

[jira] [Created] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[FLINK-3867] Flink-VM: Vagrant/Ansible based VMs to easily setup Flink by Julius Neuffer

by Ufuk Celebi-2

[jira] [Created] (FLINK-4079) YARN properties file used for per-job cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4078) Use ClosureCleaner for CoGroup where by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4076) BoltWrapper#dispose() should call AbstractStreamOperator#dispose() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4074) Reporter can block TaskManager shutdown by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 640641642643644645646 ... 780