(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 ... 69707172737475 ... 785

Topics (27473)

Replies

Last Post

Views

[jira] [Created] (FLINK-21331) Optimize calculating tasks to restart in RestartPipelinedRegionFailoverStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21330) Optimization the initialization of PipelinedRegionSchedulingStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21328) Optimize the initialization of DefaultExecutionTopology by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21327) Support window TVF in batch mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21326) Optimize building topology when initializing ExecutionGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21324) statefun-testutil can't assert messages function sends to itself by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21323) Stop-with-savepoint is not supported by SourceOperatorStreamTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21322) Add ExecutionGraphHandler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21320) Stream from FlinkKafkaShuffle.persistentKeyBy does not end if upstream ends by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink 1.11.4 release? And usual plan for maintenance etc by Adam Roberts

by Chesnay Schepler-3

[jira] [Created] (FLINK-21319) hadoop-mapreduce jars are not loaded into classpath when submiting flink on yarn jobs. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21318) ExecutionContextTest.testCatalogs fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21316) E2E tests exceed 250 minutes. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Need help on Upsert-kafka connector with confluent schema registry by Shamit

by Shengkai Fang

[jira] [Created] (FLINK-21315) Support to set operator names in state processor API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21314) Airflow | by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21313) Support more log4j2's configuration syntax by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21312) SavepointITCase.testStopSavepointWithBoundedInputConcurrently is unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21311) flink1.12 cep pattern gets some problerm by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21310) unexpected behavior of DataFrame union by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Is development in FlinkML still active? by Badrul Chowdhury

by Badrul Chowdhury

[jira] [Created] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21308) Cancel "sendAfter" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21307) Revisit activation model of FlinkSecurityManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21305) Cumulative window should accumulate late events belonging to the cleaned slice by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21304) Support split distinct aggregate for window TVF based aggregate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21303) Maybe remove LogicalSlot#getPhysicalSlotNumber by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21302) Fix NPE when use row_number() in over agg by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21300) Support 'SHOW [FULL] MODULES' syntax by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 69707172737475 ... 785