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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-11834) Introduce flink logical relational nodes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11833) Cleanup unnecessary createKeyedStateBackend methods in StateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11832) Convert some InternalType property related functions to InternalType's method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11831) Separate CodeGeneratorContext for different generation targets by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11830) Introduce CodeGeneratorContext to maintain reusable statements for code generation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11829) [checkpoint] FsCheckpointStateOutputStream might store state in files even state size below fileStateThreshold by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11828) [HA] Test instability: ZooKeeperHADispatcherTest.testStandbyDispatcherJobRecovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11827) Introduce DataFormatConverters to convert internal data format and java format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] -- Need to be able to access multiple s3 buckets with different authentication from within a single job by Dave Brewster

by Stephan Ewen

[jira] [Created] (FLINK-11824) Event-time attribute cannot have same name as in original format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11823) TrySerializer#duplicate does not create a proper duplication by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11822) Introduce Flink metadata handler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11821) fix the error package location of KafkaDeserializationSchemaWrapper.java file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11820) KafkaDeserializationSchemaWrapper should filter record which value is null by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11819) Additional attribute for order by not support by flink sql, but told supported in doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11818) Provide pipe transformation function for DataSet API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11817) DataStream API Tutorial uses deprecated fold function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Introducing Builder in FlinkKafkaProducer by Александр

by Piotr Nowojski-3

[jira] [Created] (FLINK-11816) Changes of FLINK-11516 causes compilation failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11814) Changes of FLINK-11516 causes compilation failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11815) Support execution with static resources (Flip-6): E.g. spreading tasks across available set of TMs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11812) Composite etcd based HighAvailability components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Contributor permission by 张大伟

by Fabian Hueske-2

[jira] [Created] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11809) Implement etcd based StateHandleStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11806) Import shaded jetcd by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11805) A Common External Shuffle Service Framework by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Custom SourceFunction and SinkFunction by Siew Wai Yow

by Piotr Nowojski-3

[jira] [Created] (FLINK-11804) Make sure the CloseableRegistry used in backend builder is registered with task by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 380381382383384385386 ... 778