(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 ... 458459460461462463464 ... 783

Topics (27402)

Replies

Last Post

Views

[jira] [Created] (FLINK-9697) Provide connector for Kafka 2.0.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9696) Deep toString for arrays/map in SQL client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9695) Add option for Mesos executor to forcefully pull Docker images by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9694) potentially NPE in CompositeTypeSerializerConfigSnapshot constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9693) possible memory link in jobmanager retaining archived checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9690) Restoring state with FlinkKafkaProducer and Kafka 1.1.0 client fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9689) Flink consumer deserialization example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9688) ATAN2 Sql Function support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9687) Delay the state fetch only when the triggerResult is fire by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9686) Flink Kinesis Producer: Enable Kinesis authentication via AssumeRole by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: FLINK-6222 by Foster, Craig

by zhangminglei

[jira] [Created] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [Flink-9407] Question about proposed ORC Sink ! by zhangminglei

by sagar loke

[jira] [Created] (FLINK-9682) Add setDescription to execution environment and display it in the UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9681) Make sure minRetentionTime not equal to maxRetentionTime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9680) Reduce heartbeat timeout for E2E tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9679) Implement AvroSerializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9678) Remove hard-coded sleeps in HA E2E test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9677) RestClient fails for large uploads by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Streaming by zhangminglei

by zhangminglei

[jira] [Created] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9675) Avoid FileInputStream/FileOutputStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9674) Remove 65s sleep in QueryableState E2E test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9673) Improve State efficiency of bounded OVER window operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9672) Fail fatally if we cannot submit job on added JobGraph signal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9671) Add configuration to enable task manager isolation. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9670) Introduce slot manager factory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9669) Introduce task manager assignment store by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9668) In some case Trigger.onProcessingTime don't exectue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9667) Scala docs are only generated for flink-scala by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9666) short-circuit logic should be used in boolean contexts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 458459460461462463464 ... 783