Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 23, 2018

• [FLINK-8919] [table] Add KeyedProcessFunctionWithCleanupState.

  Show description for cc94090
  

  liurenjie1024

  authored and

  fhueske

  committed
  cc94090

  Copy full SHA for cc94090

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

  Copy full SHA for 8c042e3

Commits on Mar 14, 2018

• [FLINK-8850] [sql-client] Add support for event-time in SQL Client

  Show description for 310f3de
  twalthr

  committed
  310f3de

  Copy full SHA for 310f3de

Commits on Mar 12, 2018

• [FLINK-8687] [sql-client] Make MaterializedCollectStreamResult#retrievePage to have resultLock

  Show description for 7d837a3
  

  mingleiZhang

  authored and

  twalthr

  committed
  7d837a3

  Copy full SHA for 7d837a3

• [FLINK-8274] [table] Split generated methods for preventing compiler exceptions

  Show description for 1f55f73
  twalthr

  committed
  1f55f73

  Copy full SHA for 1f55f73

Commits on Mar 9, 2018

• [FLINK-8854] [table] Fix schema mapping with time attributes

  Show description for c531486
  twalthr

  committed
  c531486

  Copy full SHA for c531486

Commits on Mar 8, 2018

• [FLINK-8839] [sql-client] Fix table source factory discovery

  Show description for 236ceb5
  twalthr

  committed
  236ceb5

  Copy full SHA for 236ceb5

Commits on Mar 6, 2018

• [FLINK-8560] Add KeyedProcessFunction exposing key in onTimer().

  Show description for 1599862
  

  bowenli86

  authored and

  kl0u

  committed
  1599862

  Copy full SHA for 1599862

Commits on Mar 2, 2018

• [FLINK-8821] [table] Fix non-terminating decimal error

  Show description for b31b707
  

  Xpray

  authored and

  twalthr

  committed
  b31b707

  Copy full SHA for b31b707

Commits on Feb 27, 2018

• [FLINK-8538] [table] Improve unified table sources

  Show description for d9f2f2f
  twalthr

  committed
  d9f2f2f

  Copy full SHA for d9f2f2f

• [FLINK-8538][table]Add a Kafka table source factory with JSON format support

  

  xccui

  authored and

  twalthr

  committed
  2450d2b

  Copy full SHA for 2450d2b

• Update version to 1.6-SNAPSHOT

  tillrohrmann

  committed
  8d180d5

  Copy full SHA for 8d180d5

Commits on Feb 26, 2018

• [FLINK-8703][tests] Migrate tests to MiniClusterResource (batch #2)

  Show description for 3e056b3
  zentol

  committed
  3e056b3

  Copy full SHA for 3e056b3

Commits on Feb 25, 2018

• [hotfix] Remove outdated class OperatorStateHandles and replace it with OperatorSubtaskState

  StefanRRichter

  committed
  617e67c

  Copy full SHA for 617e67c

• [hotfix] Introduce ShutdownHookUtil to avoid code duplication

  Show description for 4d19b1c
  StefanRRichter

  committed
  4d19b1c

  Copy full SHA for 4d19b1c

Commits on Feb 23, 2018

• [hotfix] [sql-client] Use hard-coded Scala version

  twalthr

  committed
  af3ea81

  Copy full SHA for af3ea81

Commits on Feb 21, 2018

• [hotfix] Fix various typos

  Show description for b17610e
  

  jeis2497052

  authored and

  zentol

  committed
  b17610e

  Copy full SHA for b17610e

• [hotfix][build] Set flink-shaded-jackson to provided

  Show description for 3d22f7c
  zentol

  committed
  3d22f7c

  Copy full SHA for 3d22f7c

• [FLINK-8703][tests] Migrate tests to MiniClusterResource (batch #1)

  Show description for cb08aca
  zentol

  committed
  cb08aca

  Copy full SHA for cb08aca

Commits on Feb 18, 2018

• [FLINK-8693][py] Remove redundant Intepreter initialization

  zentol

  committed
  8cea2f6

  Copy full SHA for 8cea2f6

Commits on Feb 17, 2018

• [FLINK-5886][py] Various refactorings to Streaming API

  Show description for 9b7e429
  zentol

  committed
  9b7e429

  Copy full SHA for 9b7e429

• [FLINK-5886][py] Add Python Streaming API

  Show description for 00284fb
  

  Zohar Mizrahi

  authored and

  zentol

  committed
  00284fb

  Copy full SHA for 00284fb

• [FLINK-8607] [table] Add a basic embedded SQL CLI client

  Show description for 035053c
  twalthr

  committed
  035053c

  Copy full SHA for 035053c

Commits on Feb 15, 2018

• [hotfix] Remove unused imports from SharedBuffer

  tillrohrmann

  committed
  c7d2a0d

  Copy full SHA for c7d2a0d

Commits on Feb 14, 2018

• [FLINK-7658] [table] Add Collect aggregate function to Table API.

  Show description for a4442f8
  

  Shuyi Chen

  authored and

  fhueske

  committed
  a4442f8

  Copy full SHA for a4442f8

• [hotfix] Remove costly checkState() statements from CEP SharedBuffer

  aljoscha

  committed
  75b8398

  Copy full SHA for 75b8398

Commits on Feb 12, 2018

• [FLINK-8617] [table] Fix code generation bug while accessing Map type

  Show description for f2ae241
  

  Xpray

  authored and

  twalthr

  committed
  f2ae241

  Copy full SHA for f2ae241

Commits on Feb 7, 2018

• [FLINK-7760] Fix deserialization of NFA state in CEP library

  Show description for c212701
  aljoscha

  committed
  c212701

  Copy full SHA for c212701

• [FLINK-8595] [table] Include table source factory services in flink-table jar

  twalthr

  committed
  b2fc8b4

  Copy full SHA for b2fc8b4

Commits on Feb 6, 2018

• [FLINK-8550][table] Iterate over entryset instead of keys

  Show description for 5e41eaa
  

  hequn8128

  authored and

  zentol

  committed
  5e41eaa

  Copy full SHA for 5e41eaa

• [hotfix][docs] Fix typos

  Show description for b5ffd5f
  

  zhouhai02

  authored and

  zentol

  committed
  b5ffd5f

  Copy full SHA for b5ffd5f

• [FLINK-8555] [table] Simplify function operand checkers and inference

  twalthr

  committed
  30bcb0a

  Copy full SHA for 30bcb0a

• [FLINK-8555] [table] Fix TableFunction varargs length exceed 254

  Show description for a0aa83f
  

  Xpray

  authored and

  twalthr

  committed
  a0aa83f

  Copy full SHA for a0aa83f

• [FLINK-7923] [table] Support accessing fields of arrays of composite types

  Show description for 91b7d01
  

  Shuyi Chen

  authored and

  twalthr

  committed
  91b7d01

  Copy full SHA for 91b7d01

Commits on Feb 5, 2018

• [FLINK-8561] [cep] Fix SharedBuffer.removeEdges to use .equals().

  Show description for 3d323ba
  kl0u

  committed
  3d323ba

  Copy full SHA for 3d323ba

Pagination

Previous

Next