(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 ... 644645646647648649650 ... 781

Topics (27324)

Replies

Last Post

Views

[jira] [Created] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Issue] Unable to pass VM arguments by Vinay Patil

by Ufuk Celebi-2

[jira] [Created] (FLINK-4016) FoldApplyWindowFunction is not properly initialized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and Local、 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Kafka Consumer throwing Null Pointer Exception by Akshay Thaka Shingot...

by Aljoscha Krettek-2

[jira] [Created] (FLINK-4012) Docs: Links to "Iterations" are broken (404) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4011) Unable to access completed job in web frontend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Build Issues Solved by Stephan Ewen

by mxm

[jira] [Created] (FLINK-4010) Scala Shell tests may fail because of a locked STDIN by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4009) Scala Shell fails to find library for inclusion in test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4007) Flink Kafka Consumer throws Null Pointer Exception when using DataStream keyBy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4003) Use intrinsics for MathUtils logarithms by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Client communication and akka.framesize by Felix Schüler

by mxm

HA Cluster restart behaviour by Gyula Fóra

by mxm

[jira] [Created] (FLINK-4002) [py] Improve testing infraestructure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4001) Add event time support to filesystem connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

baseurl not overridden in documentation's Jekyll serve for local previewing by Tzu-Li Tai

by Tzu-Li Tai

[jira] [Created] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3999) Rename the `running` flag in the drivers to `canceled` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

PojoComparator question by Gábor Horváth

by Stephan Ewen

[jira] [Created] (FLINK-3997) PRNG Skip-ahead by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Collision of task number values for the same task by aalexandrov

by aalexandrov

[jira] [Created] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 644645646647648649650 ... 781