flink-issues mailing list archives: March 2018

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
Truong Duc Kien (JIRA) [jira] [Created] (FLINK-8949) Rest API failure with long URL Thu, 15 Mar, 09:47
Truong Duc Kien (JIRA) [jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[] Thu, 15 Mar, 11:00
Truong Duc Kien (JIRA) [jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover Tue, 20 Mar, 01:59
Truong Duc Kien (JIRA) [jira] [Created] (FLINK-9052) Flink complains when scala.Option is used inside POJO Thu, 22 Mar, 04:23
Truong Duc Kien (JIRA) [jira] [Updated] (FLINK-9052) Flink complains when scala.Option is used inside POJO Thu, 22 Mar, 06:44
Truong Duc Kien (JIRA) [jira] [Commented] (FLINK-9052) Flink complains when scala.Option is used inside POJO Thu, 22 Mar, 06:48
Truong Duc Kien (JIRA) [jira] [Created] (FLINK-9070) Improve performance of RocksDBMapState.clear() Sun, 25 Mar, 07:23
Truong Duc Kien (JIRA) [jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear() Mon, 26 Mar, 08:38
Truong Duc Kien (JIRA) [jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear() Tue, 27 Mar, 13:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset Fri, 02 Mar, 06:48
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset Fri, 02 Mar, 06:49
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format Fri, 02 Mar, 06:52
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks Fri, 02 Mar, 06:52
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format Fri, 02 Mar, 06:52
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7913) Add support for Kafka default partitioner Fri, 02 Mar, 06:53
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers Fri, 02 Mar, 06:53
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner Fri, 02 Mar, 06:53
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks Fri, 02 Mar, 06:53
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers Fri, 02 Mar, 06:53
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector Fri, 02 Mar, 06:54
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector Fri, 02 Mar, 06:54
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-8191) Add a RoundRobinPartitioner to be shipped with the Kafka connector Fri, 02 Mar, 06:54
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 11:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 11:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 11:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 11:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 12:02
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 12:04
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers Fri, 02 Mar, 12:45
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions Wed, 07 Mar, 11:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions Wed, 07 Mar, 11:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8917) FlinkMiniCluster default createHighAvailabilityServices is not same as ClusterClient Mon, 12 Mar, 11:02
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-8202) Update queryable section on configuration page Mon, 12 Mar, 11:02
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414 Mon, 12 Mar, 15:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure Mon, 12 Mar, 15:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure Mon, 12 Mar, 15:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414 Mon, 12 Mar, 15:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7368) MetricStore makes cpu spin at 100% Mon, 12 Mar, 15:18
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh Mon, 12 Mar, 15:19
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7368) MetricStore makes cpu spin at 100% Mon, 12 Mar, 15:19
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh Mon, 12 Mar, 15:19
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled Mon, 12 Mar, 15:19
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled Mon, 12 Mar, 15:19
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer Mon, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x Mon, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x Mon, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x Mon, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7398) Table API operators/UDFs must not store Logger Mon, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7398) Table API operators/UDFs must not store Logger Mon, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy Mon, 12 Mar, 15:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer Mon, 12 Mar, 15:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy Mon, 12 Mar, 15:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader Mon, 12 Mar, 15:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader Mon, 12 Mar, 15:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7564) Fix Watermark semantics in Table API Mon, 12 Mar, 15:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Mon, 12 Mar, 15:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7563) Fix watermark semantics in CEP operators Mon, 12 Mar, 15:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7563) Fix watermark semantics in CEP operators Mon, 12 Mar, 15:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7564) Fix Watermark semantics in Table API Mon, 12 Mar, 15:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Mon, 12 Mar, 15:23
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels Mon, 12 Mar, 15:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7700) State merging in RocksDB backend leaves old state Mon, 12 Mar, 15:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist Mon, 12 Mar, 15:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist Mon, 12 Mar, 15:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7700) State merging in RocksDB backend leaves old state Mon, 12 Mar, 15:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels Mon, 12 Mar, 15:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled Mon, 12 Mar, 15:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled Mon, 12 Mar, 15:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle Mon, 12 Mar, 15:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle Mon, 12 Mar, 15:25
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7854) Reject lateral table outer joins with predicates in SQL Mon, 12 Mar, 15:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7854) Reject lateral table outer joins with predicates in SQL Mon, 12 Mar, 15:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7853) Reject table function outer joins with predicates in Table API Mon, 12 Mar, 15:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7853) Reject table function outer joins with predicates in Table API Mon, 12 Mar, 15:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions Mon, 12 Mar, 15:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7931) FlinkKinesisProducer violates at-least-once guarantees (1.3 branch) Mon, 12 Mar, 15:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7901) Detecting whether an operator is restored doesn't work with chained state (Flink 1.3) Mon, 12 Mar, 15:27
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore Mon, 12 Mar, 15:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore Mon, 12 Mar, 15:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE Mon, 12 Mar, 15:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Mon, 12 Mar, 15:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE Mon, 12 Mar, 15:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions Mon, 12 Mar, 15:28
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector Mon, 12 Mar, 15:29
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Mon, 12 Mar, 15:29
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7294) mesos.resourcemanager.framework.role not working Mon, 12 Mar, 15:29
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector Mon, 12 Mar, 15:29
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7294) mesos.resourcemanager.framework.role not working Mon, 12 Mar, 15:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code Mon, 12 Mar, 15:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code Mon, 12 Mar, 15:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7421) AvroRow(De)serializationSchema not serializable Mon, 12 Mar, 15:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7421) AvroRow(De)serializationSchema not serializable Mon, 12 Mar, 15:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7610) xerces lib conflict Mon, 12 Mar, 15:30
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7759) Fix Bug that fieldName with Boolean prefix can't be parsed by ExpressionParser. Mon, 12 Mar, 15:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7759) Fix Bug that fieldName with Boolean prefix can't be parsed by ExpressionParser. Mon, 12 Mar, 15:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource Mon, 12 Mar, 15:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource Mon, 12 Mar, 15:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-7990) Strange behavior when configuring Logback for logging Mon, 12 Mar, 15:32
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink Mon, 12 Mar, 15:33
Tzu-Li (Gordon) Tai (JIRA) [jira] [Closed] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink Mon, 12 Mar, 15:33
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
Box list
Jun 20197139
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300