Re: Request for contributor permission

Thanks a lot Gordon! Best regards, blues On 05/08/2018 12:01, Tzu-Li (Gordon) Tai wrote: Hi, I’ve gave you contributor permissions and assigned you the ticket. Happy contributing! Cheers, Gordon On 8 May 2018 at 11:56:59 AM, blues zheng (kisim...@163.com) wrote: Hi devs, We are working on

Re: Request for contributor permission

Hi, I’ve gave you contributor permissions and assigned you the ticket. Happy contributing! Cheers, Gordon On 8 May 2018 at 11:56:59 AM, blues zheng (kisim...@163.com) wrote: Hi devs, We are working on FLINK-7789, could someone give me the contributor permission? My JIRA username is

Request for contributor permission

Hi devs, We are working on FLINK-7789, could someone give me the contributor permission? My JIRA username is "kisimple". Thanks, blues

[jira] [Created] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated

Biao Liu created FLINK-9315: --- Summary: TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated Key: FLINK-9315 URL: https://issues.apache.org/jira/browse/FLINK-9315 Project: Flink

[HA] Is it possible to remove external dependency caused by high-availability.zookeeper.storageDir

Hi, As for lots of companies, we have different architectures for near-time/off-line analytics platform (fink vs hadoop), so we may not want flink cluster to depend on a shared HDFS as an additional dependency to operate especially we may deploy the streaming stack all on k8s including

[jira] [Created] (FLINK-9314) Enable SSL mutual authentication for Netty / TaskManagers

Stephan Ewen created FLINK-9314: --- Summary: Enable SSL mutual authentication for Netty / TaskManagers Key: FLINK-9314 URL: https://issues.apache.org/jira/browse/FLINK-9314 Project: Flink Issue

[jira] [Created] (FLINK-9313) Enable mutual authentication for RPC (akka)

Stephan Ewen created FLINK-9313: --- Summary: Enable mutual authentication for RPC (akka) Key: FLINK-9313 URL: https://issues.apache.org/jira/browse/FLINK-9313 Project: Flink Issue Type:

[jira] [Created] (FLINK-9311) PubSub connector

Richard Deurwaarder created FLINK-9311: -- Summary: PubSub connector Key: FLINK-9311 URL: https://issues.apache.org/jira/browse/FLINK-9311 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9310) Update default cyphersuites

Stephan Ewen created FLINK-9310: --- Summary: Update default cyphersuites Key: FLINK-9310 URL: https://issues.apache.org/jira/browse/FLINK-9310 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

Fabian Hueske created FLINK-9309: Summary: Recommend HA setup on Production Readiness Checklist Key: FLINK-9309 URL: https://issues.apache.org/jira/browse/FLINK-9309 Project: Flink Issue

[jira] [Created] (FLINK-9308) The method enableCheckpointing with low values like 10 are forming DoS on Kafka Clusters

Seweryn Habdank-Wojewodzki created FLINK-9308: - Summary: The method enableCheckpointing with low values like 10 are forming DoS on Kafka Clusters Key: FLINK-9308 URL:

Re: Confusing error message in MemCheckpointStreamFactory with large state size?

Hi Ken and Rong, That's a good point. The FSStateBackend holds all state in the JVM heap as well. The name is also not well chosen, IMO. Thanks for creating the JIRA ticket! Fabian 2018-05-05 0:52 GMT+02:00 Ken Krugler : > > > On May 3, 2018, at 9:06 PM, Rong Rong

[jira] [Created] (FLINK-9307) Running flink program doesn't print infos in console any more

Alex Chen created FLINK-9307: Summary: Running flink program doesn't print infos in console any more Key: FLINK-9307 URL: https://issues.apache.org/jira/browse/FLINK-9307 Project: Flink Issue

[jira] [Created] (FLINK-9306) Execute YARN IT tests for legacy and new mode

Aljoscha Krettek created FLINK-9306: --- Summary: Execute YARN IT tests for legacy and new mode Key: FLINK-9306 URL: https://issues.apache.org/jira/browse/FLINK-9306 Project: Flink Issue

[jira] [Created] (FLINK-9305) Register flink-s3-fs-* for the s3a:// scheme as well

Nico Kruber created FLINK-9305: -- Summary: Register flink-s3-fs-* for the s3a:// scheme as well Key: FLINK-9305 URL: https://issues.apache.org/jira/browse/FLINK-9305 Project: Flink Issue Type:

[jira] [Created] (FLINK-9304) Timer service shutdown should not be interrupted

Stefan Richter created FLINK-9304: - Summary: Timer service shutdown should not be interrupted Key: FLINK-9304 URL: https://issues.apache.org/jira/browse/FLINK-9304 Project: Flink Issue Type: