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

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-19158) Revisit java e2e download timeouts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16595) Support extra hadoop filesystem URLs for which to request delegation tokens by Shang Yuanchun (Jira...

by Husky Zeng

[jira] [Created] (FLINK-19157) Jdbc PhoenixDialect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19156) Migration of transactionIdHint in Kafka is never applied by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19154) Always clean up HA data when application completion by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19155) ResultPartitionTest is unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19153) FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API) by Aljoscha Krettek-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-19152) Remove Kafka 0.10.x and 0.11.x connectors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19150) Behaviour change after migration from 1.9 to 1.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19149) Compacted Kafka Topic can be interpreted as Changelog Stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19148) Table crashed in Flink Table API & SQL Docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19147) Support AutoClose in CliClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19146) createMiniBatchTrigger() use OR ，table.exec.mini-batch.size and table.exec.mini-batch.allow-latency by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19145) Add PyFlink-walkthrough in Flink playground. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

退订dev by 高丽丽

by Xingbo Huang

[jira] [Created] (FLINK-19144) Error when writing to partitioned table with s3 FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19143) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots failed to submit JobGraph: "Connection refused: localhost/127.0.0.1:8081" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLINK-19089: improvement of ClosableBlockingQueue by dugenkui

by dugenkui

Apply for contributor permissions by jun su

by jun su

[jira] [Created] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19141) Flink Job Submitted on Yarn Does not Work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19140) Join with Table Function (UDTF) SQL example is incorrect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19139) flink-conf.yml read values from environment variables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-138: Declarative Resource management by Chesnay Schepler-3

by Zhu Zhu

[jira] [Created] (FLINK-19138) Python UDF supports directly specifying input_types as DataTypes.ROW by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19137) Bump Apache Parquet to 1.11.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

HadoopOutputFormat has issues with LocalExecutionEnvironment? by Ken Krugler

by Ken Krugler

[jira] [Created] (FLINK-19134) Fix the converter of array coder for Python DataStream API. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Bug: Kafka producer always writes to partition 0, because KafkaSerializationSchemaWrapper does not call open() method of FlinkKafkaPartitioner by DONG, Weike

by dwysakowicz

[jira] [Created] (FLINK-19133) User provided partitioners are not initialized correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API by Wei Zhong-2

by Wei Zhong-2

1 ... 131132133134135136137 ... 778