| 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 |