Apache Flink Mailing List archive.

This forum is an archive for the mailing list dev@flink.apache.org (more options) Messages posted here will be sent to this mailing list.
This is a public archive of the Flink mailing mailing list.

More about the different Flink mailing lists: http://flink.apache.org/community.html#community
1234 ... 653
Topics (22825)
Replies Last Post Views
[DISCUSS] FLIP-143: Unified Sink API by Guowei Ma
45
by Aljoscha Krettek-2
[jira] [Created] (FLINK-19361) Create a synchronized metastore client to talk to a remote HMS by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19360) Flink fails if JAVA_HOME contains spaces by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19359) Restore from Checkpoint fails if checkpoint folders is corrupt/partial by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000 by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19357) Introduce createBucketWriter to BucketsBuilder by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19356) Introduce FileLifeCycleListener to Buckets by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19354) Add invalidateCache() method in CachedTable by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19355) Add close() method to TableEnvironment by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19352) Add cache() method to Table by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19353) BlinkPlanner translate and optimize CacheOperation by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19350) StreamingJobGraphGenerator generate job graph with cached node by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19351) StreamingJobGraphGenerator set the caching node to BoundedBlockingType by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19349) StreamGraph handle CacheSource and CacheSink by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19348) Introduce CacheSource and CacheSink by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19347) Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19346) Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19345) Introduce File streaming sink compaction by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[DISCUSS] Release flink-shaded 12.0 by Chesnay Schepler-3
1
by Robert Metzger
[jira] [Created] (FLINK-19344) DispatcherResourceCleanupTest#testJobSubmissionUnderSameJobId is unstable on Azure Pipeline by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
Does Flink support such a feature currently? by Roc Marshal
1
by Marta Paes Moreira
[jira] [Created] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23 by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19341) Update API module for FLIP-107 by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19340) AggregateITCase.testListAggWithDistinct failed with "expected:<List(1,A, 2,B, 3,C#A, 4,EF)> but was:<List(1,A, 2,B, 3,C#A, 4,EF#EF)>" by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[ANNOUNCE] Weekly Community Update 2020/38 by Konstantin Knauf-4
0
by Konstantin Knauf-4
[DISCUSS] FLIP-33: Standardize connector metrics by Becket Qin
39
by Konstantin Knauf-4
Kafka connection issues by Ramya Ramamurthy
0
by Ramya Ramamurthy
[jira] [Created] (FLINK-19339) Support Avro's unions with logical types by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19338) New source interface cannot unregister unregistered source by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
Automatically get udf's resource files from hdfs when running a job that uses hive-udf by Husky Zeng
1
by Jark Wu-2
[DISCUSS] FLIP-142: Disentangle StateBackends from Checkpointing by Seth Wiesman-4
27
by Yu Li
[jira] [Created] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name. by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19336) EncodingUtils#encodeObjectToString should propagate inner exception by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
[jira] [Created] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf by Xuannan Su (Jira)
0
by Xuannan Su (Jira)
1234 ... 653