flink-commits mailing list archives: April 2017

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
twal...@apache.org flink git commit: [FLINK-5829] [table] Bump Calcite version to 1.12. Mon, 03 Apr, 15:28
twal...@apache.org flink git commit: [FLINK-6124] [table] Add min/max string aggregation with retracion Mon, 03 Apr, 16:25
kklou...@apache.org flink git commit: [FLINK-6254] [cep] Same method name for late data outputs on PatternStream and WindowedStream Tue, 04 Apr, 09:31
ches...@apache.org [1/2] flink git commit: [FLINK-6184] Prevent NPE in buffer metrics Tue, 04 Apr, 11:36
ches...@apache.org [2/2] flink git commit: [FLINK-6183] [metrics] Prevent some cases of TaskMG not being closed Tue, 04 Apr, 11:36
aljos...@apache.org [1/3] flink git commit: Revert "[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator" Tue, 04 Apr, 11:56
aljos...@apache.org [2/3] flink git commit: Revert "[FLINK-5808] Move max keygroup constants to ExecutionConfig" Tue, 04 Apr, 11:56
aljos...@apache.org [3/3] flink git commit: Revert "[FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()" Tue, 04 Apr, 11:56
fhue...@apache.org [1/3] flink-web git commit: Add blog post 'Continuous Queries on Dynamic Tables' Tue, 04 Apr, 19:39
fhue...@apache.org [2/3] flink-web git commit: Rebuild website for 'Dynamic Tables' blog post Tue, 04 Apr, 19:39
fhue...@apache.org [3/3] flink-web git commit: Rebuild website for 'Dynamic Tables' blog post Tue, 04 Apr, 19:39
j...@apache.org flink git commit: [FLINK-6259] Fix a small spelling error from har-with-dependencies to jar-with-dependencies Wed, 05 Apr, 01:57
fhue...@apache.org [1/2] flink git commit: [FLINK-6267] [table] Remove unused imports in FlinkRelBuilder. Wed, 05 Apr, 12:54
fhue...@apache.org [2/2] flink git commit: [FLINK-6011] [table] Support TUMBLE, HOP, SESSION group window functions in SQL queries on streams. Wed, 05 Apr, 12:54
kklou...@apache.org flink git commit: [FLINK-6265] [cep] Fix consecutive() for times() Wed, 05 Apr, 15:22
ches...@apache.org [01/13] flink git commit: [FLINK-6201] [py] [dist] move python example files from resources to the examples Wed, 05 Apr, 20:42
ches...@apache.org [02/13] flink git commit: [FLINK-6212] [docs] Add avro dependency reference Wed, 05 Apr, 20:42
ches...@apache.org [03/13] flink git commit: [FLINK-6127] [checkstyle] Add MissingDeprecation check Wed, 05 Apr, 20:42
ches...@apache.org [04/13] flink git commit: [FLINK-6127] [checkstyle] Add MissingDeprecation check Wed, 05 Apr, 20:42
ches...@apache.org [05/13] flink git commit: [FLINK-6186] Remove unused import in StreamExecutionEnvironment.scala Wed, 05 Apr, 20:42
ches...@apache.org [06/13] flink git commit: [hotfix] Fix unchecked conversion in JobDetailsHandler Wed, 05 Apr, 20:42
ches...@apache.org [07/13] flink git commit: [FLINK-6246] Fix generic type of OutputTag in operator Output Wed, 05 Apr, 20:42
ches...@apache.org [08/13] flink git commit: [FLINK-6086] [py] Clean up PythonSender/-Streamer generics Wed, 05 Apr, 20:42
ches...@apache.org [09/13] flink git commit: [hotfix] [py] Code cleanup - PythonStreamer#sendBroadCastVariables() Wed, 05 Apr, 20:42
ches...@apache.org [10/13] flink git commit: [hotfix] [py] Code cleanup - StreamPrinter Wed, 05 Apr, 20:42
ches...@apache.org [11/13] flink git commit: [hotfix] [py] Code cleanup - PythonStreamer Wed, 05 Apr, 20:42
ches...@apache.org [12/13] flink git commit: [hotfix] Fix shading checks Wed, 05 Apr, 20:42
ches...@apache.org [13/13] flink git commit: [FLINK-6181][Start scripts] Fix regex in start scripts Wed, 05 Apr, 20:42
ches...@apache.org flink git commit: [FLINK-6212] [docs] Add avro dependency reference Wed, 05 Apr, 21:06
ches...@apache.org flink git commit: [FLINK-6181][Start scripts] Fix regex in start scripts Wed, 05 Apr, 21:08
ches...@apache.org flink git commit: [FLINK-6183] [metrics] Prevent some cases of TaskMG not being closed Wed, 05 Apr, 21:26
ches...@apache.org flink git commit: [FLINK-6203] [docs] [batch] Fix scala GroupReduce example Wed, 05 Apr, 21:41
ches...@apache.org flink git commit: [FLINK-6203] [docs] [batch] Fix scala GroupReduce example Wed, 05 Apr, 21:42
g...@apache.org flink git commit: [FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleInputPlanNode Thu, 06 Apr, 01:19
ches...@apache.org flink git commit: [FLINK-4848] [ssl] Throw meaningful exception when SSL is misconfigured Thu, 06 Apr, 05:35
ches...@apache.org flink git commit: [FLINK-4848] [ssl] Throw meaningful exception when SSL is misconfigured Thu, 06 Apr, 05:38
fhue...@apache.org flink git commit: [FLINK-6241] [table] Add codeGen for streaming OVER aggregations. Thu, 06 Apr, 07:27
fhue...@apache.org [01/37] flink git commit: [FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer Thu, 06 Apr, 07:28
fhue...@apache.org [02/37] flink git commit: [FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer Thu, 06 Apr, 07:28
fhue...@apache.org [03/37] flink git commit: [FLINK-6205] [FLINK-6069] [cep] Correct watermark/late events in side output. Thu, 06 Apr, 07:28
fhue...@apache.org [04/37] flink git commit: [FLINK-5915] [table] Forward the complete aggregate ArgList to aggregate runtime functions. Thu, 06 Apr, 07:28
fhue...@apache.org [05/37] flink git commit: [FLINK-5903] [yarn] Respect taskmanager.numberOfTaskSlots config value in Yarn mode Thu, 06 Apr, 07:28
fhue...@apache.org [06/37] flink git commit: [FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleInputPlanNode Thu, 06 Apr, 07:28
fhue...@apache.org [07/37] flink git commit: [FLINK-3695] [gelly] ValueArray types Thu, 06 Apr, 07:28
fhue...@apache.org [08/37] flink git commit: [FLINK-3695] [gelly] ValueArray types Thu, 06 Apr, 07:28
fhue...@apache.org [09/37] flink git commit: [FLINK-5912] [gelly] Inputs for CSV and graph generators Thu, 06 Apr, 07:28
fhue...@apache.org [10/37] flink git commit: [FLINK-5913] [gelly] Example drivers Thu, 06 Apr, 07:28
fhue...@apache.org [11/37] flink git commit: [FLINK-5913] [gelly] Example drivers Thu, 06 Apr, 07:28
fhue...@apache.org [12/37] flink git commit: [FLINK-5654] [table] Add processing-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. Thu, 06 Apr, 07:28
fhue...@apache.org [13/37] flink git commit: [FLINK-4949] [gelly] Refactor Gelly driver inputs Thu, 06 Apr, 07:28
fhue...@apache.org [14/37] flink git commit: [FLINK-5829] [table] Bump Calcite version to 1.12. Thu, 06 Apr, 07:28
fhue...@apache.org [15/37] flink git commit: [FLINK-6124] [table] Add min/max string aggregation with retracion Thu, 06 Apr, 07:28
fhue...@apache.org [16/37] flink git commit: [FLINK-6254] [cep] Same method name for late data outputs on PatternStream and WindowedStream Thu, 06 Apr, 07:28
fhue...@apache.org [17/37] flink git commit: [FLINK-6259] Fix a small spelling error from har-with-dependencies to jar-with-dependencies Thu, 06 Apr, 07:28
fhue...@apache.org [18/37] flink git commit: [FLINK-6267] [table] Remove unused imports in FlinkRelBuilder. Thu, 06 Apr, 07:28
fhue...@apache.org [19/37] flink git commit: [FLINK-6011] [table] Support TUMBLE, HOP, SESSION group window functions in SQL queries on streams. Thu, 06 Apr, 07:28
fhue...@apache.org [20/37] flink git commit: [FLINK-6265] [cep] Fix consecutive() for times() Thu, 06 Apr, 07:28
fhue...@apache.org [21/37] flink git commit: [FLINK-6201] [py] [dist] move python example files from resources to the examples Thu, 06 Apr, 07:28
fhue...@apache.org [22/37] flink git commit: [FLINK-6212] [docs] Add avro dependency reference Thu, 06 Apr, 07:28
fhue...@apache.org [23/37] flink git commit: [FLINK-6186] Remove unused import in StreamExecutionEnvironment.scala Thu, 06 Apr, 07:28
fhue...@apache.org [24/37] flink git commit: [FLINK-6127] [checkstyle] Add MissingDeprecation check Thu, 06 Apr, 07:28
fhue...@apache.org [25/37] flink git commit: [FLINK-6127] [checkstyle] Add MissingDeprecation check Thu, 06 Apr, 07:28
fhue...@apache.org [26/37] flink git commit: [hotfix] Fix unchecked conversion in JobDetailsHandler Thu, 06 Apr, 07:28
fhue...@apache.org [27/37] flink git commit: [FLINK-6246] Fix generic type of OutputTag in operator Output Thu, 06 Apr, 07:28
fhue...@apache.org [28/37] flink git commit: [FLINK-6086] [py] Clean up PythonSender/-Streamer generics Thu, 06 Apr, 07:28
fhue...@apache.org [29/37] flink git commit: [hotfix] [py] Code cleanup - PythonStreamer#sendBroadCastVariables() Thu, 06 Apr, 07:28
fhue...@apache.org [30/37] flink git commit: [hotfix] [py] Code cleanup - StreamPrinter Thu, 06 Apr, 07:28
fhue...@apache.org [31/37] flink git commit: [hotfix] [py] Code cleanup - PythonStreamer Thu, 06 Apr, 07:28
fhue...@apache.org [32/37] flink git commit: [hotfix] Fix shading checks Thu, 06 Apr, 07:28
fhue...@apache.org [33/37] flink git commit: [FLINK-6181][Start scripts] Fix regex in start scripts Thu, 06 Apr, 07:28
fhue...@apache.org [34/37] flink git commit: [FLINK-6183] [metrics] Prevent some cases of TaskMG not being closed Thu, 06 Apr, 07:28
fhue...@apache.org [35/37] flink git commit: [FLINK-6203] [docs] [batch] Fix scala GroupReduce example Thu, 06 Apr, 07:28
fhue...@apache.org [36/37] flink git commit: [FLINK-4848] [ssl] Throw meaningful exception when SSL is misconfigured Thu, 06 Apr, 07:28
fhue...@apache.org [37/37] flink git commit: [FLINK-6241] [table] Add codeGen for streaming OVER aggregations. Thu, 06 Apr, 07:28
fhue...@apache.org [1/2] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. Thu, 06 Apr, 07:41
fhue...@apache.org [2/2] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. Thu, 06 Apr, 07:41
ches...@apache.org [1/5] flink git commit: [hotfix] [py] Code cleanup - PythonPlanBinder Thu, 06 Apr, 08:58
ches...@apache.org [2/5] flink git commit: [FLINK-6223] [py] Rework PythonPlanBinder generics Thu, 06 Apr, 08:58
ches...@apache.org [3/5] flink git commit: [hotfix] [py] Fix PythonCoGroup useByteArray check Thu, 06 Apr, 08:58
ches...@apache.org [4/5] flink git commit: [FLINK-6229] [py] Rework configuration of PythonPlanBinder/Operators Thu, 06 Apr, 08:58
ches...@apache.org [5/5] flink git commit: [FLINK-6229] [py] Rework setup of PythonPlanBinder Thu, 06 Apr, 08:58
fhue...@apache.org [1/5] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows. Thu, 06 Apr, 16:47
fhue...@apache.org [2/5] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows. Thu, 06 Apr, 16:47
fhue...@apache.org [3/5] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12. Thu, 06 Apr, 16:47
fhue...@apache.org [4/5] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12. Thu, 06 Apr, 16:47
fhue...@apache.org [5/5] flink git commit: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12. Thu, 06 Apr, 16:47
g...@apache.org flink git commit: [FLINK-6268] [core] Object reuse for Either type Thu, 06 Apr, 16:56
ches...@apache.org [1/7] flink git commit: [FLINK-6270] port some memory and network task manager options to ConfigOption Thu, 06 Apr, 17:36
ches...@apache.org [2/7] flink git commit: [FLINK-6269] Make UserCodeClassLoader final Thu, 06 Apr, 17:36
ches...@apache.org [3/7] flink git commit: [FLINK-6256] Fix outputTag variable name in Side Output docs Thu, 06 Apr, 17:36
ches...@apache.org [4/7] flink git commit: [FLINK-5376] Fix log statement in UnorderedStreamElementQueue Thu, 06 Apr, 17:36
ches...@apache.org [5/7] flink git commit: [FLINK-6079] [kafka] Provide meaningful error message if TopicPartitions are null Thu, 06 Apr, 17:36
ches...@apache.org [6/7] flink git commit: [FLINK-6270] extend Configuration with contains(configOption) Thu, 06 Apr, 17:36
ches...@apache.org [7/7] flink git commit: [hotfix] [jdbc] Add generic parameter to ResultTypeQueryable Thu, 06 Apr, 17:36
fhue...@apache.org [01/12] flink git commit: [hotfix] [py] Code cleanup - PythonPlanBinder [Forced Update!] Thu, 06 Apr, 19:29
fhue...@apache.org [02/12] flink git commit: [FLINK-6223] [py] Rework PythonPlanBinder generics Thu, 06 Apr, 19:29
fhue...@apache.org [03/12] flink git commit: [hotfix] [py] Fix PythonCoGroup useByteArray check Thu, 06 Apr, 19:29
fhue...@apache.org [04/12] flink git commit: [FLINK-6229] [py] Rework setup of PythonPlanBinder Thu, 06 Apr, 19:29
fhue...@apache.org [05/12] flink git commit: [FLINK-6229] [py] Rework configuration of PythonPlanBinder/Operators Thu, 06 Apr, 19:29
fhue...@apache.org [06/12] flink git commit: [FLINK-6257] [table] Consistent naming of ProcessFunction and methods for OVER windows. Thu, 06 Apr, 19:29
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
May 2018459
Apr 2018365
Mar 2018538
Feb 2018606
Jan 2018405
Dec 2017112
Nov 2017468
Oct 2017356
Sep 2017219
Aug 2017263
Jul 2017462
Jun 2017321
May 2017729
Apr 2017307
Mar 2017394
Feb 2017310
Jan 2017807
Dec 2016417
Nov 2016314
Oct 2016524
Sep 2016371
Aug 2016522
Jul 2016290
Jun 2016252
May 2016217
Apr 2016312
Mar 2016335
Feb 2016514
Jan 2016272
Dec 2015147
Nov 2015352
Oct 2015476
Sep 2015310
Aug 2015328
Jul 2015350
Jun 2015373
May 2015339
Apr 2015399
Mar 2015397
Feb 2015422
Jan 2015334
Dec 2014211
Nov 2014170
Oct 2014186
Sep 2014307
Aug 2014276
Jul 2014291
Jun 2014270