flink-issues mailing list archives: March 2017

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 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · Next »Thread · Author · Date
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-6085) flink as micro service Thu, 23 Mar, 14:13
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-6129) MetricRegistry does not stop query actor Thu, 23 Mar, 14:14
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library Thu, 23 Mar, 14:17
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask Thu, 23 Mar, 14:25
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6179) Create SerialMainThreadValidatorUtil to support TestingSerialRpcService Fri, 24 Mar, 09:37
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-6179) Create SerialMainThreadValidatorUtil to support TestingSerialRpcService Fri, 24 Mar, 10:25
Till Rohrmann (JIRA) [jira] [Created] (FLINK-6180) Remove TestingSerialRpcService Fri, 24 Mar, 10:29
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error Fri, 24 Mar, 15:56
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask Mon, 27 Mar, 09:48
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library Mon, 27 Mar, 13:11
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask Mon, 27 Mar, 13:39
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask Tue, 28 Mar, 12:44
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-5903) taskmanager.numberOfTaskSlots and yarn.containers.vcores did not work well in YARN mode Fri, 31 Mar, 13:39
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5524) Support early out for code generated conjunctive conditions Thu, 02 Mar, 15:19
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5827) Exception when do filter after join a udtf which returns a POJO type Thu, 02 Mar, 15:34
Timo Walther (JIRA) [jira] [Created] (FLINK-5983) Replace for/foreach/map in aggregates by while loops Tue, 07 Mar, 14:50
Timo Walther (JIRA) [jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops Tue, 07 Mar, 15:36
Timo Walther (JIRA) [jira] [Created] (FLINK-5984) Allow reusing of accumulators in AggregateFunction Tue, 07 Mar, 15:43
Timo Walther (JIRA) [jira] [Created] (FLINK-5986) Add forwarded field annotations to batch (window) aggregate operators Tue, 07 Mar, 16:46
Timo Walther (JIRA) [jira] [Created] (FLINK-5994) Add Janino to flink-table JAR file Wed, 08 Mar, 09:48
Timo Walther (JIRA) [jira] [Updated] (FLINK-5994) Add Janino to flink-table JAR file Wed, 08 Mar, 09:49
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5722) Implement DISTINCT as dedicated operator Wed, 08 Mar, 13:16
Timo Walther (JIRA) [jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file Wed, 08 Mar, 13:34
Timo Walther (JIRA) [jira] [Updated] (FLINK-5177) Improve nullability handling Wed, 08 Mar, 15:05
Timo Walther (JIRA) [jira] [Assigned] (FLINK-5177) Improve nullability handling Wed, 08 Mar, 15:14
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5414) Bump up Calcite version to 1.11 Wed, 08 Mar, 15:32
Timo Walther (JIRA) [jira] [Commented] (FLINK-5047) Add sliding group-windows for batch tables Wed, 08 Mar, 16:06
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5983) Replace for/foreach/map in aggregates by while loops Wed, 08 Mar, 17:08
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5963) Remove preparation mapper of DataSetAggregate Thu, 09 Mar, 10:30
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5984) Add resetAccumulator method for AggregateFunction Thu, 09 Mar, 11:11
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5881) ScalarFunction(UDF) should support variable types and variable arguments Mon, 13 Mar, 09:36
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5882) TableFunction (UDTF) should support variable types and variable arguments Mon, 13 Mar, 15:07
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5826) UDF/UDTF should support variable types and variable arguments Mon, 13 Mar, 15:08
Timo Walther (JIRA) [jira] [Resolved] (FLINK-5441) Directly allow SQL queries on a Table Tue, 14 Mar, 08:18
Timo Walther (JIRA) [jira] [Commented] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed Wed, 22 Mar, 14:23
Timo Walther (JIRA) [jira] [Created] (FLINK-6168) Make flink-core independent of Avro Wed, 22 Mar, 15:38
Timo Walther (JIRA) [jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available Mon, 27 Mar, 08:50
Timo Walther (JIRA) [jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available Tue, 28 Mar, 08:04
Timo Walther (JIRA) [jira] [Updated] (FLINK-6214) WindowAssigners do not allow negative offsets Wed, 29 Mar, 15:15
Timo Walther (JIRA) [jira] [Created] (FLINK-6214) WindowAssigners do not allow negative offsets Wed, 29 Mar, 15:15
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Thu, 02 Mar, 06:15
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Thu, 02 Mar, 06:15
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Thu, 02 Mar, 06:23
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption Thu, 02 Mar, 06:32
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption Thu, 02 Mar, 06:32
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Thu, 02 Mar, 06:33
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Thu, 02 Mar, 06:33
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4422) Convert all time interval measurements to System.nanoTime() Thu, 02 Mar, 07:39
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Tue, 07 Mar, 07:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Tue, 07 Mar, 07:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-5991) Expose Broadcast Operator State through public APIs Wed, 08 Mar, 06:41
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5991) Expose Broadcast Operator State through public APIs Wed, 08 Mar, 06:42
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5991) Expose Broadcast Operator State through public APIs Wed, 08 Mar, 06:46
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5991) Expose Broadcast Operator State through public APIs Wed, 08 Mar, 06:55
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-3679) Allow Kafka consumer to skip corrupted messages Thu, 09 Mar, 06:12
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-5583) Support flexible error handling in the Kafka consumer Thu, 09 Mar, 06:13
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-3679) Allow Kafka consumer to skip corrupted messages Thu, 09 Mar, 06:15
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Thu, 09 Mar, 06:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages Thu, 09 Mar, 06:21
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 09 Mar, 12:16
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying Sat, 11 Mar, 10:59
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying Sat, 11 Mar, 10:59
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying Sat, 11 Mar, 11:00
Tzu-Li (Gordon) Tai (JIRA) [jira] [Assigned] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying Sun, 12 Mar, 15:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying Mon, 13 Mar, 15:55
Tzu-Li (Gordon) Tai (JIRA) [jira] [Assigned] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Mon, 13 Mar, 15:56
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer Mon, 13 Mar, 16:00
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6038) Add links to Apache Bahir Flink streaming connectors Tue, 14 Mar, 07:43
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations Tue, 14 Mar, 07:44
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations Tue, 14 Mar, 07:44
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations Tue, 14 Mar, 07:44
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-5949) Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods Tue, 14 Mar, 17:23
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs Tue, 14 Mar, 17:26
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5210) Failing performCheckpoint method causes task to fail Wed, 15 Mar, 09:41
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior Wed, 15 Mar, 09:46
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Wed, 15 Mar, 14:39
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-5701) FlinkKafkaProducer should check asyncException on checkpoints Wed, 15 Mar, 16:11
Tzu-Li (Gordon) Tai (JIRA) [jira] [Reopened] (FLINK-5701) FlinkKafkaProducer should check asyncException on checkpoints Wed, 15 Mar, 16:11
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior Thu, 16 Mar, 03:43
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior Thu, 16 Mar, 03:44
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior Thu, 16 Mar, 03:45
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-5701) FlinkKafkaProducer should check asyncException on checkpoints Thu, 16 Mar, 04:44
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer Sat, 18 Mar, 07:23
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer Sat, 18 Mar, 07:29
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer Sat, 18 Mar, 07:29
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer Sat, 18 Mar, 07:31
Tzu-Li (Gordon) Tai (JIRA) [jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer Sat, 18 Mar, 09:06
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6139) Documentation for building / preparing Flink for MapR Tue, 21 Mar, 05:54
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-6139) Documentation for building / preparing Flink for MapR Wed, 22 Mar, 15:00
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 13:17
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 13:22
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 13:24
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 14:16
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6177) Add support for "Distributed Cache" in streaming applications Fri, 24 Mar, 04:13
Tzu-Li (Gordon) Tai (JIRA) [jira] [Resolved] (FLINK-6018) Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() Fri, 24 Mar, 05:20
Tzu-Li (Gordon) Tai (JIRA) [jira] [Assigned] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis Fri, 24 Mar, 05:48
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis Fri, 24 Mar, 05:48
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis Fri, 24 Mar, 05:48
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Fri, 24 Mar, 06:10
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-6178) Allow upgrades to state serializers Fri, 24 Mar, 07:59
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 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · Next »Thread · Author · Date
Box list
Feb 20204480
Jan 20208835
Dec 201913015
Nov 201911280
Oct 201911647
Sep 20198451
Aug 201910193
Jul 201911502
Jun 20198159
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