flink-issues mailing list archives: January 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
greghogan [GitHub] flink pull request #5279: [hotfix] [build] Print cache info Wed, 10 Jan, 19:53
Greg Hogan (JIRA) [jira] [Commented] (FLINK-8403) Flink Gelly examples hanging without returning result Wed, 10 Jan, 20:30
greghogan [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Wed, 10 Jan, 20:56
greghogan [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Wed, 10 Jan, 20:56
greghogan [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Wed, 10 Jan, 20:56
greghogan [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Wed, 10 Jan, 20:56
greghogan [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Wed, 10 Jan, 20:56
greghogan [GitHub] flink pull request #5277: [hotfix][docs]Review to reduce passive voice, impr... Wed, 10 Jan, 20:56
xiatao123 [GitHub] flink issue #4150: [FLINK-6951] Incompatible versions of httpcomponents jars... Wed, 10 Jan, 21:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector Wed, 10 Jan, 21:02
xiatao123 [GitHub] flink issue #4150: [FLINK-6951] Incompatible versions of httpcomponents jars... Wed, 10 Jan, 21:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector Wed, 10 Jan, 21:46
greghogan [GitHub] flink issue #5262: [FLINK-8082][build] Bump flink version for japicmp plugin Wed, 10 Jan, 22:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8082) Bump version compatibility check to 1.4 Wed, 10 Jan, 22:20
Elias Levy (JIRA) [jira] [Commented] (FLINK-5627) Allow job specific externalized checkpoint dir Wed, 10 Jan, 22:23
Eron Wright (JIRA) [jira] [Commented] (FLINK-7883) Stop fetching source before a cancel with savepoint Thu, 11 Jan, 00:41
Eron Wright (JIRA) [jira] [Comment Edited] (FLINK-7883) Stop fetching source before a cancel with savepoint Thu, 11 Jan, 00:46
tzulitai [GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil... Thu, 11 Jan, 01:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric Thu, 11 Jan, 01:03
tzulitai [GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil... Thu, 11 Jan, 01:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric Thu, 11 Jan, 01:04
casidiablo [GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil... Thu, 11 Jan, 01:04
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric Thu, 11 Jan, 01:05
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set Thu, 11 Jan, 01:33
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer Thu, 11 Jan, 01:42
tzulitai [GitHub] flink issue #5214: [FLINK-8324] [kafka] Expose another offsets metrics by us... Thu, 11 Jan, 01:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables Thu, 11 Jan, 01:46
zhijiangW [GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom... Thu, 11 Jan, 02:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based Thu, 11 Jan, 02:09
zhijiangW [GitHub] flink pull request #4552: [FLINK-7456][network] Implement Netty sender incom... Thu, 11 Jan, 02:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based Thu, 11 Jan, 02:10
bowenli86 [GitHub] flink issue #4150: [FLINK-6951] Incompatible versions of httpcomponents jars... Thu, 11 Jan, 02:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector Thu, 11 Jan, 02:54
Raymond Tay (JIRA) [jira] [Commented] (FLINK-8327) ClassLoader resolution of child-first does not appear to work Thu, 11 Jan, 03:34
Raymond Tay (JIRA) [jira] [Comment Edited] (FLINK-8327) ClassLoader resolution of child-first does not appear to work Thu, 11 Jan, 03:35
Raymond Tay (JIRA) [jira] [Resolved] (FLINK-8327) ClassLoader resolution of child-first does not appear to work Thu, 11 Jan, 03:35
maqingxiang [GitHub] flink pull request #5280: Fix typo in AbstractMetricGroup.java Thu, 11 Jan, 05:47
dawidwys [GitHub] flink pull request #4587: [FLINK-7511] [cep] Remove dead code after dropping... Thu, 11 Jan, 08:05
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7511) Remove dead code after dropping backward compatibility with <=1.2 Thu, 11 Jan, 08:06
Fabian Hueske (JIRA) [jira] [Commented] (FLINK-8405) Keyed State in broadcasted data steam. Thu, 11 Jan, 08:21
tillrohrmann [GitHub] flink issue #4924: [FLINK-7949] AsyncWaitOperator is not restarting when que... Thu, 11 Jan, 08:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full Thu, 11 Jan, 08:22
Marek Barak (JIRA) [jira] [Commented] (FLINK-8405) Keyed State in broadcasted data steam. Thu, 11 Jan, 08:28
Marek Barak (JIRA) [jira] [Closed] (FLINK-8405) Keyed State in broadcasted data steam. Thu, 11 Jan, 08:29
Marek Barak (JIRA) [jira] [Comment Edited] (FLINK-8405) Keyed State in broadcasted data steam. Thu, 11 Jan, 08:29
kl0u [GitHub] flink pull request #4587: [FLINK-7511] [cep] Remove dead code after dropping... Thu, 11 Jan, 08:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7511) Remove dead code after dropping backward compatibility with <=1.2 Thu, 11 Jan, 09:00
Bowen Li (JIRA) [jira] [Created] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() Thu, 11 Jan, 09:00
flora karniav (JIRA) [jira] [Commented] (FLINK-8403) Flink Gelly examples hanging without returning result Thu, 11 Jan, 09:00
flora karniav (JIRA) [jira] [Closed] (FLINK-8403) Flink Gelly examples hanging without returning result Thu, 11 Jan, 09:02
Bowen Li (JIRA) [jira] [Updated] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() Thu, 11 Jan, 09:02
Bowen Li (JIRA) [jira] [Assigned] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() Thu, 11 Jan, 09:02
Bowen Li (JIRA) [jira] [Updated] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() Thu, 11 Jan, 09:05
StefanRRichter [GitHub] flink issue #5248: [FLINK-5823] [checkpoints] State backends now also handle... Thu, 11 Jan, 09:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Thu, 11 Jan, 09:12
bowenli86 [GitHub] flink pull request #5281: [FLINK-7938] support addAll() in ListState Thu, 11 Jan, 09:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7938) support addAll() in ListState Thu, 11 Jan, 09:14
Timo Walther (JIRA) [jira] [Resolved] (FLINK-8400) Use the lexicographic smallest attribute as the common group id when extract unique key Thu, 11 Jan, 09:33
asfgit [GitHub] flink pull request #5273: [FLINK-8400] [table] Use the lexicographic smalles... Thu, 11 Jan, 09:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8400) Use the lexicographic smallest attribute as the common group id when extract unique key Thu, 11 Jan, 09:34
kl0u [GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc... Thu, 11 Jan, 09:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast. Thu, 11 Jan, 09:44
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() Thu, 11 Jan, 09:46
Stefan Richter (JIRA) [jira] [Comment Edited] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() Thu, 11 Jan, 09:47
pnowojski [GitHub] flink pull request #4587: [FLINK-7511] [cep] Remove dead code after dropping... Thu, 11 Jan, 10:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7511) Remove dead code after dropping backward compatibility with <=1.2 Thu, 11 Jan, 10:01
Timo Walther (JIRA) [jira] [Created] (FLINK-8412) Show outdated warning for 1.3 docs Thu, 11 Jan, 10:56
suganya (JIRA) [jira] [Created] (FLINK-8413) Checkpointing in flink doesnt maintain the snapshot state Thu, 11 Jan, 11:15
asfgit [GitHub] flink pull request #5184: [FLINK-8234][flip6] Cache JobExecutionResult in Di... Thu, 11 Jan, 11:20
asfgit [GitHub] flink pull request #4924: [FLINK-7949] AsyncWaitOperator is not restarting w... Thu, 11 Jan, 11:20
asfgit [GitHub] flink pull request #5278: [FLINK-8404] [tests] Mark Flip-6 tests with Flip6 ... Thu, 11 Jan, 11:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8404) Mark Flip-6 tests with Flip6 annotation Thu, 11 Jan, 11:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full Thu, 11 Jan, 11:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners Thu, 11 Jan, 11:21
Till Rohrmann (JIRA) [jira] [Resolved] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full Thu, 11 Jan, 11:23
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-8404) Mark Flip-6 tests with Flip6 annotation Thu, 11 Jan, 11:24
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners Thu, 11 Jan, 11:24
Timo Walther (JIRA) [jira] [Resolved] (FLINK-8412) Show outdated warning for 1.3 docs Thu, 11 Jan, 12:05
tzulitai [GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config... Thu, 11 Jan, 12:06
tzulitai [GitHub] flink issue #5282: [FLINK-6352] [kafka] Timestamp-based offset configuration... Thu, 11 Jan, 12:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset Thu, 11 Jan, 12:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset Thu, 11 Jan, 12:07
tzulitai [GitHub] flink issue #3915: [FLINK-6352] Support to use timestamp to set the initial ... Thu, 11 Jan, 12:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset Thu, 11 Jan, 12:15
GJL [GitHub] flink pull request #5194: [FLINK-8233][flip6] Add JobExecutionResultHandler Thu, 11 Jan, 12:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8233) Expose JobExecutionResult via HTTP Thu, 11 Jan, 12:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8406) BucketingSink does not detect hadoop file systems Thu, 11 Jan, 12:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8371) Buffers are not recycled in a non-spilled SpillableSubpartition upon release Thu, 11 Jan, 12:24
suganya (JIRA) [jira] [Updated] (FLINK-8413) Snapshot state of aggregated data is not maintained in flink's checkpointing Thu, 11 Jan, 12:25
suganya (JIRA) [jira] [Updated] (FLINK-8413) Snapshote state of aggregated data is not maintained in flink's checkpointing Thu, 11 Jan, 12:25
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing Thu, 11 Jan, 12:26
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default Thu, 11 Jan, 12:26
tillrohrmann [GitHub] flink pull request #5224: [FLINK-8338] [flip6] Make CustomCommandLines non s... Thu, 11 Jan, 12:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8338) Make CustomCommandLines non static in CliFrontend Thu, 11 Jan, 12:41
elbaulp [GitHub] flink pull request #5283: Fixed doc typo in DataStream API Thu, 11 Jan, 12:52
tillrohrmann [GitHub] flink issue #5224: [FLINK-8338] [flip6] Make CustomCommandLines non static i... Thu, 11 Jan, 12:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8338) Make CustomCommandLines non static in CliFrontend Thu, 11 Jan, 12:58
tillrohrmann [GitHub] flink pull request #5194: [FLINK-8233][flip6] Add JobExecutionResultHandler Thu, 11 Jan, 12:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8233) Expose JobExecutionResult via HTTP Thu, 11 Jan, 12:59
tillrohrmann [GitHub] flink pull request #: Thu, 11 Jan, 13:14
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 20194642
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