(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 ... 637638639640641642643 ... 925

Topics (32346)

Replies

Last Post

Views

[jira] [Created] (FLINK-8556) Add proxy usage to Kinesis Connector to acces its endpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8555) Fix TableFunction varargs length exceeds 254 for SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8554) Upgrade AWS SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8553) switch flink-metrics-datadog to async mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8552) CliFrontend don't exit normal after job has been submitted with 'bin/flink run some_jar_ball' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8551) Should BIGINT in Flink SQL will be enchance to by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8550) Iterate over entryset instead of keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8548) Add Streaming State Machine Example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8545) Implement upsert stream table source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8541) Mesos RM should recover from failover timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kinesis consumer shard skew - FLINK-8516 by Thomas Weise

by Thomas Weise

[jira] [Created] (FLINK-8540) FileStateHandles must not attempt to delete their parent directory. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8539) Introduce "CompletedCheckpointStorageLocation" to explicitly handle disposal of checkpoint storage locations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8538) Add a Kafka table source factory with JSON format support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8535) Implement a basic set of table source factories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration. Will cause Caused by: java.io.FileNotFoundException release file error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8532) RebalancePartitioner should use Random value for its first partition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8530) Enable detached job submission for RestClusterClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8529) Let Yarn entry points use YarnConfigOptions#APPLICATION_MASTER_PORT by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8528) Bucket MapState of TimeBoundedStreamJoinOperator for improved performance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8527) Making stopping of Flip-6 components non-blocking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8526) When use some parallelism, the program will stuck in some setting. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8525) How to query state in flink 1.4.0? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8524) Incorrect JavaDoc in TypeExtractor.getBinaryOperatorReturnType by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 637638639640641642643 ... 925