Google Git
Sign in
apache / flink-statefun / HEAD
  1. edb3740 [FLINK-21719][docs] Update statefun developer docs for new protocol by Seth Wiesman · 3 years, 2 months ago
  2. 929872a [release] Update version to 3.0-SNAPSHOT by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  3. 7005f6a [FLINK-21904] Sync standalone-job.sh with recent Flink 1.12.x changes by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  4. b5cd78d [FLINK-21721] Add EgressMessageBuilder by Igal Shilman · 3 years, 2 months ago
  5. a9f6ebc [FLINK-21724][python] Remove type annotation from python message.as_type by Seth Wiesman · 3 years, 2 months ago
  6. 0ab1618 [FLINK-21692] Update the Python SDK by Igal Shilman · 3 years, 2 months ago
  7. b1c50db [FLINK-21705] Add a SliceType by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  8. 039b2d2 [FLINK-21678] Rename expiresAfterReadOrWrite to expiresAfterCall in Java SDK by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  9. 5e6e05b [FLINK-21676] Ensure that state names are valid identifiers in Java SDK by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  10. 9ea565e [hotfix] Add a withTopic(Slice) method to KafkaEgressMessage by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  11. 7244efc [hotfix] Incorrect arg null check in KafkaEgressMessage.withValue(Slice) by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  12. 3845226 [FLINK-21663] Restrict registering mulitple StatefulFunctionSpec under the same function typename by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  13. c85f293 [FLINK-21662] Restrict registering multiple ValueSpecs under same state name by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  14. 65e6f1b [hotfix] Rename ValueSpec.withUtf8String(...) by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  15. 76858f5 [FLINK-21577] [java] Fix instantiation error with SimpleType.simpleTypeFrom() by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  16. d46a451 [FLINK-21642] Test that retry batch on restore do not contain state value by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  17. 2f957f7 [FLINK-21642] Make a retry batch on recovery by Igal Shilman · 3 years, 2 months ago
  18. 1bea597 [hotfix] Fix README.md images by Patrick Lucas · 3 years, 2 months ago
  19. 0dbb10f [hotfix] Fix image src path in docs landing page by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  20. 5a286c6 [hotfix] Check that incoming / outgoing invocation Messages are non-empty by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  21. a788c23 [hotfix] Remove redundant console output in ConcurrentRequestReplyHandlerTest by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  22. 7d605a4 [hotfix] [java] Set has_value appropriately for TypedValues by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  23. 15b2dab [FLINK-21422][docs] Update build and release scripts by Seth Wiesman · 3 years, 3 months ago
  24. 7600f7f [FLINK-21422][docs] Migrate docs to Hugo by Seth Wiesman · 3 years, 3 months ago
  25. 14cb587 [FLINK-21530] Precompute TypeName's canonical representation by Tzu-Li (Gordon) Tai · 3 years, 2 months ago
  26. a89d6a0 [FLINK-21324][testkit] fix assertions for messages function sends to itself by Tymur Yarosh · 3 years, 3 months ago
  27. e26b4ef [FLINK-21498] Avoid copying when converting byte[] to ByteString by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  28. 0dab43a [hotfix] [e2e] Re-enable E2E tests in CI by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  29. ec762a7 [FLINK-21496] [e2e] Upgrade Testcontainers to 1.15.2 by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  30. ed73ce7 [FLINK-21491] [sdk] Depend on statefun-protocol-shaded in Java SDK by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  31. 1c40147 [FLINK-21491] Introduce statefun-shaded by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  32. dfe5a58 [FLINK-21483] [build] Remove spotbugs plugin by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  33. 21fd255 [FLINK-21276] [legal] Mention Protobuf BSD license in statefun-sdk-java by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  34. 20b521e [FLINK-21459] Implement remote Java SDK for Stateful Functions by Igal Shilman · 3 years, 3 months ago
  35. 96cd004 [FLINK-21457] Add support to differentiate a zero length value bytes and non existing value by Igal Shilman · 3 years, 3 months ago
  36. ec69df6 [hotfix] Temporary disable E2E tests in CI by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  37. c3660ee [FLINK-21243] Add a Maven module for Java SDK by Igal Shilman · 3 years, 3 months ago
  38. fa64c68 [FLINK-21230] Add PB wrapper types for the new type system. by Igal Shilman · 3 years, 3 months ago
  39. 69c658e [FLINK-21171] Wire in TypedValue throughout the runtime as state values and message payloads by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  40. 36973be [FLINK-21154] Rename packages for request-reply protocol Proto messages by Tzu-Li (Gordon) Tai · 3 years, 3 months ago
  41. 3a124bb [FLINK-21154] Move *-egress.proto to the sdk protos by Igal Shilman · 3 years, 3 months ago
  42. 24da73b [FLINK-21154] Move shared request-reply protobuf files to statefun-sdk-protos by Igal Shilman · 3 years, 4 months ago
  43. 7cb69bd [FLINK-21061] [core] Support state types for remote function states by Tzu-Li (Gordon) Tai · 3 years, 4 months ago
  44. d3112ed [hotfix] Refactor StateBinder.bind dispatch logic to runtime by Tzu-Li (Gordon) Tai · 3 years, 4 months ago
  45. d5da910 [FLINK-20742] [build] Skip deployment of example artifacts by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  46. 992f86b [FLINK-20987] Upgrade to Flink 1.12.1 by Tzu-Li (Gordon) Tai · 3 years, 4 months ago
  47. ed6b475 [hotfix] [build] Remove redundant shade filter from statefun-flink-datastream by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  48. 265a8a8 [FLINK-20741] [legal] Add licenses for statefun-flink-datastream by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  49. f3f7d99 [hotfix] isUsingCustomRawKeyedState should be set on FeedbackUnionOperator by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  50. 692d9d5 [hotfix] [docs] Make image src in Python SDK README a web link by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  51. 5ea3958 [FLINK-19741] Set isUsingCustomRawKeyedState flag in FunctionGroupOperator by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  52. f670c3f [FLINK-20689] Upgrade Flink version to 1.11.3 by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  53. 9b53e60 [FLINK-20699] Set FeedbackKey invocation_id explicitly by Igal Shilman · 3 years, 5 months ago
  54. f9fcd14 [hotfix] fix typos in StatefulFunctionModule.java. by winder · 3 years, 5 months ago
  55. 163dd03 [FLINK-20636] Validate that unaligned checkpoints is not enabled by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  56. d1744ea [FLINK-20335] [core] Remove support for module YAML versions 1.0 / 2.0 by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  57. 7fe767b [hotfix] Fix rat and license check by wangzzu · 3 years, 5 months ago
  58. fcc5ef9 [FLINK-18968][docs-zh] Optimize the translation of README.zh.md by wangzzu · 3 years, 6 months ago
  59. 2f65c8a [FLINK-18968][docs-zh] Translate README.md to Chinese by billyrrr · 3 years, 9 months ago
  60. 5ed3562 [FLINK-18968][docs-zh] Duplicate README.md as README.zh.md by billyrrr · 3 years, 9 months ago
  61. 914dc11 [hotfix] [e2e] Add timeout to ExactlyOnceWithRemoteFnE2E by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  62. ee051dd [FLINK-20334] [core] Implement V3 module YAML with function endpoint templating by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  63. 8482d94 [FLINK-20334] [sdk] Support binding function providers per namespace by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  64. 3edff61 [hotfix][sdk] Correct spelling of wrong words. by RocMarshal · 3 years, 5 months ago
  65. 2cf0d25 [hotfix][sdk] Change variable names to comply with camel case naming rules. by RocMarshal · 3 years, 5 months ago
  66. b86616b [FLINK-20303] [e2e] Add a SmokeE2E test by Igal Shilman · 3 years, 6 months ago
  67. e82c2a0 [FLINK-20268] [python, docs] Update Python SDK README.md by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  68. be8a94c [FLINK-20268] [core] Declare states with Python SDK in E2E tests by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  69. f1b30fb [FLINK-20268] [python] Update all Python examples to declare state with SDK by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  70. 7ab6172 [FLINK-20268] Update statefun-python-walkthrough-example to cover new protocol by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  71. 280bbe1 [hotfix] [python, test] Remove useless print in tests by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  72. b522652 [FLINK-20268] [python] Detect missing states and respond IncompleteInvocationContext by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  73. e0d7e92 [hotfix] [python, test] Simplify function binding in request_reply_test by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  74. 07c29cf [FLINK-20268] [python] Add StateSpec registration to Python SDK by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  75. 6b3ec55 [FLINK-20268] [python] Regenerate Python SDK protocol Protobuf messages for new protocol by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  76. f67f8e7 [hotfix] [core] Rename http-function.proto to request-reply.proto by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  77. df792ac [FLINK-20265] [core] Implement new extended protocol in RequestReplyFunction by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  78. d0d999a [hotfix] [core] Remove redundant conditioning in HttpRequestReplyClient.parseResponse by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  79. 3a1584e [FLINK-20265] [core, test] Add UT to cover user contracts of PersistedRemoteFunctionValues by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  80. c966b29 [hotfix] [core] Refactor state utility methods into PersistedRemoteFunctionValues by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  81. bf021cc [FLINK-20265] [core] Deprecate PersistedRemoteFunctionValues constructor which supports eager state specs by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  82. 62cf2e4 [FLINK-20265] [core] Allow PersistedRemoteFunctionValues to register states based on protocol PersistedValueSpecs by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  83. 2f7eb5f [FLINK-20265] [core] Add IncompleteInvocationContext to FromFunction by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  84. 2235b79 [FLINK-20189] [test] Extend UnboundedFeedbackLoggerTests to use RandomReadLengthByteArrayInputStream by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  85. e5f5364 [FLINK-20189] [core] Use tryReadFully in Header.skipHeaderSilently by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  86. 6e08676 [FLINK-20189] [core] Backport IOUtils.tryReadFully by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  87. 0720790 [FLINK-20161] [README] Update build status badge to point to Github Actions by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  88. bcfe8f1 [FLINK-20161] [ci] Remove Travis CI workflow by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  89. 877a148 [FLINK-20161] [ci] Add Github Actions workflow for JDK 8 build by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  90. 9a93f74 [FLINK-20085] [core] Remove statefun.remote.migrate-legacy-state config by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  91. fb9dbcd [FLINK-20085] [core] Remove RemoteFunctionStateMigrator migration code paths by Tzu-Li (Gordon) Tai · 3 years, 6 months ago
  92. 1366c29 [hotfix][docs] Fix some typos in Java code in documentation by Guillaume Vauvert · 3 years, 6 months ago
  93. 6a3848b [hotfix] Disable travis documentation check by Seth Wiesman · 3 years, 6 months ago
  94. 7d91e46 [hotfix] fix travis configuration by Seth Wiesman · 3 years, 6 months ago
  95. 60ee9bf [FLINK-20009][docs] Add documentation link check to travis by Seth Wiesman · 3 years, 6 months ago
  96. c67fded [hotfix] Fix broken doc links by Seth Wiesman · 3 years, 6 months ago
  97. 315718c [FLINK-19866] Move intialization logic to open() instead initializeState by wangchao · 3 years, 6 months ago
  98. 1064e2f [FLINK-19840] Do not allow rocksdb timerservice that uses the heap by Igal Shilman · 3 years, 7 months ago
  99. ddeec31 [FLINK-19692][core] Add a header for each keyGroup by Igal Shilman · 3 years, 7 months ago
  100. 3ba589e [FLINK-19692][core] Write all the assigned KeyGroups into the raw keyed stream by Igal Shilman · 3 years, 7 months ago