flink-issues mailing list archives: October 2016

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 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance Thu, 13 Oct, 01:43
tzulitai [GitHub] flink issue #2627: Kafka 0.10 follow-up fixes Thu, 13 Oct, 02:56
tzulitai [GitHub] flink pull request #2585: [FLINK-4727] [kafka-connector] Set missing initial... Thu, 13 Oct, 03:18
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read Thu, 13 Oct, 03:19
tzulitai [GitHub] flink issue #2580: [FLINK-4723] [kafka-connector] Unify committed offsets to... Thu, 13 Oct, 03:48
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Thu, 13 Oct, 03:48
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available Thu, 13 Oct, 04:02
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Thu, 13 Oct, 04:09
tzulitai [GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit... Thu, 13 Oct, 04:09
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Thu, 13 Oct, 04:10
tzulitai [GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con... Thu, 13 Oct, 04:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Thu, 13 Oct, 04:11
Tzu-Li (Gordon) Tai (JIRA) [jira] [Commented] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties Thu, 13 Oct, 04:13
Tzu-Li (Gordon) Tai (JIRA) [jira] [Comment Edited] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties Thu, 13 Oct, 04:13
Tzu-Li (Gordon) Tai (JIRA) [jira] [Created] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector Thu, 13 Oct, 07:06
rmetzger [GitHub] flink issue #2627: Kafka 0.10 follow-up fixes Thu, 13 Oct, 08:17
tzulitai [GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con... Thu, 13 Oct, 08:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Thu, 13 Oct, 08:24
asfgit [GitHub] flink pull request #2627: Kafka 0.10 follow-up fixes Thu, 13 Oct, 08:25
tzulitai [GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit... Thu, 13 Oct, 08:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Thu, 13 Oct, 08:27
tzulitai [GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit... Thu, 13 Oct, 08:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker Thu, 13 Oct, 08:29
Ufuk Celebi (JIRA) [jira] [Closed] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint Thu, 13 Oct, 08:35
tzulitai [GitHub] flink issue #2604: [FLINK-4753] [kafka] PeriodicOffsetCommitter should synch... Thu, 13 Oct, 08:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock Thu, 13 Oct, 08:55
Ovidiu Marcu (JIRA) [jira] [Commented] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails Thu, 13 Oct, 09:26
Philipp von dem Bussche (JIRA) [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs Thu, 13 Oct, 09:28
uce [GitHub] flink issue #2608: [FLINK-4512] [FLIP-10] Add option to persist periodic che... Thu, 13 Oct, 09:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4512) Add option for persistent checkpoints Thu, 13 Oct, 09:34
uce [GitHub] flink issue #2609: [FLINK-4717] Add CancelJobWithSavepoint Thu, 13 Oct, 09:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4717) Naive version of atomic stop signal with savepoint Thu, 13 Oct, 09:35
mxm [GitHub] flink issue #2518: [FLINK-3931] Implement Transport Encryption (SSL/TLS) Thu, 13 Oct, 09:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS) Thu, 13 Oct, 09:36
kl0u [GitHub] flink pull request #2618: Refactoring the Continuous File Monitoring Functio... Thu, 13 Oct, 10:08
Anton Mushin (JIRA) [jira] [Commented] (FLINK-4604) Add support for standard deviation/variance Thu, 13 Oct, 10:13
mxm [GitHub] flink pull request #2618: Refactoring the Continuous File Monitoring Functio... Thu, 13 Oct, 10:16
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4779) Restoring from savepoint fails when BucketingSink has not yet created folder Thu, 13 Oct, 10:19
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist Thu, 13 Oct, 10:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist Thu, 13 Oct, 10:21
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4779) Restoring from savepoint fails when BucketingSink has not yet created folder Thu, 13 Oct, 10:22
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist Thu, 13 Oct, 10:22
Robert Metzger (JIRA) [jira] [Created] (FLINK-4822) Ensure that the Kafka 0.8 connector is compatible with kafka-consumer-groups.sh Thu, 13 Oct, 10:27
Robert Metzger (JIRA) [jira] [Updated] (FLINK-4822) Ensure that the Kafka 0.8 connector is compatible with kafka-consumer-groups.sh Thu, 13 Oct, 10:28
bjlovegithub [GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper... Thu, 13 Oct, 10:49
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams Thu, 13 Oct, 10:49
Sajeev Ramakrishnan (JIRA) [jira] [Created] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value Thu, 13 Oct, 11:23
Greg Hogan (JIRA) [jira] [Commented] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value Thu, 13 Oct, 11:50
rmetzger [GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ... Thu, 13 Oct, 12:13
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface Thu, 13 Oct, 12:14
Sajeev Ramakrishnan (JIRA) [jira] [Commented] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value Thu, 13 Oct, 12:15
rmetzger [GitHub] flink issue #2386: [FLINK-3660] Measure latency and exposes them via a metri... Thu, 13 Oct, 12:16
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface Thu, 13 Oct, 12:17
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-2221) Checkpoints to "file://" are not cleaned up Thu, 13 Oct, 12:19
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up Thu, 13 Oct, 12:19
Robert Metzger (JIRA) [jira] [Created] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() Thu, 13 Oct, 12:21
aljoscha [GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ... Thu, 13 Oct, 12:23
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface Thu, 13 Oct, 12:24
rmetzger [GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ... Thu, 13 Oct, 12:46
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface Thu, 13 Oct, 12:46
Stephan Ewen (JIRA) [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs Thu, 13 Oct, 12:49
Maximilian Michels (JIRA) [jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() Thu, 13 Oct, 13:15
KurtYoung [GitHub] flink issue #2588: [FLINK-4735] [cluster management] Migrate some job execut... Thu, 13 Oct, 13:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls Thu, 13 Oct, 13:24
KurtYoung [GitHub] flink issue #2497: [FLINK-4339][cluster management] Implement Slot Pool core... Thu, 13 Oct, 13:32
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4339) Implement Slot Pool Core Thu, 13 Oct, 13:32
Robert Metzger (JIRA) [jira] [Assigned] (FLINK-4410) Report more information about operator checkpoints Thu, 13 Oct, 13:35
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4410) Report more information about operator checkpoints Thu, 13 Oct, 13:35
Robert Metzger (JIRA) [jira] [Assigned] (FLINK-4698) Visualize additional checkpoint information Thu, 13 Oct, 13:36
Robert Metzger (JIRA) [jira] [Assigned] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker Thu, 13 Oct, 13:36
rmetzger [GitHub] flink issue #2585: [FLINK-4727] [kafka-connector] Set missing initial offset... Thu, 13 Oct, 13:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read Thu, 13 Oct, 13:58
rmetzger [GitHub] flink issue #2604: [FLINK-4753] [kafka] PeriodicOffsetCommitter should synch... Thu, 13 Oct, 13:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock Thu, 13 Oct, 14:00
rmetzger [GitHub] flink pull request #2580: [FLINK-4723] [kafka-connector] Unify committed off... Thu, 13 Oct, 14:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Thu, 13 Oct, 14:03
Anton Mushin (JIRA) [jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance Thu, 13 Oct, 14:10
Anton Mushin (JIRA) [jira] [Comment Edited] (FLINK-4604) Add support for standard deviation/variance Thu, 13 Oct, 14:11
Timo Walther (JIRA) [jira] [Created] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation Thu, 13 Oct, 14:13
Robert Metzger (JIRA) [jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema Thu, 13 Oct, 14:18
Timo Walther (JIRA) [jira] [Updated] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation Thu, 13 Oct, 14:24
mxm [GitHub] flink issue #2624: [FLINK-4516] update leadership information in ResourceMan... Thu, 13 Oct, 14:24
mxm [GitHub] flink pull request #2624: [FLINK-4516] update leadership information in Reso... Thu, 13 Oct, 14:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4516) ResourceManager leadership election Thu, 13 Oct, 14:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4516) ResourceManager leadership election Thu, 13 Oct, 14:25
Timo Walther (JIRA) [jira] [Resolved] (FLINK-4791) Fix issues caused by expression reduction Thu, 13 Oct, 14:31
Anton Mushin (JIRA) [jira] [Commented] (FLINK-4604) Add support for standard deviation/variance Thu, 13 Oct, 14:38
Cody Koeninger (JIRA) [jira] [Commented] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available Thu, 13 Oct, 14:46
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources Thu, 13 Oct, 14:49
Greg Hogan (JIRA) [jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() Thu, 13 Oct, 14:53
Greg Hogan (JIRA) [jira] [Commented] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value Thu, 13 Oct, 14:57
Maximilian Michels (JIRA) [jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs Thu, 13 Oct, 15:01
Maximilian Michels (JIRA) [jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() Thu, 13 Oct, 15:37
rmetzger [GitHub] flink issue #2386: [FLINK-3660] Measure latency and exposes them via a metri... Thu, 13 Oct, 15:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface Thu, 13 Oct, 15:39
StephanEwen [GitHub] flink issue #2588: [FLINK-4735] [cluster management] Migrate some job execut... Thu, 13 Oct, 15:41
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls Thu, 13 Oct, 15:41
StephanEwen [GitHub] flink issue #2497: [FLINK-4339][cluster management] Implement Slot Pool core... Thu, 13 Oct, 15:43
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-4339) Implement Slot Pool Core Thu, 13 Oct, 15:43
Greg Hogan (JIRA) [jira] [Assigned] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() Thu, 13 Oct, 15:58
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 · Next »Thread · Author · Date
Box list
Jul 20198638
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