Google Git
Sign in
apache / flink-statefun / HEAD
  1. b3a88da [FLINK-19515][python] InvocationContext use after dispose fix by Frans King · 3 years, 7 months ago
  2. 4bb7e32 [FLINK-19620] Rename RemoteModuleE2E to ExactlyOnceWithRemoteFnE2E by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  3. 61bcfc2 [FLINK-19620] Remove original ExactlyOnceE2E by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  4. 012d4b3 [FLINK-19620] Add exactly-once verification to RemoteModuleE2E by Tzu-Li (Gordon) Tai · 3 years, 7 months ago
  5. 75b9dfe [docs] Add Haskell SDK to 3rd party SDKs by Timothy Bess · 3 years, 8 months ago
  6. 4fe04ea [hotfix][docs] Add 2.2 to previous docs list by Seth Wiesman · 3 years, 7 months ago
  7. 13bd2f8 [hotfix][doc][py] Change Response -> Reply by Igal Shilman · 3 years, 7 months ago
  8. 8d2e907 [FLINK-19399][doc][python] Document AsyncRequestReplyHandler by Igal Shilman · 3 years, 7 months ago
  9. f9968cd [FLINK-19176] Add pluggable statefun payload serializer by Galen Warren · 3 years, 8 months ago
  10. dd5c157 [hotfix] [legal] Update distribution jar NOTICE by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  11. 9070d29 [FLINK-19327][k8s] Bump JobManager heap size to 1 GB by Igal Shilman · 3 years, 8 months ago
  12. a08141e [FLINK-19329] Check for the existence of managed resources during dispose by Igal Shilman · 3 years, 8 months ago
  13. 0d85a2c [FLINK-19330][core] Move intialization logic to open() instead initializeState() by Igal Shilman · 3 years, 8 months ago
  14. c37f4c4 [hotfix][dockerfile] Add newline to end of flink-conf by Seth Wiesman · 3 years, 8 months ago
  15. c11b3f0 [release] Update version to 2.3-SNAPSHOT by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  16. 13d8730 [FLINK-19290] [docs] Add documentation for Flink DataStream integration SDK by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  17. e9a20a7 [FLINK-19296][http] Do not retry HTTP calls on shutdown by Igal Shilman · 3 years, 8 months ago
  18. 769b5c7 [FLINK-19296][http] Pass a shutdown flag to RetryingCallback by Igal Shilman · 3 years, 8 months ago
  19. a0ef9de [FLINK-19279][core] Remove the StatefulFunctionUniverse cache by Igal Shilman · 3 years, 8 months ago
  20. 953b67f [hotfix] - Fix spotless violations by Igal Shilman · 3 years, 8 months ago
  21. 8321588 [FLINK-19256] [core] Only allow creating throush static factory methods by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  22. 6b09705 [FLINK-19256] [datastream] Improve DataStream API example by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  23. 97c7cf5 [FLINK-19256] [core] Move Flink config validation out of StatefulFunctionsConfig by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  24. 95d7c37 [hotfix] [docs] Broken link in sdk/external.md by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  25. 0cff4c6 [hotfix] [docs] Fix hyperlink formatting in sdk/external.md by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  26. 533e77f [FLINK-19197] [docs] Add documentation for PersistedStateRegistry by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  27. 7d3b2af [FLINK-19199] [core] Add execution attempt ID to feedback channel keys by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  28. 935e424 [FLINK-19220] Close all the function providers that managing resources by Igal Shilman · 3 years, 8 months ago
  29. 672cc31 [FLINK-19220] Mark HttpFunctionProvider as a ManagingResources by Igal Shilman · 3 years, 8 months ago
  30. 6e11a27 [FLINK-19220] Add an internal interface by Igal Shilman · 3 years, 8 months ago
  31. d45c7be [FLINK-19220] Add a close method by Igal Shilman · 3 years, 8 months ago
  32. 13cbda4 [FLINK-19222][docs] Elevate external SDKs by Seth Wiesman · 3 years, 8 months ago
  33. 038560a [FLINK-19203] Use Scala 2.12 by Igal Shilman · 3 years, 8 months ago
  34. b86daab [FLINK-19192] Set connection pool size to 1024 by Igal Shilman · 3 years, 8 months ago
  35. 80aa4ae [FLINK-19191] Set the default maxInflightAsyncOperations to 1024 by Igal Shilman · 3 years, 8 months ago
  36. e35ba2b [FLINK-19190][docs] Switch to camelCase and add recently introduced metrics by Igal Shilman · 3 years, 8 months ago
  37. c1aaa7f [FLINK-19190][metrics] Switch to camelCase by Igal Shilman · 3 years, 8 months ago
  38. ae57f9e [hotfix] Fix spotless style violations by Igal Shilman · 3 years, 8 months ago
  39. 85d064a [FLINK-19017] Report remote function invocation metrics by Igal Shilman · 3 years, 8 months ago
  40. 0db114a [FLINK-19017] Add remote function metrics to RequestReplyClient by Igal Shilman · 3 years, 8 months ago
  41. 0b5b058 [FLINK-19017] Implement the remote function metrics interface by Igal Shilman · 3 years, 8 months ago
  42. efbeab8 [FLINK-19017] Add an interface for remote function metrics by Igal Shilman · 3 years, 8 months ago
  43. 58c18a3 [FLINK-19017] Add dropwizzard metrics by Igal Shilman · 3 years, 8 months ago
  44. 048f850 [FLINK-19017] Log retriable exceptions by Igal Shilman · 3 years, 8 months ago
  45. dbaeb0a [FLINK-19017] Pass RequestSummary to the retrying callback by Igal Shilman · 3 years, 8 months ago
  46. 7ce1a6e [FLINK-19017] Use ToFunctionRequestSummary in RequestReplyClient by Igal Shilman · 3 years, 8 months ago
  47. 7ccb866 [FLINK-19017] Add a RequestSummary class by Igal Shilman · 3 years, 8 months ago
  48. 9c115e7 [FLINK-19130] [core] Apply backlog metrics in RequestReplyFunction by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  49. eb63dc5 [FLINK-19130] [core] Add backlog messages to FunctionTypeMetrics by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  50. de60b64 [FLINK-19130] [core] Expose function type metrics via InternalContext by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  51. 7ed411d [FLINK-19130] [core] Rename AsyncWaiter to InternalContext by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  52. 6bb5cde [FLINK-19130] [core] Rename MetricsFactory to FunctionTypeMetricsFactory by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  53. 6c77ca4 [FLINK-19130] [core] Wire-in new metrics into AsyncSink by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  54. 0fbb17a [FLINK-19130] [core] Allow ObjectContainer to add alias keys by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  55. 6408866 [FLINK-19130] [core] Let StatefulFunctionsRepository extend FunctionTypeMetricsRepository by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  56. 78cbc19 [FLINK-19130] [core] Extend metric interfaces for backpressure metrics by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  57. 09b4d4f [hotfix] [docs] Upgrade Flink version in docs config by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  58. 71fd069 [FLINK-19129] [k8s] Update log4j-console in template Helm chart by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  59. 3978b1f [FLINK-19019] [docker] Add common filesystem plugins to flink-statefun image by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  60. 2fee6d7 [hotfix] [k8s] Remove restart-strategy from values.yaml by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  61. c7363b5 [FLINK-19107] [k8s] Add restart strategy to k8s config-map templates by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  62. 4012bfa [FLINK-19107] Add checkpointing and recovery options to template flink-conf.yaml by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  63. 28aeee6 [FLINK-19106] [datastream] Expose new timeout configs for DataStream API by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  64. dcca2a5 [hotfix] [core] Remove irrelevant callTimeout default value by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  65. 4783652 [FLINK-19106] [remote] Add new keys for timeouts to module.yaml by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  66. d497958 [FLINK-19106] [core] Apply timeout configs to OkHttp client by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  67. 179f123 [FLINK-19106] [core] Extend HttpFunctionSpec with more timeout configs by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  68. 822c6e6 [hotfix] [core] Rename PersistedStates.findReflectivelyAndBind by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  69. bda7fa6 [FLINK-19102] [core, sdk] Make StateBinder a per-FunctionType entity by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  70. dd095c8 [FLINK-19096] [sdk] Add toString() for state classes for better error messages by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  71. f26df15 [FLINK-19096] [sdk] Rework PersistedStateRegistry registration methods by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  72. 9a76143 [FLINK-19095] [core] Respect state expiration configuration in PersistedRemoteFunctionValues by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  73. 8050cb0 [FLINK-19095] [remote] Add "expireMode" to YAML function state spec by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  74. 75749f9 [FLINK-19095] [core] Use SDK Expiration in StateSpec by Tzu-Li (Gordon) Tai · 3 years, 8 months ago
  75. c483184 [FLINK-18979][docs] Update READMEs by Seth Wiesman · 3 years, 9 months ago
  76. 10df361 [FLINK-18979][docs] Update homepage introduction by Seth Wiesman · 3 years, 9 months ago
  77. 4a86dbe [FLINK-18979][docs] Default to remote modules in connectors by Seth Wiesman · 3 years, 9 months ago
  78. fa43ab8 [FLINK-18979][docs] Move Python SDK above Java SDK by Seth Wiesman · 3 years, 9 months ago
  79. d2cdcd3 [FLINK-18979][docs] Move modules to overview and put remote modules on top by Seth Wiesman · 3 years, 9 months ago
  80. 194b3f9 [FLINK-18518] Move statefun releated files into statefun/ dir by Igal Shilman · 3 years, 9 months ago
  81. 2a024b0 [FLINK-18518] Add an async handler integration test by Igal Shilman · 3 years, 9 months ago
  82. 908d5b8 [FLINK-18518] Add async request reply handler example by Igal Shilman · 3 years, 9 months ago
  83. 2acfb0c [FLINK-18518] Add AsyncRequestReplyHandler by Igal Shilman · 3 years, 9 months ago
  84. fb66deb [FLINK-19001] Add more JavaDoc by Igal Shilman · 3 years, 9 months ago
  85. 09fa62e [FLINK-19001] Add a remote function to the example by Igal Shilman · 3 years, 9 months ago
  86. 6888a92 [FLINK-19001] Add remote functions to the DataStreamBuilder by Igal Shilman · 3 years, 9 months ago
  87. 87d2866 [FLINK-19001] Add a ReqRep FunctionBuilder by Igal Shilman · 3 years, 9 months ago
  88. 634781f [FLINK-19001] Add a serializable HttpFunctionProvider by Igal Shilman · 3 years, 9 months ago
  89. a045147 [FLINK-19001] Make HttpFunctionSpec java serializable by Igal Shilman · 3 years, 9 months ago
  90. f219f8b [FLINK-19001] Make FunctionType serializable by Igal Shilman · 3 years, 9 months ago
  91. 1e32991 [FLINK-19001] Initialize okhttp lazily. by Igal Shilman · 3 years, 9 months ago
  92. 7fe17f9 [FLINK-19001] Add flink-clients to the example pom.xml by Igal Shilman · 3 years, 9 months ago
  93. 5bb8db7 [FLINK-19001] Add additional JavadDocs by Igal Shilman · 3 years, 11 months ago
  94. ae6aabf [FLINK-19001] Add an example for data stream embedding by Igal Shilman · 3 years, 11 months ago
  95. d0b808e [FLINK-19001] Set scope provided. by Igal Shilman · 3 years, 11 months ago
  96. a918cb2 [FLINK-19001] Adds a statefun-flink-datastream module. by Igal Shilman · 3 years, 11 months ago
  97. 3ba559f [FLINK-19001] Add scala binary version along side with Flink version by Igal Shilman · 3 years, 11 months ago
  98. d239507 [FLINK-19001] Remove the dependency on SerializableFunctionProvider by Igal Shilman · 3 years, 11 months ago
  99. b8d8ac4 [FLINK-19001] Add an embedded translator by Igal Shilman · 3 years, 11 months ago
  100. 506dc53 [FLINK-19001] Use the Stateful functions core translator by Igal Shilman · 3 years, 11 months ago