Commits

Branch selector

 master

User selector

fhueske

Datepicker

All time

Commit History

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

Commits on Oct 27, 2017

• [hotfix] [table] Include commons-lang3 in flink-table artifact JAR.

  fhueske

  committed
  7997715

Commits on Oct 25, 2017

• [FLINK-6697] [table] Add support for group window ROWTIME to batch SQL & Table API.

  Show description for babee27
  fhueske

  committed
  babee27

• [FLINK-6584] [docs] Add ROWTIME and PROCTIME group window functions to documentation.

  fhueske

  committed
  14e0948

Commits on Oct 24, 2017

• [FLINK-7821] [table] Deprecate Table.limit() and replace it by Table.offset() and Table.fetch().

  Show description for e1c7e49
  fhueske

  committed
  e1c7e49

• [FLINK-7755] [table] Fix NULL handling in batch joins.

  Show description for 2a63815
  fhueske

  committed
  2a63815

Commits on Oct 13, 2017

• [FLINK-7763] [table] Fix testing RowSink for enabled object reuse.

  fhueske

  committed
  57333c6

Commits on Oct 10, 2017

• [FLINK-6233] [table] Add more tests for rowtime window join + minor refactoring.

  fhueske

  committed
  1ea7f49

Commits on Oct 4, 2017

• [FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing field.

  Show description for dae21da
  fhueske

  committed
  dae21da

Pagination

PreviousNext