This is an automated email from the ASF dual-hosted git repository.
guoyangze pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6e63e6c [FLINK-26805][table] Managed table breaks legacy connector
without 'connector.type'
add
wangyang0918 commented on pull request #85:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/85#issuecomment-1075919509
I agree that `restartNonce` should respect the `UpgradeMode` and try to
reuse the current spec change behavior.
The HA is not always necessary for
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new 6e63e6c [FLINK-26805][table]
Aitozi commented on a change in pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#discussion_r832812643
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/sessionjob/FlinkSessionJobList.java
##
@@
Aitozi commented on a change in pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#discussion_r832812555
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/sessionjob/spec/FlinkSessionJobSpec.java
##
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 e3a708d [FLINK-26753] PK
wangyang0918 merged pull request #93:
URL: https://github.com/apache/flink-kubernetes-operator/pull/93
--
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.
To unsubscribe,
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new 68b9186 [FLINK-26706]
This is an automated email from the ASF dual-hosted git repository.
lindong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
The following commit(s) were added to refs/heads/master by this push:
new 8571317 [FLINK-25527] Add Transformer and
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9c93387 [FLINK-26767][python] Update code to use the changes for
TableConfig
add 05d043b
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from aa28cd7 [FLINK-26767][python] Update code to use the changes for
TableConfig
add 24f0ac2
JaeguKim edited a comment on pull request #97:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/97#issuecomment-1075818223
Development guide is using both
JaeguKim edited a comment on pull request #97:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/97#issuecomment-1075818223
Development guide is using both
JaeguKim commented on pull request #97:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/97#issuecomment-1075818223
Development guide is using both
kelemensanyi commented on pull request #44:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/44#issuecomment-1075811730
@gyfora , it might be that only my local environment is causing problems for
me, as I've just noticed the operator uses the default `imagePullPolicy` which
kelemensanyi commented on pull request #44:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/44#issuecomment-1075807670
Thanks @gyfora for finding out the details about the configuration. It
sounds good what you suggested.
I think I implemented that as well, but while
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 65a3b08 [hotfix][table-planner] Remove
ExecNodeConfig#getMaxIdleStateRetentionTime()
add 9c93387
This is an automated email from the ASF dual-hosted git repository.
dianfu 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 aa28cd7 [FLINK-26767][python] Update code to
kelemensanyi commented on a change in pull request #44:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/44#discussion_r832748931
##
File path: helm/flink-operator/values.yaml
##
@@ -61,6 +61,7 @@ operatorConfiguration:
metrics.reporter.slf4j.interval: 5
This is an automated email from the ASF dual-hosted git repository.
thw pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 9b9c20f [FLINK-26781] Link Flink
morhidi commented on pull request #93:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/93#issuecomment-1075663141
> > This PR looks really good to me.
> > When I am testing this PR in my minikube, I find we must add a trailing
slash in the URL. For example,
morhidi commented on pull request #97:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/97#issuecomment-1075587365
The fix `--set image.repository=/flink-operator` is valid though :)
--
This is an automated message from the Apache Git Service.
To respond to the message,
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 65a3b0807d691b7738351fd81dab1b4418af2448
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 19:53:47 2022 +0200
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b7fb46469a05e8b171b2034e765365456630d92c
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 14:52:28 2022 +0200
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 607c3a7ba415cc4138f446b43c48e06faae3e369
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 14:55:42 2022 +0200
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 30ce8e72baa8dad98d4901eebe93092d002aea06
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 16:56:01 2022 +0200
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 885d4bb3c2016cb97e9d6191c1047ca60ed8cfde
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 14:49:16 2022 +0200
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a6daa22d63df261b228c22f54564c17c243e57d8
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 14:32:23 2022 +0200
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 41ee1d2 [FLINK-26536][python] Fix
RemoteKeyedStateBackend#merge_namespaces to handle properly for the
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0ba337cd9f1f6f374aba662769c0ff2b2013e49e
Author: Marios Trivyzas
AuthorDate: Mon Mar 21 13:49:49 2022 +0200
JaeguKim opened a new pull request #97:
URL: https://github.com/apache/flink-kubernetes-operator/pull/97
As I follow development guide, I found some incorrect command.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
gyfora commented on a change in pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#discussion_r832372431
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/sessionjob/spec/FlinkSessionJobSpec.java
##
morhidi commented on pull request #93:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/93#issuecomment-1075353127
> This PR looks really good to me.
>
> When I am testing this PR in my minikube, I find we must add a trailing
slash in the URL. For example,
gyfora commented on a change in pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#discussion_r832371344
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/sessionjob/FlinkSessionJobList.java
##
@@
gyfora merged pull request #96:
URL: https://github.com/apache/flink-kubernetes-operator/pull/96
--
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.
To unsubscribe, e-mail:
morhidi commented on a change in pull request #93:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/93#discussion_r832368355
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/IngressUtils.java
##
@@ -122,4 +154,27
wangyang0918 commented on a change in pull request #93:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/93#discussion_r832341172
##
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/IngressUtils.java
##
@@ -122,4
Aitozi commented on pull request #85:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/85#issuecomment-1075311636
@wangyang0918 I think the `restartNonce` should also respect to the
`UpgradeMode`, So I should avoid cancel job with `LAST_STATE` mode directly. If
other parts
gyfora commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1075239386
I think we can simply wait for 3.0.0 at this point :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
SteNicholas commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1075236354
@gyfora, the Operator SDK is upgraded to
[2.1.3](https://github.com/java-operator-sdk/java-operator-sdk/releases/tag/v2.1.3).
Should we bump to the release
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new 9abd874 [FLINK-26536][python] Fix
Aitozi commented on pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#issuecomment-1075193196
I remove the package reorganizing in this pr, PTAL again @gyfora cc
@wangyang0918
--
This is an automated message from the Apache Git Service.
To respond to
gyfora merged pull request #90:
URL: https://github.com/apache/flink-kubernetes-operator/pull/90
--
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.
To unsubscribe, e-mail:
This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git.
from c7265c2 [FLINK-26765] RBAC documentation
add 3cb4f2b [FLINK-26454] Clean up logging and use
Aitozi commented on pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#issuecomment-1075171259
Get it, I will keep it in the current package first.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
gyfora commented on pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#issuecomment-1075168896
I see it's only 5 new spec/status classes that internally use the old
(common) classes. At this point I would prefer to keep the current package
structure that
gyfora edited a comment on pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#issuecomment-1075166034
What is the point of reorganizing the CRD/Status classes into new packages?
I feel that currently it is structured in a pretty straightforward way, but now
gyfora commented on pull request #92:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/92#issuecomment-1075166034
What is the point of reorganizing the CRD/Status classes into new packages?
I feel that currently it is structured in a pretty straightforward way, but now
it
mbalassi commented on pull request #96:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/96#issuecomment-1075154956
I run the test altogether 5 times successfully, it seems stable now.
--
This is an automated message from the Apache Git Service.
To respond to the message,
mbalassi opened a new pull request #96:
URL: https://github.com/apache/flink-kubernetes-operator/pull/96
I went with a simple extra wait-time approach as the tools already existed
for this.
The meaningful alternative is to add expected whitelisted states, like
`DEPLOYED_NOT_READY`
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a0dd7aa [FLINK-26775][python] WindowOperator#process_element
registers wrong cleanup timer
add 28f04b1
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e7b19d8 [FLINK-26638][connectors/elasticsearch] Update docs for
Table-API implementation to
mbalassi commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1075027644
https://issues.apache.org/jira/browse/FLINK-26804
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
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 950cd16 [FLINK-26758][container] Migrate tests to JUnit 5
add a9f9534 [FLINK-26747][gpu] Migrate tests to
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 950cd16 [FLINK-26758][container] Migrate tests
mbalassi commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1074995217
Opening a ticket for this, I run into it too. I have an idea for resolving
it.
> > @gyfora It seems that the e2e tests are not stable after #84.
> >
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 237cec3 [hotfix][table-planner] Remove
ExecNodeConfig#getMaxIdleStateRetentionTime()
add d9fab76
Aitozi commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1074981205
> @gyfora It seems that the e2e tests are not stable after #84.
>
> ```
> Run ls e2e-tests/test_*.sh | while read script_test;do \
> Running
gyfora merged pull request #95:
URL: https://github.com/apache/flink-kubernetes-operator/pull/95
--
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.
To unsubscribe, e-mail:
This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new c7265c2 [FLINK-26765] RBAC
gyfora merged pull request #91:
URL: https://github.com/apache/flink-kubernetes-operator/pull/91
--
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.
To unsubscribe, e-mail:
This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new 758ed1c [FLINK-26554] Upgrade
wangyang0918 commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1074965779
@gyfora It seems that the e2e tests are not stable after #84.
```
Run ls e2e-tests/test_*.sh | while read script_test;do \
Running
This is an automated email from the ASF dual-hosted git repository.
mbalassi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git.
from 856f6f7 [FLINK-26786] Add default container annotation to the
operator deployment
add
This is an automated email from the ASF dual-hosted git repository.
zhangzp pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
The following commit(s) were added to refs/heads/master by this push:
new 3ab3273 [FLINK-25552] Add Estimator and
morhidi commented on pull request #95:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/95#issuecomment-1074953564
+1 LGTM
--
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
mbalassi merged pull request #94:
URL: https://github.com/apache/flink-kubernetes-operator/pull/94
--
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.
To unsubscribe,
gyfora commented on pull request #44:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/44#issuecomment-1074943957
I looked into this a bit more closely. I think the correct solution here is
the following:
Remove ConfigurationServiceDecorator and use
mbalassi opened a new pull request #95:
URL: https://github.com/apache/flink-kubernetes-operator/pull/95
Also moved stuff around in the `docs/static/img` content to match text.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
morhidi removed a comment on pull request #90:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/90#issuecomment-1074748405
+1, LGTM, we can also consider setting the root log level to INFO in the
operator
--
This is an automated message from the Apache Git Service.
To
gyfora commented on pull request #91:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/91#issuecomment-1074923552
@wangyang0918 , I talked the operator sdk guys yesterday on Discord. They
introduced this check and made it default (by accident) in `2.1.2`.
This check
Aitozi commented on pull request #94:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/94#issuecomment-1074904717
@wangyang0918 Yes, This pipeline verify it.
https://github.com/Aitozi/flink-kubernetes-operator/runs/5639643537?check_suite_focus=true
--
This is an
wangyang0918 commented on pull request #94:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/94#issuecomment-1074895387
--
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
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cbdf95e [FLINK-26779][rest] OperationKey implements Serializable
new 317c39f
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e7b19d8bfac83b20ebe49ff52afb5d1616d104c7
Author: Alexander Preuß <11444089+alp...@users.noreply.github.com>
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 07150c4 [FLINK-26779][rest] OperationKey implements Serializable
add 7fcd693 [hotfix][connector-hive] Avoid
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new cbdf95e [FLINK-26779][rest]
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 07150c4 [FLINK-26779][rest] OperationKey
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 14d32f6 [FLINK-26775][python] WindowOperator#process_element
registers wrong cleanup timer
add 9689dd4
Aitozi opened a new pull request #94:
URL: https://github.com/apache/flink-kubernetes-operator/pull/94
Minor fix for the CI command
--
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
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new 0a89a59 [FLINK-26775][python]
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new a0dd7aa [FLINK-26775][python]
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new 065ddea [FLINK-26775][python]
This is an automated email from the ASF dual-hosted git repository.
dianfu 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 14d32f6 [FLINK-26775][python]
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii 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 480956f [FLINK-25549][state/changelog]
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ff33362 [FLINK-26704][table] Remove deprecated Table API string
expressions
add e32c04c
wangyang0918 commented on pull request #93:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/93#issuecomment-1074791689
Great work. I will have a look on this PR today.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e32c04c [FLINK-26495][table-planner] Prohibit hints(dynamic table
options) on view
add 948bfda
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git.
from e784824 Doc typo fix
add 856f6f7 [FLINK-26786] Add default container annotation to the
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e32c04c [FLINK-26495][table-planner] Prohibit hints(dynamic table
options) on view
add 948bfda
90 matches
Mail list logo
