Google Git
Sign in
apache / flink-statefun / HEAD
  1. 186d7d3 [FLINK-19001] Extract the core translation logic of stateful function operators by Igal Shilman · 3 years, 11 months ago
  2. 7a33d5d [FLINK-19001] Refactor Sinks to be able to return side output streams by Igal Shilman · 3 years, 11 months ago
  3. a1ef0ef [FLINK-19001] Add ability to construct Sources from existing DataStreams by Igal Shilman · 3 years, 11 months ago
  4. 0588bd7 [FLINK-19001] Add Transform Keys by Igal Shilman · 3 years, 11 months ago
  5. e20be5a [FLINK-19001] Add a RoutableMessabeBuilder by Igal Shilman · 3 years, 11 months ago
  6. e4f0589 [FLINK-19001] Add RoutableMessage by Igal Shilman · 3 years, 11 months ago
  7. 56ef7e5 [FLINK-18812][core] Upgrade Flink to 1.11.1 by Seth Wiesman · 3 years, 9 months ago
  8. 70646bf [hotfix] fix python sdk example by Seth Wiesman · 3 years, 9 months ago
  9. d22a448 [hotfix] [docs] Fix typo in modules.md by Ufuk Celebi · 3 years, 10 months ago
  10. 5d15efc [hotfix] [docs] Fix typo in java.md by Ufuk Celebi · 3 years, 10 months ago
  11. 2401396 [hotfix] [docs] Fix typo in packaging.md by Ufuk Celebi · 3 years, 10 months ago
  12. a6ef6eb [hotfix] [docs] Fix typos in logical.md by Ufuk Celebi · 3 years, 10 months ago
  13. e875388 [hotfix] [docs] Fix typos in distributed_architecture.md by Ufuk Celebi · 3 years, 10 months ago
  14. ea7c3f6 [hotfix] [docs] Fix typos in java_walkthrough.md by Ufuk Celebi · 3 years, 10 months ago
  15. e8e5b34 [hotfix] [docs] Fix typos in application-building-blocks.md by Ufuk Celebi · 3 years, 10 months ago
  16. 65b83dd [hotfix] [docs] Make differences sub sections in application-building-blocks.md by Ufuk Celebi · 3 years, 10 months ago
  17. d1a1d31 [hotfix] [docs] Add extension in project-setup.md by Ufuk Celebi · 3 years, 10 months ago
  18. 7abe0a4 [hotfix] [docs] Fix typos in python_walkthrough.md by Ufuk Celebi · 3 years, 10 months ago
  19. 289c30e [FLINK-17954] [core] Demux legacy remote function state on restore by Tzu-Li (Gordon) Tai · 3 years, 11 months ago
  20. 48dc474 [FLINK-17954] [core] Use PersistedRemoteFunctionValues in RequestReplyFunction by Tzu-Li (Gordon) Tai · 3 years, 11 months ago
  21. 414e446 [FLINK-17954] [core] Introduce PersistedRemoteFunctionValues by Tzu-Li (Gordon) Tai · 3 years, 11 months ago
  22. 54cc5e8 [FLINK-18316] [core] Wire in PersistedStateRegistry in PersistedStates.findAndBind by Tzu-Li (Gordon) Tai · 3 years, 10 months ago
  23. d54a66e [FLINK-18316] [core] Let original Flink StateBinder implement SDK StateBinder by Tzu-Li (Gordon) Tai · 3 years, 10 months ago
  24. 2eb4aab [FLINK-18316] [sdk] Add SDK classes for PersistedStateRegistry by Tzu-Li (Gordon) Tai · 3 years, 10 months ago
  25. 23c8df1 [FLINK-18316] [core] Refactor Flink StateBinder by Tzu-Li (Gordon) Tai · 3 years, 10 months ago
  26. 2693f95 [FLINK-18316] [core] Remove BoundState by Tzu-Li (Gordon) Tai · 3 years, 10 months ago
  27. 8376afa [FLINK-18016] [doc] Add documentation for UDS domain socket transport by Tzu-Li (Gordon) Tai · 3 years, 11 months ago
  28. ae04d0a [FLINK-18015] [doc] Add documentation for state expiration by Tzu-Li (Gordon) Tai · 3 years, 11 months ago
  29. a854d16 [hotfix] [legal] Add missing junixsocket-native-common entry in distribution NOTICE by Tzu-Li (Gordon) Tai · 3 years, 11 months ago
  30. bcdb139 [hotfix] Document how to build snapshot docker images by Seth Wiesman · 4 years ago
  31. 2532f9a [hotfix] [docs] Add v2.1 link to docs by Tzu-Li (Gordon) Tai · 4 years ago
  32. 1ddc0f5 [hotfix][docs] Document temporary image registry by Seth Wiesman · 4 years ago
  33. e092515 [hotfix] [docs] Incorrect Flink version in docs config by Tzu-Li (Gordon) Tai · 4 years ago
  34. 3f30aad [release] Update version to 2.2-SNAPSHOT by Tzu-Li (Gordon) Tai · 4 years ago
  35. 4b96b43 [FLINK-17997] [legal] Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE content by Tzu-Li (Gordon) Tai · 4 years ago
  36. 44400f9 [FLINK-17875] [core] Parameterize JsonModuleTest to cover all module format versions by Tzu-Li (Gordon) Tai · 4 years ago
  37. d8a2210 [FLINK-17875] [core] Update FunctionJsonEntity to recognize V2 state format by Tzu-Li (Gordon) Tai · 4 years ago
  38. 3c8e1f4 [FLINK-17875] [core] Add format version 2.0 by Tzu-Li (Gordon) Tai · 4 years ago
  39. b852dcc [FLINK-17875] [core] Wire in StateSpec into RequestReplyFunction by Tzu-Li (Gordon) Tai · 4 years ago
  40. 0023360 [FLINK-17875] [core] Introduce StateSpec for remote function specs by Tzu-Li (Gordon) Tai · 4 years ago
  41. 1fa4664 [FLINK-17875] [core] Move JSON Pointers to individual entities by Tzu-Li (Gordon) Tai · 4 years ago
  42. 4a920f9 [FLINK-17875] [core] Move default function config values to HttpFunctionSpec by Tzu-Li (Gordon) Tai · 4 years ago
  43. 758076b [FLINK-17875] [core] Wire in JsonEntities into JsonModule by Tzu-Li (Gordon) Tai · 4 years ago
  44. ac07854 [FLINK-17875] [core] Introduce JsonEntity and implementations by Tzu-Li (Gordon) Tai · 4 years ago
  45. c14d07a [FLINK-17963] [core] Revert execution environment patching in StatefulFunctionsJob by Tzu-Li (Gordon) Tai · 4 years ago
  46. 6bdbc25 [hotfix] [build] Fix path to spotbugs exclude filter file by Tzu-Li (Gordon) Tai · 4 years ago
  47. 2abbff1 [FLINK-17518] [e2e] Remove routable Kafka E2E test by Tzu-Li (Gordon) Tai · 4 years ago
  48. 60d93d6 [FLINK-17518] [e2e] Add remote module E2E by Tzu-Li (Gordon) Tai · 4 years ago
  49. bae971d [FLINK-17518] [e2e] Add remote functions for remote module E2E by Tzu-Li (Gordon) Tai · 4 years ago
  50. 6d204fe [FLINK-17518] [e2e] Add resultsInAnyOrder to KafkaIOVerifier by Tzu-Li (Gordon) Tai · 4 years ago
  51. ae1e4ce [FLINK-17518] [e2e] Build Python SDK with -Prun-e2e-tests by Tzu-Li (Gordon) Tai · 4 years ago
  52. bd06c18 [FLINK-17518] [build] Add a root.dir property to Maven by Tzu-Li (Gordon) Tai · 4 years ago
  53. f114019 [FLINK-17518] [python] Make Python SDK build script oblivious of working directory by Tzu-Li (Gordon) Tai · 4 years ago
  54. 1c018e1 [FLINK-17611] [core] Add an ITCase for Unix domain sockets by Igal Shilman · 4 years ago
  55. 9c43dc9 [FLINK-17611] [core] Bridge OkHttp and UNIX domain sockets by Igal Shilman · 4 years ago
  56. 95e8757 [FLINK-17611] [core] Support UNIX domain sockets for remote function endpoints by slinkydeveloper · 4 years ago
  57. 23b4d73 [hotfix] Fix spotless checks by Seth Wiesman · 4 years ago
  58. c04f111 [FLINK-16985][docker] Set default Flink Job name" by abc863377 · 4 years ago
  59. 9bf1414 [hotfix] Add @ForRuntime annotation to Expiration constructor by Seth Wiesman · 4 years ago
  60. dc92984 [FLINK-17644] Add Expiration to the Persisted states by Igal Shilman · 4 years ago
  61. 3daf875 [FLINK-17644] Add Expiration to the SDK by Igal Shilman · 4 years ago
  62. dd85b11 [FLINK-17644] Use state expiration by Igal Shilman · 4 years ago
  63. 50b4d1c [hotfix] Avoid raw types in UnboundedFeedbackLoggerTest by Tzu-Li (Gordon) Tai · 4 years ago
  64. c49de86 [hotfix] Remove unused code by Igal Shilman · 4 years ago
  65. 6425f42 [FLINK-17533] Remove concurrent checkpoints limitation by Igal Shilman · 4 years ago
  66. 12626a5 [FLINK-17533] Add support for multiple concurrent checkpoints by Igal Shilman · 4 years ago
  67. 4aac946 [FLINK-17533] Expose checkpointId from barrier messages by Igal Shilman · 4 years ago
  68. b3f6b84 [FLINK-17533] Expose the UnboundedFeedbackLoggerFactory by Igal Shilman · 4 years ago
  69. 3927424 [FLINK-17533] Add UnboundedFeedbackLoggerFactory by Igal Shilman · 4 years ago
  70. cabe2ea [FLINK-16928] Remove jobmanager.scheduler from all config files and docs by Tzu-Li (Gordon) Tai · 4 years ago
  71. d146a90 [FLINK-16928] [core] Remove legacy scheduler config validation by Tzu-Li (Gordon) Tai · 4 years ago
  72. ea14e2c [FLINK-17712] [build] Upgrade Flink version to 1.10.1 by Tzu-Li (Gordon) Tai · 4 years ago
  73. bd30ec0 [FLINK-17516] [e2e] Implement exactly-once E2E against ExactlyOnceVerificationModule by Tzu-Li (Gordon) Tai · 4 years ago
  74. c57ca3e [FLINK-17516] [e2e] Add verification app for exactly-once E2E by Tzu-Li (Gordon) Tai · 4 years ago
  75. e518ea0 [FLINK-17516] [e2e] Allow restarting workers with StatefulFunctionsAppContainers by Tzu-Li (Gordon) Tai · 4 years ago
  76. 60f4bd7 [FLINK-17516] [e2e] Bind checkpoint dirs to temporary local directory by Tzu-Li (Gordon) Tai · 4 years ago
  77. 84afed9 [FLINK-17516] [e2e] Enable exactly-once checkpointing in all e2e tests by Tzu-Li (Gordon) Tai · 4 years ago
  78. 5244bb6 [FLINK-17516] [e2e] Expose master REST port in StatefulFunctionsAppContainers by Tzu-Li (Gordon) Tai · 4 years ago
  79. c2a2648 [FLINK-17516] [e2e] Refactor StatefulFunctionsAppContainers to use Builder pattern by Tzu-Li (Gordon) Tai · 4 years ago
  80. 4708701 [FLINK-17684] [e2e] Enable E2E tests in Travis builds by Tzu-Li (Gordon) Tai · 4 years ago
  81. 180b2f2 [FLINK-17605] Consolidate flink.version property in parent POM by Tzu-Li (Gordon) Tai · 4 years ago
  82. 404182a [FLINK-17287][github] Disable merge commit button by Chesnay Schepler · 4 years ago
  83. bebf3d7 [hotfix] Fix typo in error message by Rafi Aroch · 4 years ago
  84. b316b71 [hotfix][docs] Add 'Install dependencies' step before 'Run unit tests' + fix typo in example by Rafi Aroch · 4 years ago
  85. ed3cd02 [hotfix][docs] Fix typos in LogicFunction page by klion26 · 4 years ago
  86. f3ebc7b [FLINK-17319][docs] add link to python_walkthrough.html to fix broken reference by Patrick Wiener · 4 years ago
  87. ccc8afa [FLINK-17060] [docs] Replace "{flink}" with the Apache Flink trademark by Authuir · 4 years ago
  88. 8c48701 [FLINK-17261] [docs] Fix typo in highlight tag by Tzu-Li (Gordon) Tai · 4 years ago
  89. 2ceb374 [FLINK-17193] [python-k8s-example] Abort script on failure. Build SDK distribution if was not previously built by Rafi Aroch · 4 years ago
  90. 0e33e4a [FLINK-17193] [python-k8s-example] Redirect helm template output to file. by Rafi Aroch · 4 years ago
  91. 3f4cddc [hotfix] Add missing configurations to flink session cluster deployment by Seth Wiesman · 4 years, 1 month ago
  92. c536942 [hotfix] [build] Ignore license checks in snapshot deployments by Tzu-Li (Gordon) Tai · 4 years, 1 month ago
  93. 3596dbd [hotfix] [build] Make deploy_snapshot_jars.sh oblivious of path by Tzu-Li (Gordon) Tai · 4 years, 1 month ago
  94. 780d5c8 [FLINK-15767] [build] Add script for snapshot deployments by Tzu-Li (Gordon) Tai · 4 years, 1 month ago
  95. 947e22a [hotfix] [docs] Typo with PyPI mention by Tzu-Li (Gordon) Tai · 4 years, 1 month ago
  96. 3ce6d1f [release] Adapting the README to Stateful Functions 2.0. by Marta Paes Moreira · 4 years, 1 month ago
  97. 0a70f24 [FLINK-16977][docs] Add docs for components and distributed architecture by Stephan Ewen · 4 years, 1 month ago
  98. c8a5c73 [FLINK-16950] Add --isolation-level read_committed by Igal Shilman · 4 years, 1 month ago
  99. 4948b2c [FLINK-16948][docs] Change docs to better highlight embedded vs remote module configurations by Seth Wiesman · 4 years, 1 month ago
  100. fcb1604 [FLINK-16932][legal] Remove unnecessary entries in the distribution jar NOTICE by Dian Fu · 4 years, 1 month ago