Commits

Branch selector

 master

User selector

fhueske

Datepicker

All time

Commit History

Commits on Sep 18, 2018

• [FLINK-10259] [table] Fix identification of key attributes for GroupWindows.

  Show description for f28b829
  fhueske

  committed
  f28b829

Commits on Aug 24, 2018

• [FLINK-10153] [docs] Add Tutorials section and rework structure.

  Show description for 52cbe07
  fhueske

  committed
  52cbe07

Commits on Aug 16, 2018

• [FLINK-10116] [types] Fix getTotalFields() implementation of some TypeInfos.

  Show description for 3390164
  fhueske

  committed
  3390164

Commits on Aug 10, 2018

• [hotfix] [docs] Fix ProcessWindowFunction code snippets.

  Show description for 396bdd1
  fhueske

  committed
  396bdd1

Commits on Jul 26, 2018

• [FLINK-9935] [table] Fix incorrect group field access in batch window combiner.

  fhueske

  committed
  63e84ad

Commits on Jul 24, 2018

• [FLINK-9296] [table] Add support for non-windowed DISTINCT aggregates.

  Show description for 9f181a4
  

  fhueske

  authored and

  twalthr

  committed
  9f181a4

Commits on May 18, 2018

• [hotfix] [docs] Add Release Notes for Flink 1.6.

  fhueske

  committed
  cc06fd4

• [hotfix] [docs] Add Release Notes for Flink 1.5.

  Show description for 7282a05
  fhueske

  committed
  7282a05

Commits on Apr 5, 2018

• [hotfix] [docs] Improve description of keyBy().

  fhueske

  committed
  7712c02

Commits on Mar 29, 2018

• [FLINK-9031] [optimizer] Fix DataSet Union operator translation bug.

  Show description for 87ff6eb
  

  fhueske

  authored and

  StephanEwen

  committed
  87ff6eb

Commits on Mar 27, 2018

• [FLINK-9067] [e2eTests] Add StreamSQLTestProgram and test run script.

  

  fhueske

  authored and

  twalthr

  committed
  6c37b15

Commits on Mar 26, 2018

• [FLINK-8972] [e2eTests] Add DataSetAllroundTestProgram and e2e test script.

  

  fhueske

  authored and

  twalthr

  committed
  5803950

Commits on Mar 23, 2018

• [hotfix] [table] Add Java deprecation annotation to TableEnvironment.sql().

  fhueske

  committed
  7b07fa5

Commits on Mar 22, 2018

• [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_SAMP, STDEV_POP functions on GROUP BY windows.

  Show description for 8c042e3
  fhueske

  committed
  8c042e3

Commits on Feb 16, 2018

• [FLINK-3655] [core] Add support for multiple file paths for FileInputFormat.

  Show description for 892eb85
  fhueske

  committed
  892eb85

Commits on Feb 14, 2018

• [FLINK-8652] [QS] Reduce log level in getKvState to DEBUG.

  Show description for f270dec
  fhueske

  committed
  f270dec

Commits on Feb 5, 2018

• [FLINK-8242] [table] RexProgramExtractor only translates literals of known types.

  fhueske

  committed
  9ad1fa7

• [FLINK-8242] [orc] Fix predicate translation if literal is not Serializable.

  Show description for 63a19e8
  fhueske

  committed
  63a19e8

• [FLINK-8243] [orc] OrcTableSource reads input path recursively by default.

  Show description for de3d85b
  fhueske

  committed
  de3d85b

Commits on Jan 31, 2018

• [FLINK-8230] [orc] Fix NPEs when reading nested columns.

  Show description for bcead3b
  

  fhueske

  authored and

  twalthr

  committed
  bcead3b

• [hotfix] [table] Fix IndexOOBE in DataStreamSortRule.

  Show description for 2b76eca
  

  fhueske

  authored and

  twalthr

  committed
  2b76eca

Commits on Nov 22, 2017

• [FLINK-2170] [connectors] Add OrcRowInputFormat and OrcTableSource.

  Show description for 200612e
  fhueske

  committed
  200612e

Commits on Nov 16, 2017

• [FLINK-8016] [docs] Add documentation for KafkaJsonTableSinks.

  Show description for c697bc1
  fhueske

  committed
  c697bc1

• [FLINK-8014] [table] Add Kafka010JsonTableSink.

  Show description for 50fba9a
  fhueske

  committed
  50fba9a

Commits on Nov 15, 2017

• [FLINK-7490] [table] Use correct classloader to compile generated code that calls UDAGGs.

  Show description for 59df4b7
  

  fhueske

  authored and

  twalthr

  committed
  59df4b7

Commits on Nov 8, 2017

• [FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates.

  Show description for 989c779
  fhueske

  committed
  989c779

• [FLINK-8012] [table] Fix TableSink config for tables with time attributes.

  Show description for 8c5b547
  fhueske

  committed
  8c5b547

Commits on Nov 7, 2017

• [hotfix] [docs] Fix UDTF join description in SQL docs.

  fhueske

  committed
  81e1ac3

• [hotfix] [docs] Improve Supported Types section of Table API & SQL docs.

  fhueske

  committed
  f1ea6a6

Commits on Nov 2, 2017

• [FLINK-7338] [table] Fix retrieval of OVER window lower bound.

  fhueske

  committed
  16b0882

• [FLINK-7421] [table] Fix serializability of AvroRowSerializationSchema + AvroRowDeserializationSchema.

  fhueske

  committed
  78c8ea2

• [FLINK-6226] [table] Add tests for UDFs with Byte, Short, and Float arguments.

  fhueske

  committed
  6e118d1

Commits on Oct 31, 2017

• [FLINK-6563] [table] Add builders with time attribute support for KafkaTableSources.

  Show description for 0e92b66
  fhueske

  committed
  0e92b66

• [FLINK-7939] [table] Fix Table conversion of DataStream of AtomicType.

  Show description for 505d478
  fhueske

  committed
  505d478

Commits on Oct 30, 2017

• [FLINK-7548] [table] Refactor TableSource interface.

  Show description for 9a2ba6e
  fhueske

  committed
  9a2ba6e

Pagination

PreviousNext