| skyahead |
[GitHub] flink pull request: [FLINK-3635] Potential null deference in Twitt... |
Fri, 01 Apr, 02:42 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap |
Fri, 01 Apr, 02:43 |
| skyahead |
[GitHub] flink pull request: [FLINK-3541] [Kafka Connector] Clean up workar... |
Fri, 01 Apr, 04:36 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 |
Fri, 01 Apr, 04:36 |
| dalegaard |
[GitHub] flink pull request: Refactor rolling sink writer |
Fri, 01 Apr, 06:02 |
| Matthias J. Sax (JIRA) |
[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests |
Fri, 01 Apr, 07:23 |
| stefanobaghino |
[GitHub] flink pull request: [FLINK-3678] Make Flink logs directory configu... |
Fri, 01 Apr, 08:07 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3678) Make Flink logs directory configurable |
Fri, 01 Apr, 08:08 |
| uce |
[GitHub] flink pull request: [FLINK-3678] Make Flink logs directory configu... |
Fri, 01 Apr, 08:40 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3678) Make Flink logs directory configurable |
Fri, 01 Apr, 08:40 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3541] [Kafka Connector] Clean up workar... |
Fri, 01 Apr, 08:42 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3541] [Kafka Connector] Clean up workar... |
Fri, 01 Apr, 08:43 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 |
Fri, 01 Apr, 08:43 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 |
Fri, 01 Apr, 08:43 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3635] Potential null deference in Twitt... |
Fri, 01 Apr, 08:44 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap |
Fri, 01 Apr, 08:44 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Created] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails |
Fri, 01 Apr, 08:57 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Updated] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails |
Fri, 01 Apr, 08:59 |
| Maximilian Michels (JIRA) |
[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests |
Fri, 01 Apr, 09:00 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Updated] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails |
Fri, 01 Apr, 09:00 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Created] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails |
Fri, 01 Apr, 09:01 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Updated] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails |
Fri, 01 Apr, 09:02 |
| Till Rohrmann (JIRA) |
[jira] [Commented] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails |
Fri, 01 Apr, 09:05 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Commented] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails |
Fri, 01 Apr, 09:10 |
| Nikolaas Steenbergen (JIRA) |
[jira] [Updated] (FLINK-3687) org.apache.flink.runtime.net.ConnectionUtilsTest fails |
Fri, 01 Apr, 09:10 |
| Konstantin Knauf (JIRA) |
[jira] [Created] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime |
Fri, 01 Apr, 09:36 |
| Matthias J. Sax (JIRA) |
[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests |
Fri, 01 Apr, 09:41 |
| Maximilian Michels (JIRA) |
[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests |
Fri, 01 Apr, 09:44 |
| stefanobaghino |
[GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no... |
Fri, 01 Apr, 09:54 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API |
Fri, 01 Apr, 09:55 |
| Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime |
Fri, 01 Apr, 10:04 |
| Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime |
Fri, 01 Apr, 10:12 |
| Konstantin Knauf (JIRA) |
[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime |
Fri, 01 Apr, 10:31 |
| ramkrish86 |
[GitHub] flink pull request: FLINK-3579 Improve String concatenation (Ram) |
Fri, 01 Apr, 11:02 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3579) Improve String concatenation |
Fri, 01 Apr, 11:02 |
| Dawid Wysakowicz (JIRA) |
[jira] [Commented] (FLINK-2946) Add orderBy() to Table API |
Fri, 01 Apr, 11:29 |
| Dawid Wysakowicz (JIRA) |
[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders |
Fri, 01 Apr, 11:34 |
| Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime |
Fri, 01 Apr, 11:58 |
| Aljoscha Krettek (JIRA) |
[jira] [Updated] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime |
Fri, 01 Apr, 11:59 |
| tillrohrmann |
[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in... |
Fri, 01 Apr, 11:59 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types |
Fri, 01 Apr, 12:00 |
| Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask |
Fri, 01 Apr, 12:01 |
| Aljoscha Krettek (JIRA) |
[jira] [Comment Edited] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask |
Fri, 01 Apr, 12:06 |
| Maximilian Michels (JIRA) |
[jira] [Created] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager |
Fri, 01 Apr, 12:26 |
| mxm |
[GitHub] flink pull request: [FLINK-3689] fix shutdown of JM when RM is not... |
Fri, 01 Apr, 12:28 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager |
Fri, 01 Apr, 12:28 |
| Till Rohrmann (JIRA) |
[jira] [Updated] (FLINK-3633) Job submission silently fails when using user code types |
Fri, 01 Apr, 12:34 |
| Konstantin Knauf (JIRA) |
[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask |
Fri, 01 Apr, 13:22 |
| Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask |
Fri, 01 Apr, 13:28 |
| tillrohrmann |
[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in... |
Fri, 01 Apr, 13:39 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types |
Fri, 01 Apr, 13:40 |
| asfgit |
[GitHub] flink pull request: [FLINK-3678] Make Flink logs directory configu... |
Fri, 01 Apr, 13:55 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3678) Make Flink logs directory configurable |
Fri, 01 Apr, 13:55 |
| Ufuk Celebi (JIRA) |
[jira] [Closed] (FLINK-3678) Make Flink logs directory configurable |
Fri, 01 Apr, 13:55 |
| stefanobaghino |
[GitHub] flink pull request: [FLINK-3678] Make Flink logs directory configu... |
Fri, 01 Apr, 13:56 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3678) Make Flink logs directory configurable |
Fri, 01 Apr, 13:57 |
| Henry Saputra (JIRA) |
[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication |
Fri, 01 Apr, 15:29 |
| Henry Saputra (JIRA) |
[jira] [Created] (FLINK-3690) Create documentation on the new ResourceManager component |
Fri, 01 Apr, 15:32 |
| tillrohrmann |
[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in... |
Fri, 01 Apr, 16:08 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types |
Fri, 01 Apr, 16:09 |
| asfgit |
[GitHub] flink pull request: [FLINK-3633] Fix user code de/serialization in... |
Fri, 01 Apr, 16:10 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3633) Job submission silently fails when using user code types |
Fri, 01 Apr, 16:11 |
| Till Rohrmann (JIRA) |
[jira] [Closed] (FLINK-3633) Job submission silently fails when using user code types |
Fri, 01 Apr, 16:11 |
| StephanEwen |
[GitHub] flink pull request: [docs] Add first version of "Concepts" documen... |
Fri, 01 Apr, 16:49 |
| StephanEwen |
[GitHub] flink pull request: [docs] Add first version of "Concepts" documen... |
Fri, 01 Apr, 16:49 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3689] fix shutdown of JM when RM is not... |
Fri, 01 Apr, 17:18 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager |
Fri, 01 Apr, 17:19 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3635] Potential null deference in Twitt... |
Fri, 01 Apr, 17:19 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3635) Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap |
Fri, 01 Apr, 17:20 |
| Maximilian Michels (JIRA) |
[jira] [Commented] (FLINK-3690) Create documentation on the new ResourceManager component |
Fri, 01 Apr, 18:03 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no... |
Fri, 01 Apr, 18:09 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API |
Fri, 01 Apr, 18:10 |
| Maximilian Michels (JIRA) |
[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication |
Fri, 01 Apr, 18:14 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no... |
Fri, 01 Apr, 18:17 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API |
Fri, 01 Apr, 18:17 |
| asfgit |
[GitHub] flink pull request: [FLINK-3689] fix shutdown of JM when RM is not... |
Fri, 01 Apr, 18:37 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager |
Fri, 01 Apr, 18:37 |
| Maximilian Michels (JIRA) |
[jira] [Closed] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager |
Fri, 01 Apr, 18:38 |
| StephanEwen |
[GitHub] flink pull request: FLINK-3428: Adds a fixed time trailing waterma... |
Fri, 01 Apr, 18:38 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor |
Fri, 01 Apr, 18:39 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3560] [examples] Remove unchecked outpu... |
Fri, 01 Apr, 18:41 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3560) Examples shouldn't always print usage statement |
Fri, 01 Apr, 18:42 |
| StephanEwen |
[GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass... |
Fri, 01 Apr, 18:48 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant |
Fri, 01 Apr, 18:48 |
| Henry Saputra (JIRA) |
[jira] [Commented] (FLINK-3690) Create documentation on the new ResourceManager component |
Fri, 01 Apr, 19:34 |
| Gna Phetsarath (JIRA) |
[jira] [Created] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord |
Fri, 01 Apr, 19:44 |
| Gna Phetsarath (JIRA) |
[jira] [Updated] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord |
Fri, 01 Apr, 19:46 |
| mbalassi |
[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun... |
Fri, 01 Apr, 22:09 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' |
Fri, 01 Apr, 22:09 |
| Fabian Hueske (JIRA) |
[jira] [Commented] (FLINK-2946) Add orderBy() to Table API |
Fri, 01 Apr, 22:15 |
| Fabian Hueske (JIRA) |
[jira] [Commented] (FLINK-3664) Create a method to easily Summarize a DataSet |
Fri, 01 Apr, 22:31 |
| hsaputra |
[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun... |
Sat, 02 Apr, 00:10 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3657) Change access of DataSetUtils.countElements() to 'public' |
Sat, 02 Apr, 00:10 |
| ggevay |
[GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass... |
Sat, 02 Apr, 09:30 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant |
Sat, 02 Apr, 09:31 |
| dawidwys |
[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i... |
Sat, 02 Apr, 11:16 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders |
Sat, 02 Apr, 11:17 |
| Tian Li (JIRA) |
[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat |
Sat, 02 Apr, 16:18 |
| smarthi |
[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun... |
Sat, 02 Apr, 17:26 |
| smarthi |
[GitHub] flink pull request: FLINK-3657: Change access of DataSetUtils.coun... |
Sat, 02 Apr, 17:26 |