flink-issues mailing list archives: March 2018

Site index · List index
Message list1 · 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
mingleizhang (JIRA) [jira] [Commented] (FLINK-8813) AutoParallellismITCase fails with Flip6 Thu, 01 Mar, 01:28
yuqi1129 [GitHub] flink pull request #: Thu, 01 Mar, 02:14
tedyu [GitHub] flink issue #5205: [FLINK-8037] Fix integer multiplication or shift implicit... Thu, 01 Mar, 02:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort Thu, 01 Mar, 02:15
benwang li (JIRA) [jira] [Created] (FLINK-8815) EventTime won't work as reduce Thu, 01 Mar, 02:27
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 02:30
sihuazhou [GitHub] flink pull request #5604: [FLINK-8816][ResourceManager] Remove the oldWorker... Thu, 01 Mar, 02:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 02:35
sihuazhou [GitHub] flink issue #5604: [FLINK-8816][ResourceManager] Remove the oldWorker only a... Thu, 01 Mar, 02:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 02:36
vinoyang (JIRA) [jira] [Commented] (FLINK-5231) JobManager should exit on "OutOfMemoryError" Thu, 01 Mar, 02:43
zhangminglei [GitHub] flink issue #5599: [FLINK-8808] [flip6] Allow RestClusterClient to connect t... Thu, 01 Mar, 03:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8808) Enable RestClusterClient to submit jobs to local Dispatchers Thu, 01 Mar, 03:20
Xpray [GitHub] flink issue #5174: [FLINK-8274][TableAPI & SQL] Fix Java 64K method compilin... Thu, 01 Mar, 03:44
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc Thu, 01 Mar, 03:45
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8753) Introduce savepoint that go though the incremental checkpoint path Thu, 01 Mar, 03:56
vinoyang (JIRA) [jira] [Commented] (FLINK-5621) Flink should provide a mechanism to prevent scheduling tasks on TaskManagers with operational issues Thu, 01 Mar, 03:57
Chesnay Schepler (JIRA) [jira] [Commented] (FLINK-8813) AutoParallellismITCase fails with Flip6 Thu, 01 Mar, 04:10
zentol [GitHub] flink pull request #: Thu, 01 Mar, 05:33
yanghua [GitHub] flink issue #5593: [FLINK-7836][Client] specifying node label for flink job ... Thu, 01 Mar, 06:08
bowenli86 [GitHub] flink issue #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFunction#... Thu, 01 Mar, 06:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer() Thu, 01 Mar, 06:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7836) specifying node label for flink job to run on yarn Thu, 01 Mar, 06:09
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 06:31
Bowen Li (JIRA) [jira] [Assigned] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable Thu, 01 Mar, 06:36
sihuazhou [GitHub] flink pull request #5605: [FLINK-8817][Distributed Coordination] Decrement n... Thu, 01 Mar, 06:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 06:38
sihuazhou [GitHub] flink issue #5605: [FLINK-8817][Distributed Coordination] Decrement numPendi... Thu, 01 Mar, 06:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 06:39
Bowen Li (JIRA) [jira] [Assigned] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable Thu, 01 Mar, 07:04
vinoyang (JIRA) [jira] [Assigned] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable Thu, 01 Mar, 07:27
Bowen Li (JIRA) [jira] [Assigned] (FLINK-5809) Add registerNextWatermarkCallback() to TimerService Thu, 01 Mar, 07:40
Bowen Li (JIRA) [jira] [Updated] (FLINK-5809) Add registerNextWatermarkCallback() to TimerService Thu, 01 Mar, 07:40
twalthr [GitHub] flink issue #5174: [FLINK-8274][TableAPI & SQL] Fix Java 64K method compilin... Thu, 01 Mar, 07:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc Thu, 01 Mar, 07:55
Nico Kruber (JIRA) [jira] [Created] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write Thu, 01 Mar, 08:01
Nico Kruber (JIRA) [jira] [Updated] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write Thu, 01 Mar, 08:05
Nico Kruber (JIRA) [jira] [Updated] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write Thu, 01 Mar, 08:05
Nico Kruber (JIRA) [jira] [Reopened] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:18
Nico Kruber (JIRA) [jira] [Comment Edited] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:18
Nico Kruber (JIRA) [jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:18
Nico Kruber (JIRA) [jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:18
Nico Kruber (JIRA) [jira] [Comment Edited] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:19
NicoK [GitHub] flink issue #5581: [FLINK-8755][FLINK-8786][network] fix two bugs in spilled... Thu, 01 Mar, 08:19
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8755) SpilledSubpartitionView wrongly relys on the backlog for determining whether more data is available Thu, 01 Mar, 08:20
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-8819) Rework travis script to use build stages Thu, 01 Mar, 08:29
Chesnay Schepler (JIRA) [jira] [Updated] (FLINK-8819) Rework travis script to use build stages Thu, 01 Mar, 08:39
NicoK [GitHub] flink pull request #5606: [FLINK-4387][QS] don't wait and process requests a... Thu, 01 Mar, 08:51
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:52
Nico Kruber (JIRA) [jira] [Assigned] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 08:55
StephanEwen [GitHub] flink issue #5567: [FLINK-8451] [serializers] Make Scala tuple serializer de... Thu, 01 Mar, 09:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8451) CaseClassSerializer is not backwards compatible in 1.4 Thu, 01 Mar, 09:10
yanghua [GitHub] flink issue #5593: [FLINK-7836][Client] specifying node label for flink job ... Thu, 01 Mar, 09:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7836) specifying node label for flink job to run on yarn Thu, 01 Mar, 09:13
Xinyang Gao (JIRA) [jira] [Commented] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception" Thu, 01 Mar, 09:13
BillLeecn [GitHub] flink pull request #5516: [FLINK-8544] [Kafka Connector] Handle null message... Thu, 01 Mar, 09:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null Thu, 01 Mar, 09:17
BillLeecn [GitHub] flink pull request #5516: [FLINK-8544] [Kafka Connector] Handle null message... Thu, 01 Mar, 09:17
BillLeecn [GitHub] flink issue #5516: [FLINK-8544] [Kafka Connector] Handle null message key in... Thu, 01 Mar, 09:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null Thu, 01 Mar, 09:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null Thu, 01 Mar, 09:18
sihuazhou [GitHub] flink issue #5605: [FLINK-8817][Distributed Coordination] Decrement numPendi... Thu, 01 Mar, 09:20
sihuazhou [GitHub] flink pull request #5605: [FLINK-8817][Distributed Coordination] Decrement n... Thu, 01 Mar, 09:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 09:21
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 09:21
tzulitai [GitHub] flink issue #5282: [FLINK-6352] [kafka] Timestamp-based offset configuration... Thu, 01 Mar, 09:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset Thu, 01 Mar, 09:26
sihuazhou [GitHub] flink issue #5604: [FLINK-8816][ResourceManager] Remove the oldWorker only a... Thu, 01 Mar, 09:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 09:27
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 09:28
tillrohrmann [GitHub] flink issue #5604: [FLINK-8816][ResourceManager] Remove the oldWorker only a... Thu, 01 Mar, 09:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 09:37
sihuazhou [GitHub] flink issue #5604: [FLINK-8816][ResourceManager] Remove the oldWorker only a... Thu, 01 Mar, 09:40
sihuazhou [GitHub] flink pull request #5604: [FLINK-8816][ResourceManager] Remove the oldWorker... Thu, 01 Mar, 09:40
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 09:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 09:41
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. Thu, 01 Mar, 09:42
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 09:43
pnowojski [GitHub] flink pull request #5607: [hotfix][docs] Drop the incorrect parallel remark ... Thu, 01 Mar, 09:43
zentol [GitHub] flink pull request #5607: [hotfix][docs] Drop the incorrect parallel remark ... Thu, 01 Mar, 09:46
asfgit [GitHub] flink pull request #5606: [FLINK-4387][QS][tests] don't wait and process req... Thu, 01 Mar, 09:47
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 09:48
Kostas Kloudas (JIRA) [jira] [Closed] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 09:50
vinoyang (JIRA) [jira] [Commented] (FLINK-5621) Flink should provide a mechanism to prevent scheduling tasks on TaskManagers with operational issues Thu, 01 Mar, 09:51
aljoscha [GitHub] flink issue #5599: [FLINK-8808] [flip6] Allow RestClusterClient to connect t... Thu, 01 Mar, 09:52
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8808) Enable RestClusterClient to submit jobs to local Dispatchers Thu, 01 Mar, 09:53
twalthr [GitHub] flink issue #5567: [FLINK-8451] [serializers] Make Scala tuple serializer de... Thu, 01 Mar, 09:55
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8451) CaseClassSerializer is not backwards compatible in 1.4 Thu, 01 Mar, 09:56
aljoscha [GitHub] flink issue #5600: [FLINK-8811] [flip6] Add initial implementation of the Mi... Thu, 01 Mar, 09:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8811) Add MiniClusterClient to allow fast MiniCluster operations Thu, 01 Mar, 09:59
tarun razdan (JIRA) [jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. Thu, 01 Mar, 10:05
Fabian Hueske (JIRA) [jira] [Created] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes Thu, 01 Mar, 10:08
Nico Kruber (JIRA) [jira] [Closed] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 10:29
Nico Kruber (JIRA) [jira] [Reopened] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 10:29
Nico Kruber (JIRA) [jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Thu, 01 Mar, 10:29
Ruidong Li (JIRA) [jira] [Created] (FLINK-8821) Fix BigDecimal divide in AvgAggFunction Thu, 01 Mar, 10:50
pnowojski [GitHub] flink pull request #5607: [hotfix][docs] Drop the incorrect parallel remark ... Thu, 01 Mar, 10:54
Xpray [GitHub] flink pull request #5608: [FLINK-8821][TableAPI && SQL] Fix BigDecimal divid... Thu, 01 Mar, 10:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-8821) Fix BigDecimal divide in AvgAggFunction Thu, 01 Mar, 10:57
Xin Liu (JIRA) [jira] [Created] (FLINK-8822) RotateLogFile may not work well when sed version is below 4.2 Thu, 01 Mar, 10:59
Message list1 · 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
May 20196223
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