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

Topics (27203)

Replies

Last Post

Views

Please submit talk proposals for the ApacheCons as soon as possilbe by Christofer Dutz

by Christofer Dutz

[jira] [Created] (FLINK-22292) Add documentation about state access in Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22291) Fix split switching in HiveInputFormatPartitionReader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Welcome to create Pulsar + Flink solutions at Pulsar Hackathon! by Dianjin Wang

by Dianjin Wang

[jira] [Created] (FLINK-22289) Update JDBC XA sink docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22288) Remove unnecesary argument from JdbcSink.exactlyOnceSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22286) Fix the state doesn't support custom python class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22285) org.apache.flink.yarn.YARNHighAvailabilityITCase Hang by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Using FileSystem SQL Connector to Commit Hive Partition Exception by chenzuoli

by Rui Li

[jira] [Created] (FLINK-22284) Null address will be logged when channel is closed in NettyPartitionRequestClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22283) GraphiteReporter Metrics named xxx alredy exists by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22281) flink sql by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Add checkpoint id in FLIP-27 source SplitEnumerator::snapshotState() by Zhou, Brian

by Zhou, Brian

[PSA] Documentation is currently not being updated by Chesnay Schepler-3

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-22280) Add XML output format for Flink Table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22278) Refactor sql client's DynamicResult by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22277) Refactor sql client's DynamicResult by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Update on Implementation of Flink Jira Process & Bot (go live today) by Konstantin Knauf-4

by Konstantin Knauf-3

[jira] [Created] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22274) SQL parser fails to parse group by statements with brackets in views by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22273) Add documentation for General Python Group Window Aggregation in Python Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Add jobId and JobName variable to JobManager metrics in per-job deployment mode by Lu Niu

by Till Rohrmann

[SURVEY] Remove Mesos support by Robert Metzger

by Matthias

[jira] [Created] (FLINK-22272) Some scenes can't drop table by hive catalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22270) Python test pipeline no output for 900 seconds by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running." by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithoutRestartsHelper fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 31323334353637 ... 778