(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 ... 201202203204205206207 ... 778

Topics (27204)

Replies

Last Post

Views

[jira] [Created] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17082) Remove mocking from SQL client tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL by Jark Wu-2

by Jark Wu-2

[jira] [Created] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17080) Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17076) Revamp Kafka Connector Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17075) Add task status reconciliation between TM and JM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Configuring autolinks to Flink JIRA ticket in github repos by Yun Tang

by Till Rohrmann

[DISCUSS] FLIP-111: Docker image unification by Andrey Zagrebin-4

by Ismaël Mejía

[jira] [Created] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17073) Slow checkpoint cleanup causing OOMs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17072) Let Dispatcher and ResourceManager pick random endpoint id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

contributor apply by zhangzhanhua

by Timo Walther-2

[ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released by Tzu-Li (Gordon) Tai

by Zhijiang(wangzhijian...

[jira] [Created] (FLINK-17071) Kubernetes session CLI logging output is either misleading or concerning by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17070) Kubernetes session CLI ignores stop/help command in detached mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17069) DefaultClusterClientServiceLoader should provide more information in case of missing dependencies by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17067) CatalogManager#createTable and createTemporaryTable should provide consistent semantics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17066) Limits the PyArrow version to 0.13 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17065) Adds notes of Python versions supported by PyFlink in doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17064) Improve ExpressionConverter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17063) Make null typ be a possible result of a type inference by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17062) Fix the conversion from Java row type to Python row type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17061) Unset process/flink memory size from configuration once dynamic worker resource is activated. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS]FLIP-113: Support SQL and planner hints by Danny Chan

by Danny Chan-2

[jira] [Created] (FLINK-17060) "{flink}" isn't being replaced by the Apache Flink trademark in Stateful Functions docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17058) Adding TimeoutTrigger support nested triggers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17057) Add OpenSSL micro-benchmarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17056) JMH main() methods call unrelated benchmarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 201202203204205206207 ... 778