flink-issues mailing list archives: April 2016

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 · Next »Thread · Author · Date
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
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 · Next »Thread · Author · Date
Box list
Feb 20183250
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