This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git.
from d6f6da3 [FLINK-25934] Reduce Statefun's memory consumption to 300mb
add cf7251c [FLINK-2615
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f503fef [FLINK-25053][docs] Document how to use the usrlib to load
code in the user code class loader
add 689b0
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new f503fef [FLINK-25053][docs] Document how t
asardaes edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041166014
I don't know if you already considered how to allow users to specify logging
configuration, but even if you did, I think it would be counterproductive to
r
asardaes commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041166014
I don't know if you already considered how to allow users to specify logging
configuration, but even if you did, I think it would be counterproductive to
redeploy
This is an automated email from the ASF dual-hosted git repository.
guoyangze pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3106f14 [hotfix][tests][connector/kafka] Disable KafkaSink metric
tests until FLINK-26126 has been fixed
add
FuyaoLi2017 edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041062506
For session cluster, maybe we can consider some job level control? This
`sessionClusterMaintainedJobs` mentioned below is a map containing arbitrary
num
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new 6ec208b [FLINK-25994] Implemen
FuyaoLi2017 edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041062506
For session cluster, maybe we can consider some job level control?
I am not sure if this will add much value or not. We can have some
discussion o
FuyaoLi2017 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041062506
For session cluster, maybe we can consider some job level control?
I am not sure if this will be add much value or not. We can have some
discussion over
wangyang0918 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041059009
@FuyaoLi2017 The CRD is generated automatically. You will find it once you
build the project successfully.
--
This is an automated message from the Apache G
FuyaoLi2017 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1041056813
Hi @gyfora , I can't found the CRD file. Based on helm standard, I think it
should be added in `helm/flink-operator/crds`. Maybe you missed it?
--
This i
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3106f14c06c8ee619afc516cb627b83e5ec4ca74
Author: Hang Ruan
AuthorDate: Tue Feb 15 20:43:30 2022 +0800
[hotfix][test
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 57e3f03ccd719ed772c983ba335517d95f8f3e6a
Author: Hang Ruan
AuthorDate: Tue Feb 15 20:15:21 2022 +0800
[FLINK-25289]
This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6222532 [FLINK-24474] Default rest.bind-address to localhost in
flink-conf.yaml
new 57e3f03 [FLINK-25289][tes
bgeng777 commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806876471
##
File path: helm/flink-operator/templates/webhook.yaml
##
@@ -0,0 +1,103 @@
+#
tweise commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807106755
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
##
@@ -0,0 +1,41 @@
+/*
+ *
bgeng777 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040476397
I follow the developer guide to install it via helm and it works smoothly.
Thanks a lot for the awesome work! I just left some minor comments and hope
they can he
tweise commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040565750
> @wangyang0918 thanks for the review and the comments:
>
> 1. It seems that the operator sdk itself requires minimum java 11 and I
dont immediately see a wor
morhidi commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806962571
##
File path: helm/flink-operator/templates/webhook.yaml
##
@@ -0,0 +1,103 @@
+##
gyfora commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1039299350
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
Grypse commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806516502
##
File path: examples/basic-checkpoint-ha.yaml
##
@@ -0,0 +1,61 @@
+#
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806540896
##
File path: examples/basic-checkpoint-ha.yaml
##
@@ -0,0 +1,61 @@
+#
dannycranmer commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806722565
##
File path:
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/JobReconcilerTest.java
##
@@ -0,0
wangyang0918 edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040188011
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spec
martin-g commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806600983
##
File path: README.md
##
@@ -1,2 +1,69 @@
# flink-kubernetes-operator
-Apache Flink Kubernetes Operator
+Temporary repository for Flink K
wangyang0918 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040021423
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific co
tweise commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040565750
> @wangyang0918 thanks for the review and the comments:
>
> 1. It seems that the operator sdk itself requires minimum java 11 and I
dont immediately see a wor
tweise commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807110450
##
File path: pom.xml
##
@@ -0,0 +1,285 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-inst
tweise commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807108293
##
File path: pom.xml
##
@@ -0,0 +1,285 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-inst
tweise commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807106755
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
##
@@ -0,0 +1,41 @@
+/*
+ *
gyfora commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040553023
@bgeng777 thanks a lot for giving this a try! really appreciate it
--
This is an automated message from the Apache Git Service.
To respond to the message, please
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807099646
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/JobSpec.java
##
@@ -0,0 +1,41 @@
+/*
+ *
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807096197
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
##
@@ -0,0 +1,36 @@
+/*
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from fdb8010 [FLINK-26077][runtime] Support operators send request to
Coordinator and return a response (#18737)
ad
bgeng777 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040476397
I follow the developer guide to install it via helm and it works smoothly.
Thanks a lot for the awesome work! I just left some minor comments and hope
they can he
bgeng777 commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r807009833
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/JobStatus.java
##
@@ -0,0 +1,36 @@
+/
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806986394
##
File path: helm/flink-operator/templates/webhook.yaml
##
@@ -0,0 +1,103 @@
+###
morhidi commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806962571
##
File path: helm/flink-operator/templates/webhook.yaml
##
@@ -0,0 +1,103 @@
+##
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new fdb8010 [FLINK-26077][runtime] Support operators s
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806914292
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java
##
@@ -0,0 +1,229 @@
+/*
+ *
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806903568
##
File path: helm/flink-operator/templates/webhook.yaml
##
@@ -0,0 +1,103 @@
+###
bgeng777 commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806876471
##
File path: helm/flink-operator/templates/webhook.yaml
##
@@ -0,0 +1,103 @@
+#
gyfora commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040283503
@dannycranmer I pushed a commit that reworks the 2 tests that used mockito
:) I think this change makes sense and mockito did not add too much value in
this case
This is an automated email from the ASF dual-hosted git repository.
hxb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from daff5df [FLINK-25906][streaming] check explicit env allowed on
StreamExecutionEnvironment own.
add eb80d55 [FLINK
wangyang0918 edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040188011
> @wangyang0918 The problem with `flink-kubernetes` is that it is not a
proper maven dependency but we release a fatjar, this means we cannot really
ex
wangyang0918 edited a comment on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040188011
> @wangyang0918 The problem with `flink-kubernetes` is that it is not a
proper maven dependency but we release a fatjar, this means we cannot really
ex
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new daff5df [FLINK-25906][streaming] check explicit e
wangyang0918 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040188011
> @wangyang0918 The problem with `flink-kubernetes` is that it is not a
proper maven dependency but we release a fatjar, this means we cannot really
exclude t
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806748800
##
File path:
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/JobReconcilerTest.java
##
@@ -0,0 +1,10
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806743159
##
File path: pom.xml
##
@@ -0,0 +1,285 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-inst
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806741497
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java
##
@@ -0,0 +1,229 @@
+/*
+ *
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806740258
##
File path: pom.xml
##
@@ -0,0 +1,285 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-inst
dannycranmer commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806722565
##
File path:
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/JobReconcilerTest.java
##
@@ -0,0
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 009d255 [FLINK-26055][table] Use FlinkVersion rather than version
string from core in persisted plan
add 52a40
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 423143c [FLINK-25574][connectors/async] Migrate AsyncSink connectors
to decomposed SinkV2
add 54cedcb [hotfix
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 423143c [FLINK-25574][connectors/async] Migrate A
gyfora commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806659071
##
File path: pom.xml
##
@@ -0,0 +1,286 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-inst
gyfora commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040079121
@wangyang0918 The problem with `flink-kubernetes` is that it is not a proper
maven dependency but we release a fatjar, this means we cannot really exclude
the fabri
martin-g commented on a change in pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#discussion_r806600983
##
File path: README.md
##
@@ -1,2 +1,69 @@
# flink-kubernetes-operator
-Apache Flink Kubernetes Operator
+Temporary repository for Flink K
gyfora commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040066056
@wangyang0918 thanks for the review and the comments:
1. It seems that the operator sdk itself requires minimum java 11 and I dont
immediately see a workaroun
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 481f98ff02126a2cc0ee4fc447d09d388d266085
Author: Till Rohrmann
AuthorDate: Tue Feb 15 09:53:51 2022 +010
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from c45cf00 [FLINK-25915][docs] Add Matomo tracking code to base layout
new 345f744 [FLINK-25898]
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 345f7440a71efaa6d54ddd2ea7c2d4683c8ad35b
Author: Till Rohrmann
AuthorDate: Thu Feb 10 18:10:07 2022 +010
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 231ec1ac45b2562c12ded19aad4a8bf29c256ba2
Author: Till Rohrmann
AuthorDate: Thu Feb 10 18:13:23 2022 +010
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from 7ec6664 [FLINK-25933][statefun] Add support for the async HTTP
transport in request-reply function build
wangyang0918 commented on pull request #1:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1#issuecomment-1040021423
@gyfora Thanks for creating the prototype with the first version. I have
tested the functionality in a minikube with basic example. It works really
well. Grea
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 17aed84 [FLINK-26090][table] Remove pre FLIP-84 APIs
add 1cf276b [FLINK-26002][tests] Added RestoreUpgradedJ
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new db7f3c5 [hotfix] Commit operat
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0b1ae18 [FLINK-25982] Support idleness with watermark alignment
add 17aed84 [FLINK-26090][table] Remove pre FL
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d896c93 [hotfix][docs] Describe how to resolve the
ITCASE_USE_MINICLUSTER rule
add fec48f3 [hotfix] Corre
This is an automated email from the ASF dual-hosted git repository.
airblader pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5a854a3 [FLINK-25640][docs] Enhance the document for blocking shuffle
add d896c93 [hotfix][docs] Describe ho
72 matches
Mail list logo
