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

Topics (27217)

Replies

Last Post

Views

[jira] [Created] (FLINK-22687) unified the org.apache.flink.runtime.jobmaster.slotpool.SlotPool and org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPool by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22685) Write data to hive table in batch mode throws FileNotFoundException. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22684) Add the ability to ignore in-flight data on recovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22682) Checkpoint interval too large for higher DOP by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22681) how can i get flink job status from prometheus(PrometheusPushGateway) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22680) An IndexOutOfBoundsException is thrown out after apply WatermarkAssignerChangelogNormalizeTransposeRule by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22679) code optimization：Transformation.equals by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Help. Who can add permission in FLIP. by wangwj

by Robert Metzger

[jira] [Created] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22676) The partition tracker should support remote shuffle properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22675) Add an interface method ShuffleMaster#close by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22673) Add document about add jar related commands by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22672) Some enhancements for pluggable shuffle service framework by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22671) xxx by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22670) Initial HybridSource DataStream Implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22669) Support date format in a path when use filesytem as source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22668) FLIP-150: Introduce Hybrid Source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22667) Fix the wrong file system ln java doc and documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22666) Add more test cases for brigding to Scala DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22665) Add a Flink BigQuery Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22664) Task metrics are not properly unregistered during region failover by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22661) HiveInputFormatPartitionReader can return invalid data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22660) Incorrect flink documentation example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22658) Remove Deprecated util class TableConnectorUtil by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22657) HiveParserDDLSemanticAnalyzer can directly return operations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22656) Fix spelling mistakes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22655) When using -i <init.sql> option to initialize SQL Client session It should be possible to annotate the script with -- by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 19202122232425 ... 778