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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15122) Reusing record object in StreamTaskNetworkInput by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Multi-topics consuming from KafkaTableSource by leo

by Rong Rong

[jira] [Created] (FLINK-15121) Add public constructor/getter for execution environments that takes Configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15120) Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15119) Remove PlanExecutor and its subclasses by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15118) Make flink-scala-shell use Executors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15117) JoinITCase.testFullJoinWithLeftLocalPred fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15116) Make JobClient stateless, remove AutoCloseable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15115) Drop Kafka 0.8/0.9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15114) Add execute result info for alter/create/drop database in sql client. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15113) fs.azure.account.key not hidden from global configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15112) NPE when trying to join on two temporal tables in a single query by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15111) java.lang.RuntimeException for KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPartitionDiscoverer.java:80) when using SASL_SSL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15110) Support exclusions for variables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15109) InternalTimerServiceImpl references restored state after use, taking up resources unnecessarily by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15108) SQL-CLI can not execute same query multiple times by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15107) SQL-CLI can not execute insert into statement with lowercase "INSERT INTO" keyword by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15106) Hive 3.x tests leave metastore_db folder under build directory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15104) Performance regression on 4.12.2019 in RocksDB benchmarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15102) Allow users to construct a DataStream from a new Source API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15101) Add the interface for SpiltEnumerator and implementation for SourceCoordinator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15100) Add the interface and base implementation for SourceReader. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15099) Implement OperatorEvent passing RPC. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15098) CsvTableSink has no properties of a OVERWRITE mode to write, but the exception hint the user use it when a file or directory already exists by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15097) flink can not use user specified hdfs conf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15096) Do not use GlobalJobParameters to pass system configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15095) bridge table schema's primary key to metadata handler in blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15094) Warning about using private constructor of java.nio.DirectByteBuffer in Java 11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15093) FLINK-13708 still exist in StreamExecutionEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-15092) Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT] [VOTE] FLIP-88: PyFlink User-Defined Function Resource Management by Dian Fu-2

by Dian Fu-2

[jira] [Created] (FLINK-15091) JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 266267268269270271272 ... 778