(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 ... 485486487488489490491 ... 783

Topics (27399)

Replies

Last Post

Views

Proposal - Change shard discovery in Flink Kinesis Connector to use ListShards by Kailash Dayanand

by mingleizhang

[jira] [Created] (FLINK-8895) Job failed when one kafka broker shutdown by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8894) CurrentJobIdsHandler fails to serialize response by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8893) NPE when netty try to allocate directBuffer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Flink 1.4.2 released by Tzu-Li (Gordon) Tai

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-8892) Travis Build: Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test (integration-tests) on project flink-tests_2.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8891) RestServerEndpoint can bind on local address only by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8890) Compare checkpoints in order in CompletedCheckpoint.checkpointsMatch() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8889) Do not override config values in TestBaseUtils#startCluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8886) Job isolation via scheduling in shared cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should tread ThreadDeath as fatal. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8882) flink-tests fails with core dump by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8881) Accumulators not updated for running jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8880) Validate configurations for SQL Client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8879) Add concurrent access check to AvroSerializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8878) Check for concurrent access to Kryo Serializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8877) Configure Kryo's log level based on Flink's log level by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8876) Improve concurrent access handling in stateful serializers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8875) Watermark tab on Web Interface should display low watermark in ISO8601 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8874) rewrite Flink docs/dev/stream/operators/process_function.md to recommend using KeyedProcessFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8873) move unit tests of KeyedStream.scala from DataStreamTest.scala to KeyedStreamTest.scala by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8872) Yarn detached mode via -yd does not detach by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8870) End-to-end tests wrongly pass if md5sum is not installed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8869) Kafka restore from checkpoint without react to the new add partition to kafka server by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8868) Support Table Function as Table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8865) Add CLI query code completion in SQL Client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8864) Add CLI query history by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8863) Add user-defined function support in SQL Client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 485486487488489490491 ... 783