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

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19957) flink-sql-connector-hive incompatible with cdh6 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19956) $ does not work on variables without being qualified in Scala by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19955) Document cross-version compatibility by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19954) Move execution deployment tracking logic from legacy EG code to SchedulerNG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19953) Translation in docs/ops/memory/mem_setup.zh.md by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19952) flink SecurityOptions.class use depracted method so mant times by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19951) PyFlink end-to-end test stuck in "Reading kafka messages" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19950) LookupJoin can not support view or subquery and so on. o by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Dependency injection and flink. by santhosh venkat

by Arvid Heise-3

[jira] [Created] (FLINK-19949) Unescape CSV format line delimiter character by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19948) CAST(now() as bigint) throws compile exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Could someone please take a look at mr PR, thanks by JiaTao Tao

by JiaTao Tao

[jira] [Created] (FLINK-19947) Support sink parallelism configuration to Print connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19946) Support sink parallelism configuration to Hbase connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19945) Support sink parallelism configuration to FileSystem connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19944) Support sink parallelism configuration to Hive connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19942) Support sink parallelism configuration to JDBC connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19941) Support sink parallelism configuration to Kafka connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19939) Remove redundant union from multiple input node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19938) Implement shuffle data read scheduling for sort-merge blocking shuffle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19937) Support sink parallelism for all connectors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19936) Make SinkITCase more stable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19935) OOM error occur for sql-client sumit job without JVM heap setting by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19933) Execute and collect with limit fails on bounded datastream jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19932) Add integration test for BATCH execution on DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19931) Do not emit intermediate results for reduce operation BATCH execution mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19930) Upgrade cassandra-driver-core to 4.X by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19929) Upgrade Kinesis dependencies to avoid protobuf 2.6.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19928) Introduce test configuration to detect instabilities better by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19926) Wrong results for join post tumble grouping by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 105106107108109110111 ... 778