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 |