Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 23, 2019

• [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

  Show description for 71fa237
  

  dianfu

  authored and

  hequn8128

  committed
  71fa237

  Copy full SHA for 71fa237

• [FLINK-14157][e2e] Disable Streaming File Sink s3 end-to-end test for java 11.

  Show description for 250f23d
  kl0u

  committed
  250f23d

  Copy full SHA for 250f23d

• [FLINK-14157][e2e] Undo jaxb rellocations for java 8 in s3.

  kl0u

  committed
  8496de3

  Copy full SHA for 8496de3

• [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on PushingAsyncDataInput#emitNext

  Show description for a80bbf1
  

  zhijiangW

  authored and

  pnowojski

  committed
  a80bbf1

  Copy full SHA for a80bbf1

• [hotfix][task] Refactor the constrcutor of StreamOneInputProcessor

  

  zhijiangW

  authored and

  pnowojski

  committed
  68386c4

  Copy full SHA for 68386c4

• [hotfix][task] Refactor the constrcutor of StreamTwoInputProcessor

  Show description for 4d42eab
  

  zhijiangW

  authored and

  pnowojski

  committed
  4d42eab

  Copy full SHA for 4d42eab

• [hotfix][network] Refactor the class name AsyncDataInput to PullingAsyncDataInput

  

  zhijiangW

  authored and

  pnowojski

  committed
  c727190

  Copy full SHA for c727190

• [hotfix][task] Remove unused argument from constructor of StreamTaskNetworkInput

  

  zhijiangW

  authored and

  pnowojski

  committed
  0983d1f

  Copy full SHA for 0983d1f

• [hotfix][task] Remove unncessary SuppressWarnings from StreamOneInputProcessor

  

  zhijiangW

  authored and

  pnowojski

  committed
  7aa0671

  Copy full SHA for 7aa0671

• [hotfix][task] Refactor the process of checking input index for StreamOneInputProcessor#processInput

  Show description for f5b6952
  

  zhijiangW

  authored and

  pnowojski

  committed
  f5b6952

  Copy full SHA for f5b6952

• [FLINK-14160][docs] Describe --backpressure option for Operations Playground.

  Show description for c83c186
  

  alpinegizmo

  authored and

  fhueske

  committed
  c83c186

  Copy full SHA for c83c186

• [FLINK-13864][fs-connector] Make StreamingFileSink extensible

  Show description for adfe011
  

  yxu-valleytider

  authored and

  kl0u

  committed
  adfe011

  Copy full SHA for adfe011

Commits on Sep 22, 2019

• [FLINK-14150][python] Clean up the __pycache__ directories and other empty directories in flink-python source code folder before packaging.

  Show description for 8155d46
  

  WeiZhong94

  authored and

  hequn8128

  committed
  8155d46

  Copy full SHA for 8155d46

Commits on Sep 21, 2019

• [FLINK-14140][python] Fix the broken flink logo in flink python shell.

  Show description for af37ae7
  

  WeiZhong94

  authored and

  hequn8128

  committed
  af37ae7

  Copy full SHA for af37ae7

Commits on Sep 20, 2019

• [FLINK-14096][client] Merge NewClusterClient into ClusterClient

  Show description for 1c20b83
  tisonkun

  authored
  1c20b83

  Copy full SHA for 1c20b83

Commits on Sep 19, 2019

• [FLINK-13953][build, runtime] Facilitate enabling new Scheduler in MiniCluster Tests

  Show description for 34b5399
  

  zhuzhurk

  authored and

  GJL

  committed
  34b5399

  Copy full SHA for 34b5399

• [hotfix][build] Use parent's maven-surefire-plugin version in elasticsearch6 connector

  

  zhuzhurk

  authored and

  GJL

  committed
  0c209df

  Copy full SHA for 0c209df

• [FLINK-13845][javadocs] Drop references to removed 'Checkpointed' interface

  Show description for e273d8d
  

  Myasuka

  authored and

  StephanEwen

  committed
  e273d8d

  Copy full SHA for e273d8d

• [hotfix][docs] Fix wrong JavaDoc link in SavepointSerializer

  Show description for 03d7ab6
  

  chendonglin

  authored and

  StephanEwen

  committed
  03d7ab6

  Copy full SHA for 03d7ab6

• [FLINK-13796][coordination] Remove unused variable from YarnResourceManager

  Show description for d98132f
  

  Fokko

  authored and

  StephanEwen

  committed
  d98132f

  Copy full SHA for d98132f

• [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

  Show description for 6f36df6
  

  Ryan Tao

  authored and

  StephanEwen

  committed
  6f36df6

  Copy full SHA for 6f36df6

• [FLINK-13449][core] Add ARM architecture to MemoryArchitecture

  Show description for 07f86e6
  

  Yikun

  authored and

  StephanEwen

  committed
  07f86e6

  Copy full SHA for 07f86e6

• [FLINK-11859][runtime] Small improvement to performance of SpanningRecordSerializer

  Show description for 35e57a8
  

  kevin.cyj

  authored and

  StephanEwen

  committed
  35e57a8

  Copy full SHA for 35e57a8

• [FLINK-13896][build] Set Scala compile target version to the same as Java compile target version

  Show description for 289e147
  

  zjuwangg

  authored and

  StephanEwen

  committed
  289e147

  Copy full SHA for 289e147

• [hotfix][API/DataStream] Add missing assert for checkpoint lock checks

  Show description for 13af3aa
  

  link3280

  authored and

  tillrohrmann

  committed
  13af3aa

  Copy full SHA for 13af3aa

Commits on Sep 18, 2019

• [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

  tweise

  committed
  4a4a147

  Copy full SHA for 4a4a147

• [FLINK-14017][python] Support to start up Python worker in process mode.

  Show description for f65ee55
  

  WeiZhong94

  authored and

  hequn8128

  committed
  f65ee55

  Copy full SHA for f65ee55

• [FLINK-13965] Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @deprecated annotation

  Show description for 64b656b
  

  yanghua

  authored and

  tillrohrmann

  committed
  64b656b

  Copy full SHA for 64b656b

• [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

  Show description for cc3a27b
  

  dianfu

  authored and

  hequn8128

  committed
  cc3a27b

  Copy full SHA for cc3a27b

• [FLINK-14014][python][table-common] Adds basic classes PythonFunction, PythonEnv, PythonFunctionInfo

  Show description for 10cb5ab
  

  dianfu

  authored and

  hequn8128

  committed
  10cb5ab

  Copy full SHA for 10cb5ab

• [FLINK-14014] Bump maven-shade-plugin to 3.2.1

  Show description for e7216ee
  

  dianfu

  authored and

  hequn8128

  committed
  e7216ee

  Copy full SHA for e7216ee

• [FLINK-13979][docs-zh] Translate new "Streaming File Sink" docs to chinese

  Show description for 4e1d6db
  

  catkint

  authored and

  wuchong

  committed
  4e1d6db

  Copy full SHA for 4e1d6db

• [FLINK-12746] Add DataStream API Walkthrough

  Show description for ee0d6fd
  fhueske

  committed
  ee0d6fd

  Copy full SHA for ee0d6fd

• [FLINK-12746][docs] Add DataStream API Walkthrough

  Show description for df8f9a5
  

  sjwiesman

  authored and

  fhueske

  committed
  df8f9a5

  Copy full SHA for df8f9a5

• [FLINK-14067] Remove unused PlanExecutor.getOptimizerPlanAsJSON()

  aljoscha

  committed
  e2728c0

  Copy full SHA for e2728c0

Pagination

Previous

Next