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
Chesnay Schepler (JIRA) [jira] [Assigned] (FLINK-4767) Migrate JobManager configuration options Tue, 30 Jan, 15:22
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-4767) Migrate JobManager configuration options Tue, 30 Jan, 15:22
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-4765) Migrate ConfigConstants to ConfigOptions Tue, 30 Jan, 15:23
kl0u [GitHub] flink pull request #5342: [FLINK-8479] Timebounded stream join Tue, 30 Jan, 15:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator Tue, 30 Jan, 15:27
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8525) Improve queryable state code examples Tue, 30 Jan, 15:27
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-8525) Improve queryable state code examples Tue, 30 Jan, 15:35
aljoscha [GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric Tue, 30 Jan, 15:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Tue, 30 Jan, 15:37
aljoscha [GitHub] flink pull request #5161: [FLINK-7608][metric] Refactor latency statistics m... Tue, 30 Jan, 15:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric Tue, 30 Jan, 15:43
aljoscha [GitHub] flink issue #5155: [FLINK-4812][metrics] Expose currentLowWatermark for all ... Tue, 30 Jan, 16:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators Tue, 30 Jan, 16:41
aljoscha [GitHub] flink issue #5369: [FLINK-8407][DataStream]Setting the parallelism after a p... Tue, 30 Jan, 16:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Tue, 30 Jan, 16:55
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-8411) HeapListState#add(null) will wipe out entire list state Tue, 30 Jan, 16:57
Aljoscha Krettek (JIRA) [jira] [Reopened] (FLINK-8411) HeapListState#add(null) will wipe out entire list state Tue, 30 Jan, 16:57
kl0u [GitHub] flink issue #5230: [FLINK-8345] Add iterator of keyed state on broadcast sid... Tue, 30 Jan, 17:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast. Tue, 30 Jan, 17:14
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-8522) DefaultOperatorStateBackend writes data in checkpoint that is never read. Tue, 30 Jan, 17:16
Till Rohrmann (JIRA) [jira] [Created] (FLINK-8530) Enable detached job submission for RestClusterClient Tue, 30 Jan, 17:27
Stephan Ewen (JIRA) [jira] [Resolved] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Tue, 30 Jan, 18:24
Stephan Ewen (JIRA) [jira] [Closed] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Tue, 30 Jan, 18:24
Stephan Ewen (JIRA) [jira] [Created] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state Tue, 30 Jan, 18:32
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-8504) TaskExecutor does not properly deregisters JobManager from JobLeaderService Tue, 30 Jan, 21:57
asfgit [GitHub] flink pull request #5361: [FLINK-8504] [flip6] Deregister jobs from the JobL... Tue, 30 Jan, 21:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8504) TaskExecutor does not properly deregisters JobManager from JobLeaderService Tue, 30 Jan, 21:58
XuMingmin [GitHub] flink pull request #5371: [FLINK-8357] [conf] Enable rolling in default log ... Tue, 30 Jan, 22:17
XuMingmin [GitHub] flink pull request #5371: [FLINK-8357] [conf] Enable rolling in default log ... Tue, 30 Jan, 22:17
XuMingmin [GitHub] flink pull request #5371: [FLINK-8357] [conf] Enable rolling in default log ... Tue, 30 Jan, 22:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Tue, 30 Jan, 22:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Tue, 30 Jan, 22:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Tue, 30 Jan, 22:18
Ted Yu (JIRA) [jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0 Tue, 30 Jan, 22:52
Ted Yu (JIRA) [jira] [Updated] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort Tue, 30 Jan, 22:54
Ted Yu (JIRA) [jira] [Commented] (FLINK-7795) Utilize error-prone to discover common coding mistakes Tue, 30 Jan, 22:55
Bowen Li (JIRA) [jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL) Tue, 30 Jan, 23:00
Ted Yu (JIRA) [jira] [Updated] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex Wed, 31 Jan, 01:14
Ted Yu (JIRA) [jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs Wed, 31 Jan, 01:15
tweise [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 01:48
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 01:49
tweise [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 01:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 01:51
zhangminglei [GitHub] flink pull request #5371: [FLINK-8357] [conf] Enable rolling in default log ... Wed, 31 Jan, 02:35
zhangminglei [GitHub] flink pull request #5371: [FLINK-8357] [conf] Enable rolling in default log ... Wed, 31 Jan, 02:35
zhangminglei [GitHub] flink pull request #5371: [FLINK-8357] [conf] Enable rolling in default log ... Wed, 31 Jan, 02:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Wed, 31 Jan, 02:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Wed, 31 Jan, 02:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Wed, 31 Jan, 02:36
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the taskslot, join and shuffle operator will easly caused deadlock. Wed, 31 Jan, 02:38
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the taskslot, join and shuffle operators will easly cause deadlock. Wed, 31 Jan, 02:39
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the taskslot, join and shuffle operators will easly caused deadlock. Wed, 31 Jan, 02:39
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the taskslot, join and shuffle operators will easly cause deadlock. Wed, 31 Jan, 02:50
yanxiaobin (JIRA) [jira] [Updated] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 02:50
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the number of cpu, join and shuffle operators will easly cause deadlock. Wed, 31 Jan, 02:50
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the number of cpu, join and shuffle operators will easly cause deadlock. Wed, 31 Jan, 02:52
zhu.qing (JIRA) [jira] [Updated] (FLINK-8526) When use parallelism equals to half of the number of cpu, join and shuffle operators will easly cause deadlock. Wed, 31 Jan, 02:54
yanxiaobin (JIRA) [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 02:59
yanxiaobin (JIRA) [jira] [Comment Edited] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 03:02
yanxiaobin (JIRA) [jira] [Comment Edited] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) Wed, 31 Jan, 03:10
zhangminglei [GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting... Wed, 31 Jan, 03:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Wed, 31 Jan, 03:26
tweise [GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh... Wed, 31 Jan, 04:50
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks Wed, 31 Jan, 04:51
yew1eb [GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ... Wed, 31 Jan, 06:23
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support Wed, 31 Jan, 06:24
xccui [GitHub] flink issue #5369: [FLINK-8407][DataStream]Setting the parallelism after a p... Wed, 31 Jan, 07:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden Wed, 31 Jan, 07:09
zhangminglei [GitHub] flink issue #5375: [FLINK-7095] [TaskManager] Add Command line parsing tool ... Wed, 31 Jan, 07:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main Wed, 31 Jan, 07:29
Yuta Morisawa (JIRA) [jira] [Created] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Wed, 31 Jan, 07:41
Yuta Morisawa (JIRA) [jira] [Updated] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Wed, 31 Jan, 07:41
zhangminglei [GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting... Wed, 31 Jan, 07:41
Yuta Morisawa (JIRA) [jira] [Updated] (FLINK-8532) RebalancePartitioner should use Random value for its first partition Wed, 31 Jan, 07:42
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8357) enable rolling in default log settings Wed, 31 Jan, 07:42
Eron Wright (JIRA) [jira] [Created] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization Wed, 31 Jan, 08:02
Eron Wright (JIRA) [jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization Wed, 31 Jan, 08:05
bowenli86 [GitHub] flink issue #5356: [FLINK-8364][state backend] Add iterator() to ListState w... Wed, 31 Jan, 08:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value Wed, 31 Jan, 08:14
zentol [GitHub] flink issue #5384: [FLINK-8475][config][docs] Integrate akka options Wed, 31 Jan, 08:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8475) Move remaining sections to generated tables Wed, 31 Jan, 08:29
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
pnowojski [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:32
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:33
asfgit [GitHub] flink pull request #5384: [FLINK-8475][config][docs] Integrate akka options Wed, 31 Jan, 08:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8475) Move remaining sections to generated tables Wed, 31 Jan, 08:40
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode Wed, 31 Jan, 08:58
zhijiangW [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff... Wed, 31 Jan, 08: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 · Next »Thread · Author · Date
Box list
Jul 20197010
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