(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 ... 503504505506507508509 ... 929

Topics (32484)

Replies

Last Post

Views

[jira] [Created] (FLINK-12631) Check if proper JAR file in JobWithJars by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12630) Refactor abstract InputGate to general interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

want to contribute to Apache Flink by katehenrison yang

by katehenrison yang

[jira] [Created] (FLINK-12629) Add integration test for scala shell in yarn mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12628) Check test failure if partition has no consumers in Execution.getPartitionMaxParallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12627) Document how to configure and use catalogs in SQL CLI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12626) Client should not register table-source-sink twice in TableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12625) Improve SQL Client to work with Catalog APIs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12624) Make Flink case-insensitive to meta object names by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

want to contribute to Apache Flink by ruiyin chen

by ruiyin chen

[jira] [Created] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12622) The process function compiles error in MyProcessWindowFunction in windows.md by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12621) Use MiniCluster instead of JobExecutor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12620) Deadlock in task deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12618) jdk.tools exclusion interfering with swift-fs-hadoop build by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12617) StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12616) Maintain connection between JM<->TM until all partitions have been released by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12615) Track allocated partitions on the JM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] Add JobListener (hook) in flink job lifecycle by Jeff Zhang

by Chesnay Schepler-3

[jira] [Created] (FLINK-12614) Refactor YARN tests to not do assertion in @After methods by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12613) Move SinkFunction to flink-core by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12612) Track stored paritions on the TM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12611) Make time indicator nullable in blink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12610) Introduce planner rules about aggregate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12609) Align the data types of Python with Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12608) Add getVertexOrThrow(ExecutionVertexID) to SchedulingTopology by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12606) Move SourceFunction to flink-core by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12605) Describe new contribution process by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12604) Register TableSource/Sink as CatalogTable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12603) Remove getOwningTaskName method from InputGate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Correct the flink pom `artifactId` config before flink 1.9 release by jincheng sun

by jincheng sun

[jira] [Created] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12601) Register DataStream/DataSet as DataStream/SetTableOperations in Catalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 503504505506507508509 ... 929