Commits

Branch selector

 master

User selector

kl0u

Datepicker

All time

Commit History

Commits on Oct 20, 2020

• [FLINK-19732] Disable checkpointing in BATCH mode

  Show description for 8fee135
  kl0u

  committed
  8fee135

  Copy full SHA for 8fee135

• [FLINK-19579] Add the SideOutputTransformation translator

  Show description for c5f7d19
  kl0u

  committed
  c5f7d19

  Copy full SHA for c5f7d19

• [FLINK-19578] Add PartitionTransformation translator

  Show description for de7234b
  kl0u

  committed
  de7234b

  Copy full SHA for de7234b

• [FLINK-19577] Add the UnionTransformation translator

  Show description for 835ea03
  kl0u

  committed
  835ea03

  Copy full SHA for 835ea03

• [FLINK-19575] Add LegacySourceTransformation translator

  Show description for f005ba2
  kl0u

  committed
  f005ba2

  Copy full SHA for f005ba2

• [FLINK-19576] Add LegacySinkTransformation translator

  Show description for e5d3036
  kl0u

  committed
  e5d3036

  Copy full SHA for e5d3036

• [FLINK-19574] Add SourceTransformation translator

  Show description for acc9904
  kl0u

  committed
  acc9904

  Copy full SHA for acc9904

Commits on Oct 16, 2020

• [FLINK-19583] Expose the execution.runtime-mode to users

  Show description for b3fd487
  kl0u

  committed
  b3fd487

  Copy full SHA for b3fd487

Commits on Oct 15, 2020

• [FLINK-19573] Add the MultipleInputTransformation translator

  Show description for d5e34a5
  kl0u

  committed
  d5e34a5

  Copy full SHA for d5e34a5

• [FLINK-19572] Add the TwoInputTransformation translator

  Show description for be682cb
  kl0u

  committed
  be682cb

  Copy full SHA for be682cb

Commits on Oct 12, 2020

• [hotfix] Make Transformation.getTransitivePredecessors() return a list

  kl0u

  committed
  c3fedf3

  Copy full SHA for c3fedf3

• [FLINK-19485] Add TransformationTranslator framework and OneInputTranslator

  Show description for 0c3dfc8
  kl0u

  committed
  0c3dfc8

  Copy full SHA for 0c3dfc8

• [hotfix] Make the StreamGraphGenerator use Transformation.getInputs()

  Show description for a2202ee
  kl0u

  committed
  a2202ee

  Copy full SHA for a2202ee

• [FLINK-19485] Add the Transformation.getInputs() method

  Show description for bed3352
  kl0u

  committed
  bed3352

  Copy full SHA for bed3352

• [minor] StreamGraphGenerator.transformSink() refactoring

  kl0u

  committed
  68fec83

  Copy full SHA for 68fec83

Commits on Oct 1, 2020

• [hotfix] Minor StreamGraphGenerator refactoring

  kl0u

  committed
  4fcd7d3

  Copy full SHA for 4fcd7d3

• [FLINK-19392] Detect runtime execution mode based on boundedness of sources

  Show description for c2e3399
  kl0u

  committed
  c2e3399

  Copy full SHA for c2e3399

• [FLINK-19392] Add default Boundedness to legacy sources

  Show description for 1495449
  kl0u

  committed
  1495449

  Copy full SHA for 1495449

Commits on Jul 30, 2020

• [FLINK-18362][yarn] Fix mistakenly merged commit 0e10fd5

  kl0u

  committed
  a0227e2

  Copy full SHA for a0227e2

Commits on Jul 8, 2020

• [hotfix] Harden JarDeleteHandlerTest test

  kl0u

  committed
  a720cf5

  Copy full SHA for a720cf5

• [FLINK-18519][REST] Send exception to client when app fails to execute

  Show description for 78b00f6
  kl0u

  committed
  78b00f6

  Copy full SHA for 78b00f6

Commits on Jul 2, 2020

• [FLINK-18469][docs] Include Application Mode in 1.11 release notes

  Show description for 01da0ea
  kl0u

  committed
  01da0ea

  Copy full SHA for 01da0ea

Commits on Jun 22, 2020

• [hotfix] Annotate the DefaultClusterClientServiceLoader as internal

  kl0u

  committed
  1ad47e3

  Copy full SHA for 1ad47e3

• [FLINK-18352] Make DefaultClusterClientServiceLoader/DefaultExecutorServiceLoader thread-safe

  Show description for b05ab52
  kl0u

  committed
  b05ab52

  Copy full SHA for b05ab52

Commits on Jun 16, 2020

• [FLINK-17891][yarn] Set execution.target=yarn-session in FlinkYarnSessionCli.run()

  Show description for cc1f1a4
  kl0u

  committed
  cc1f1a4

  Copy full SHA for cc1f1a4

Commits on Jun 11, 2020

• [FLINK-17788][scala-shell] Fix yarn session support in scala shell

  kl0u

  committed
  6744033

  Copy full SHA for 6744033

Commits on Jun 10, 2020

• [FLINK-18084][docs] Document the Application Mode

  Show description for 7aa5f33
  kl0u

  committed
  7aa5f33

  Copy full SHA for 7aa5f33

• [FLINK-18084] Rename the ExecutorCLI to GenericCLI according to docs

  kl0u

  committed
  bdcaea6

  Copy full SHA for bdcaea6

• [hotfix] Fix typo in ops/deployment/index

  kl0u

  committed
  d98b935

  Copy full SHA for d98b935

• [hotfix][cli] Update the help message of the Generic CLI

  kl0u

  committed
  c67e796

  Copy full SHA for c67e796

Commits on Jun 4, 2020

• [FLINK-17935] Move set yarn.log-config-file to YarnClusterClientFactory.createClusterDescriptor()

  Show description for a674b5e
  kl0u

  committed
  a674b5e

  Copy full SHA for a674b5e

• Revert "[FLINK-17935] Move set yarn.log-config-file to YarnClusterClientFactory.createClusterDescriptor()"

  Show description for ec4e874
  kl0u

  committed
  ec4e874

  Copy full SHA for ec4e874

• [FLINK-17935] Move set yarn.log-config-file to YarnClusterClientFactory.createClusterDescriptor()

  Show description for 2eb7377
  kl0u

  committed
  2eb7377

  Copy full SHA for 2eb7377

Commits on May 28, 2020

• [FLINK-17819][yarn] Fix error msg for yarn deployments when hadoop not in classpath

  Show description for c8ab94f
  kl0u

  committed
  c8ab94f

  Copy full SHA for c8ab94f

Commits on May 15, 2020

• [FLINK-17729][yarn] Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs

  Show description for 6d97318
  kl0u

  committed
  6d97318

  Copy full SHA for 6d97318

Pagination

Previous

Next