(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 ... 561562563564565566567 ... 781

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6438) Expand docs home page a little by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6437) Move history server configuration to a separate file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Supported Hadoop versions by Greg Hogan

by Greg Hogan

[jira] [Created] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6435) AsyncWaitOperator does not handle exceptions properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6434) There may be allocatedSlots leak in SlotPool by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6433) Unreachable code in SqlToRelConverter#visitCall() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6432) Activate strict checkstyle for flink-python by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6431) Activate strict checkstyle for flink-metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6430) Remove Calcite classes for time resolution of auxiliary group functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6429) Bump up Calcite version to 1.13 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6428) Add supported DISTINCT in dataStream SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6427) BucketingSink does not sync file length in case of cancel by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6426) Correct the method parameter type error in the group-window table API document by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question on checkpointing by Blake Essing

by Aljoscha Krettek-2

[jira] [Created] (FLINK-6424) Add basic helper functions for map type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Resource overallocation by Luís Alves

by Luís Alves

[jira] [Created] (FLINK-6423) JoinFunction can not be replaced with lambda by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6421) Unchecked reflection calls in PojoSerializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6420) Cleaner CEP API to specify conditions between events by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6418) Support for dynamic state changes in CEP patterns by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Idempotent Job Submission by James Bucher

by Till Rohrmann

[jira] [Created] (FLINK-6417) Wildcard support for read text file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6415) Make sure Flink artifacts have no specific logger dependency by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6414) Use scala.binary.version in place of change-scala-version.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6413) Add stream operator callback to notify about consumed network buffer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6412) Stream has already been closed durign job cancel by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6411) YarnApplicationMasterRunner should not interfere with RunningJobsRegistry by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

question about rowtime processfunction - are watermarks needed? by Radu Tudoran

by Fabian Hueske-2

[jira] [Created] (FLINK-6410) build fails after changing Scala to 2.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 561562563564565566567 ... 781