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
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main Sat, 27 Jan, 13:30
yew1eb [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Sat, 27 Jan, 13:48
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Sat, 27 Jan, 13:49
Ted Yu (JIRA) [jira] [Updated] (FLINK-8415) Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() Sat, 27 Jan, 22:26
Ted Yu (JIRA) [jira] [Updated] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown Sat, 27 Jan, 22:26
zentol [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Sun, 28 Jan, 07:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Sun, 28 Jan, 07:03
Gary Yao (JIRA) [jira] [Commented] (FLINK-8434) The new yarn resource manager should take over the running task managers after failover Sun, 28 Jan, 12:06
pluppens [GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co... Sun, 28 Jan, 15:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart Sun, 28 Jan, 15:39
jelmerk [GitHub] flink pull request #5376: [FLINK-6214] WindowAssigners do not allow negative... Sun, 28 Jan, 22:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6214) WindowAssigners do not allow negative offsets Sun, 28 Jan, 22:39
Jelmer Kuperus (JIRA) [jira] [Commented] (FLINK-6214) WindowAssigners do not allow negative offsets Sun, 28 Jan, 22:40
Jelmer Kuperus (JIRA) [jira] [Issue Comment Deleted] (FLINK-6214) WindowAssigners do not allow negative offsets Sun, 28 Jan, 22:41
bowenli86 [GitHub] flink issue #5365: [FLINK-8515] update RocksDBMapState to replace deprecated... Mon, 29 Jan, 01:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8515) update RocksDBMapState to replace deprecated remove() with delete() Mon, 29 Jan, 01:04
yew1eb [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Mon, 29 Jan, 06:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Mon, 29 Jan, 06:12
kl0u [GitHub] flink issue #5230: [FLINK-8345] Add iterator of keyed state on broadcast sid... Mon, 29 Jan, 08:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast. Mon, 29 Jan, 08:02
florianschmidt1994 [GitHub] flink issue #5342: [FLINK-8479] Timebounded stream join Mon, 29 Jan, 08:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator Mon, 29 Jan, 08:14
yanxiaobin (JIRA) [jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions Mon, 29 Jan, 09:14
zentol [GitHub] flink issue #5351: [FLINK-6623][Blob] BlobServer#putBuffer moves file after ... Mon, 29 Jan, 09:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6623) BlobCacheSuccessTest fails on Windows Mon, 29 Jan, 09:59
Till Rohrmann (JIRA) [jira] [Created] (FLINK-8520) CassandraConnectorITCase.testCassandraTableSink unstable on Travis Mon, 29 Jan, 10:22
asfgit [GitHub] flink pull request #5358: [hotfix][StreamingJobGraphGenerator] modify the cl... Mon, 29 Jan, 10:24
asfgit [GitHub] flink pull request #5366: [hotfix] improve javadoc and logging of RocksDBKey... Mon, 29 Jan, 10:24
tillrohrmann [GitHub] flink issue #5321: [FLINK-8465] [flip6] Retrieve correct leader component ad... Mon, 29 Jan, 10:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8465) Retrieve correct leader component address in ClusterClient Mon, 29 Jan, 10:28
tzulitai [GitHub] flink issue #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ (Transp... Mon, 29 Jan, 10:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support Mon, 29 Jan, 10:37
tzulitai [GitHub] flink issue #4675: [FLINK-7386] FIx Elasticsearch 5 connector is not compati... Mon, 29 Jan, 10:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client Mon, 29 Jan, 10:38
zentol [GitHub] flink pull request #5377: [FLINK-8494][config] Migrate CC#DEFAULT_PARALLELIS... Mon, 29 Jan, 10:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Mon, 29 Jan, 10:40
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-8489) Data is not emitted by second ElasticSearch connector Mon, 29 Jan, 10:47
zentol [GitHub] flink pull request #5378: [FLINK-8489][ES] Prevent side-effects when modifyi... Mon, 29 Jan, 10:55
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Mon, 29 Jan, 10:56
zentol [GitHub] flink issue #5332: [FLINK-6464][streaming] Stabilize default window operator... Mon, 29 Jan, 10:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6464) Metric name is not stable Mon, 29 Jan, 10:57
zentol [GitHub] flink issue #5338: [FLINK-8476][config][HA] Deprecate HA config constants Mon, 29 Jan, 11:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8476) ConfigConstants#DEFAULT_HA_JOB_MANAGER_PORT unused Mon, 29 Jan, 11:01
zentol [GitHub] flink issue #5299: [Hotfix][Doc][DataStream API] Fix Scala code example in C... Mon, 29 Jan, 11:07
asfgit [GitHub] flink pull request #5299: [Hotfix][Doc][DataStream API] Fix Scala code examp... Mon, 29 Jan, 11:09
zentol [GitHub] flink pull request #: Mon, 29 Jan, 11:15
zentol [GitHub] flink pull request #5268: [FLINK-8398] [kinesis, tests] Harden KinesisDataFe... Mon, 29 Jan, 11:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests Mon, 29 Jan, 11:17
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-7760) Restore failing from external checkpointing metadata. Mon, 29 Jan, 11:20
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP. Mon, 29 Jan, 11:21
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() Mon, 29 Jan, 11:21
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. Mon, 29 Jan, 11:21
Shashank Agarwal (JIRA) [jira] [Comment Edited] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP. Mon, 29 Jan, 11:23
cjolif [GitHub] flink issue #4675: [FLINK-7386] FIx Elasticsearch 5 connector is not compati... Mon, 29 Jan, 11:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client Mon, 29 Jan, 11:29
cjolif [GitHub] flink issue #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ (Transp... Mon, 29 Jan, 11:30
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support Mon, 29 Jan, 11:31
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP. Mon, 29 Jan, 11:32
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-7521) Remove the 10MB limit from the current REST implementation. Mon, 29 Jan, 11:34
zentol [GitHub] flink issue #5262: [FLINK-8082][build] Bump flink version for japicmp plugin Mon, 29 Jan, 11:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8082) Bump version compatibility check to 1.4 Mon, 29 Jan, 11:46
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-8130) Javadocs link for snapshot release is not correct Mon, 29 Jan, 11:47
StephanEwen [GitHub] flink issue #5378: [FLINK-8489][ES] Prevent side-effects when modifying user... Mon, 29 Jan, 11:51
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Mon, 29 Jan, 11:52
StephanEwen [GitHub] flink issue #5377: [FLINK-8494][config] Migrate CC#DEFAULT_PARALLELISM_KEY Mon, 29 Jan, 11:52
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Mon, 29 Jan, 11:53
StephanEwen [GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting... Mon, 29 Jan, 11:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Mon, 29 Jan, 11:55
zhangminglei [GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting... Mon, 29 Jan, 11:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Mon, 29 Jan, 12:00
zentol [GitHub] flink issue #5378: [FLINK-8489][ES] Prevent side-effects when modifying user... Mon, 29 Jan, 12:00
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Mon, 29 Jan, 12:01
mingleizhang (JIRA) [jira] [Updated] (FLINK-8357) enable rolling in default log settings Mon, 29 Jan, 12:06
zentol [GitHub] flink pull request #5379: [FLINK-8130][docs] Fix snapshot javadoc link Mon, 29 Jan, 12:32
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8130) Javadocs link for snapshot release is not correct Mon, 29 Jan, 12:33
zentol [GitHub] flink issue #5377: [FLINK-8494][config] Migrate CC#DEFAULT_PARALLELISM_KEY Mon, 29 Jan, 12:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8494) Migrate CC#DEFAULT_PARALLELISM_KEY Mon, 29 Jan, 12:34
zentol [GitHub] flink issue #5378: [FLINK-8489][ES] Prevent side-effects when modifying user... Mon, 29 Jan, 12:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Mon, 29 Jan, 12:51
mingleizhang (JIRA) [jira] [Commented] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout Mon, 29 Jan, 12:52
patricklucas [GitHub] flink pull request #5380: [hotfix][connectors] Fix log format strings Mon, 29 Jan, 13:30
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-4874) Document how to enable Flink web interface in local execution Mon, 29 Jan, 13:35
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv Mon, 29 Jan, 13:41
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8047) Create HTTP Sink Mon, 29 Jan, 13:41
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources Mon, 29 Jan, 13:42
tzulitai [GitHub] flink issue #5380: [hotfix][connectors] Fix log format strings Mon, 29 Jan, 13:44
tzulitai [GitHub] flink issue #5378: [FLINK-8489][ES] Prevent side-effects when modifying user... Mon, 29 Jan, 13:49
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector Mon, 29 Jan, 13:50
StefanRRichter [GitHub] flink issue #5365: [FLINK-8515] update RocksDBMapState to replace deprecated... Mon, 29 Jan, 13:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8515) update RocksDBMapState to replace deprecated remove() with delete() Mon, 29 Jan, 13:54
StefanRRichter [GitHub] flink issue #5356: [FLINK-8364][state backend] Add iterator() to ListState w... Mon, 29 Jan, 13:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value Mon, 29 Jan, 13:59
fhueske [GitHub] flink issue #5356: [FLINK-8364][state backend] Add iterator() to ListState w... Mon, 29 Jan, 14:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value Mon, 29 Jan, 14:08
GJL [GitHub] flink pull request #5354: [FLINK-8505] [flip6] Prevent SlotManager from reac... Mon, 29 Jan, 14:08
GJL [GitHub] flink pull request #5354: [FLINK-8505] [flip6] Prevent SlotManager from reac... Mon, 29 Jan, 14:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8505) SlotManager can reach inconsistent state Mon, 29 Jan, 14:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8505) SlotManager can reach inconsistent state Mon, 29 Jan, 14:09
pnowojski [GitHub] flink issue #4649: [FLINK-6116] Watermarks don't work when unioning with sam... Mon, 29 Jan, 14:31
StefanRRichter [GitHub] flink issue #5356: [FLINK-8364][state backend] Add iterator() to ListState w... Mon, 29 Jan, 14:31
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
Jul 20198356
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