dalongliu created FLINK-27660:
-
Summary: Table API support create function using customed jar
Key: FLINK-27660
URL: https://issues.apache.org/jira/browse/FLINK-27660
Project: Flink
Issue Type: Su
deadwind4 commented on code in PR #19682:
URL: https://github.com/apache/flink/pull/19682#discussion_r874426556
##
flink-python/pyflink/datastream/connectors/base.py:
##
@@ -48,3 +50,32 @@ def __init__(self, sink: Union[str, JavaObject]):
:param sink: The java Sink obje
[
https://issues.apache.org/jira/browse/FLINK-26946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26946:
---
Priority: Major (was: Critical)
> Add SHIFTRIGHT supported in SQL & Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-26946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26946:
---
Fix Version/s: (was: 1.16.0)
> Add SHIFTRIGHT supported in SQL & Table API
> ---
dalongliu created FLINK-27659:
-
Summary: Planner support to use jar which is registered by "USING
JAR" syntax
Key: FLINK-27659
URL: https://issues.apache.org/jira/browse/FLINK-27659
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26943:
---
Priority: Major (was: Critical)
> Add DATE_ADD supported in SQL & Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-26943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26943:
---
Fix Version/s: (was: 1.16.0)
> Add DATE_ADD supported in SQL & Table API
> -
[
https://issues.apache.org/jira/browse/FLINK-26940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26940:
---
Priority: Major (was: Critical)
> Add SUBSTRING_INDEX supported in SQL & Table API
> --
[
https://issues.apache.org/jira/browse/FLINK-26940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-26940:
---
Fix Version/s: (was: 1.16.0)
> Add SUBSTRING_INDEX supported in SQL & Table API
> --
dalongliu created FLINK-27658:
-
Summary: Introduce MutableURLClassLoader allow to register and
remove user jar dynamically
Key: FLINK-27658
URL: https://issues.apache.org/jira/browse/FLINK-27658
Project:
[
https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537976#comment-17537976
]
Gyula Fora commented on FLINK-27153:
I will add more on this to the doc changes that
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27654:
---
Priority: Major (was: Blocker)
> Older jackson-databind found in /flink-kubernetes-shaded-1
[
https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537975#comment-17537975
]
Gyula Fora commented on FLINK-27153:
What I meant here [~wangyang0918] is that now t
Sxnan commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r874416498
##
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java:
##
@@ -45,6 +56,9 @@ public class NettyShuffleMaster implements
ShuffleMaster
gyfora commented on PR #216:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/216#issuecomment-1128471981
I merged this.
Added some [missing
tests](https://github.com/apache/flink-kubernetes-operator/commit/ba06ce8e49d95b50dd50e9950a8e96bbe4d5c707)
that now cover this as p
tsreaper opened a new pull request, #123:
URL: https://github.com/apache/flink-table-store/pull/123
Current implementation of `TableStoreDateObjectInspector` is still
incorrect. The resulting `Date` is actually the previous day in timezones with
negative offsets.
--
This is an automated
flinkbot commented on PR #19742:
URL: https://github.com/apache/flink/pull/19742#issuecomment-1128469146
## CI report:
* 02cb5764f0605ffa7f41ef592e289926d7f3aa0e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27651:
---
Labels: pull-request-available (was: )
> Support CREATE FUNCTION USING JAR syntax
> ---
lsyldliu opened a new pull request, #19742:
URL: https://github.com/apache/flink/pull/19742
## What is the purpose of the change
Support CREATE FUNCTION USING JAR syntax
## Brief change log
- *Support CREATE FUNCTION USING JAR syntax*
## Verifying this ch
[
https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537970#comment-17537970
]
Hang Ruan commented on FLINK-24050:
---
cc [~martijnvisser] [~twalthr]
> Support prima
yunfengzhou-hub commented on PR #100:
URL: https://github.com/apache/flink-ml/pull/100#issuecomment-1128464068
Thanks for the comments. I have updated the PR according to the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dianfu commented on code in PR #19682:
URL: https://github.com/apache/flink/pull/19682#discussion_r874408143
##
docs/content/docs/connectors/datastream/pulsar.md:
##
@@ -768,6 +768,51 @@ you to reuse the same Flink job after certain "allowed"
data model changes, like
a field i
yunfengzhou-hub commented on code in PR #100:
URL: https://github.com/apache/flink-ml/pull/100#discussion_r874410359
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/LabeledPointWithWeightGenerator.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed
yunfengzhou-hub commented on code in PR #100:
URL: https://github.com/apache/flink-ml/pull/100#discussion_r874410359
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/LabeledPointWithWeightGenerator.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed
dianfu commented on code in PR #19682:
URL: https://github.com/apache/flink/pull/19682#discussion_r874386261
##
flink-python/pyflink/datastream/connectors/pulsar.py:
##
@@ -363,17 +366,18 @@ def set_deserialization_schema(self,
pulsar_deserialization_schema._j_pulsa
gyfora closed pull request #216: [FLINK-27435] Savepoint History
URL: https://github.com/apache/flink-kubernetes-operator/pull/216
--
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
Juntao Hu created FLINK-27657:
-
Summary: Implement remote operator state backend in PyFlink
Key: FLINK-27657
URL: https://issues.apache.org/jira/browse/FLINK-27657
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-27656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537957#comment-17537957
]
Yubin Li commented on FLINK-27656:
--
Hi, parquet file format has been supported in
http
lindong28 commented on code in PR #100:
URL: https://github.com/apache/flink-ml/pull/100#discussion_r874368648
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/LabeledPointWithWeightGenerator.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to th
flinkbot commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1128408013
## CI report:
* 3a5ea7083ab8c3097cc3258e8524f857e7afd426 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dusukang opened a new pull request, #19741:
URL: https://github.com/apache/flink/pull/19741
## What is the purpose of the change
Using MysqlCatalog to get table primary key of the same table name in
different databases
## Brief change log
Modify the method parameters for get MyS
flinkbot commented on PR #19740:
URL: https://github.com/apache/flink/pull/19740#issuecomment-1128403736
## CI report:
* f88bd5d261e4e27d4d8cddb9ca30c937da3c87ce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-26480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26480:
---
Labels: pull-request-available (was: )
> Support window_all in Python DataStream API
>
cun8cun8 opened a new pull request, #19740:
URL: https://github.com/apache/flink/pull/19740
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them o
Vancior closed pull request #19739: [FLINK-27586][python] Support non-keyed
co-broadcast processing in PyFlink
URL: https://github.com/apache/flink/pull/19739
--
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
[
https://issues.apache.org/jira/browse/FLINK-27621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537942#comment-17537942
]
dalongliu commented on FLINK-27621:
---
Hi, [~jackylau] thanks for your propose, we will
[
https://issues.apache.org/jira/browse/FLINK-27649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27649:
---
Summary: Reduce the number of outputted log lines by
Elasticsearch6SinkE2ECase (was: Reduce
tweise commented on code in PR #216:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/216#discussion_r874352602
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -431,11 +431,12 @@ public void cancelJob
[
https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537748#comment-17537748
]
Martijn Visser edited comment on FLINK-24433 at 5/17/22 4:14 AM:
-
morhidi commented on PR #217:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/217#issuecomment-1128388724
> @morhidi You could find the following exception in the e2e tests with
default namespace. We do not print the operator logs when `watchNamespaces`
enabled. This also nee
MartijnVisser merged PR #19737:
URL: https://github.com/apache/flink/pull/19737
--
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: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-26909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26909.
---
Fix Version/s: 1.15.1
Resolution: Done
Done via:
master: 46c6d78ddd6b271cd434eff03ae65c0e74c0d53e
r
[
https://issues.apache.org/jira/browse/FLINK-26909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26909:
Summary: Allow to set parallelism to be -1 from Cli (was: Support
AdaptiveBatch when parallelism is -1 fr
zhuzhurk closed pull request #19651: [FLINK-26909][Client/Job Submission]
Support AdaptiveBatch when parallelism is -1 from Cli
URL: https://github.com/apache/flink/pull/19651
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
flinkbot commented on PR #19739:
URL: https://github.com/apache/flink/pull/19739#issuecomment-1128378612
## CI report:
* 399472e452d23b6a9b45eae7c296658998b28a3d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27586:
---
Labels: pull-request-available (was: )
> Support non-keyed co-broadcast processing in PyFli
Vancior opened a new pull request, #19739:
URL: https://github.com/apache/flink/pull/19739
## What is the purpose of the change
This PR provided using broadcast state related API such as
`BroadcastStream`, `BroadcastConnectedStream` and `BroadcastProcessFunction` in
PyFlink, whic
wangyang0918 commented on code in PR #216:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/216#discussion_r874335119
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SavepointObserver.java:
##
@@ -131,15 +135,63 @@ private O
wangyang0918 commented on code in PR #216:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/216#discussion_r874334467
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -431,11 +431,12 @@ public void can
dusukang closed pull request #19703: Modify JdbcCatalog to get primary key In
scenarios with the same table name
URL: https://github.com/apache/flink/pull/19703
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
lindong28 merged PR #86:
URL: https://github.com/apache/flink-ml/pull/86
--
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27654:
--
Fix Version/s: kubernetes-operator-1.0.0
> Older jackson-databind found in /flink-kubernetes-shaded-1.
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27654:
--
Priority: Blocker (was: Major)
> Older jackson-databind found in /flink-kubernetes-shaded-1.0-SNAPSHO
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537889#comment-17537889
]
Yang Wang commented on FLINK-27654:
---
Thanks [~jbusche] for reporting this ticket.
It
[
https://issues.apache.org/jira/browse/FLINK-27656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537886#comment-17537886
]
Jingsong Lee commented on FLINK-27656:
--
There is a Jira for parquet. We can link it
[
https://issues.apache.org/jira/browse/FLINK-27652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-27652:
Assignee: Jane Chan
> CompactManager.Rewriter cannot handle different partition keys invo
[
https://issues.apache.org/jira/browse/FLINK-27652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537885#comment-17537885
]
Jingsong Lee commented on FLINK-27652:
--
There is indeed a bug here, the reason is t
deadwind4 commented on PR #18769:
URL: https://github.com/apache/flink/pull/18769#issuecomment-1128337329
We need to bump Beam to 2.39.0
https://github.com/PAIR-code/what-if-tool/issues/185#issuecomment-1013971242
--
This is an automated message from the Apache Git Service.
To respond t
yunfengzhou-hub opened a new pull request, #100:
URL: https://github.com/apache/flink-ml/pull/100
This PR adds a `LabeledPointWithWeightGenerator` to `flink-ml-benchmark`
module.
`LabeledPointWithWeightGenerator` is used to generate vector-typed features
with double-typed label and w
[
https://issues.apache.org/jira/browse/FLINK-27655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27655:
-
Fix Version/s: table-store-0.2.0
> Implement Avro File statistic collector
> ---
[
https://issues.apache.org/jira/browse/FLINK-27656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27656:
-
Fix Version/s: table-store-0.2.0
> Add parquet file format
>
>
>
Zheng Hu created FLINK-27656:
Summary: Add parquet file format
Key: FLINK-27656
URL: https://issues.apache.org/jira/browse/FLINK-27656
Project: Flink
Issue Type: Sub-task
Reporter: Z
Zheng Hu created FLINK-27655:
Summary: Implement Avro File statistic collector
Key: FLINK-27655
URL: https://issues.apache.org/jira/browse/FLINK-27655
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #19738:
URL: https://github.com/apache/flink/pull/19738#issuecomment-1128331729
## CI report:
* 82819ac1be56db4b1c74d7b62d5c9265ce4b191a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
deadwind4 opened a new pull request, #19738:
URL: https://github.com/apache/flink/pull/19738
## What is the purpose of the change
fix typo
## Brief change log
- *Fix typo of ElasticsearchSinkBuilderBase#setConnectionPassword comment*
## Verifying this change
wangyang0918 commented on PR #217:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/217#issuecomment-1128330687
> We can easily fix this tomorrow by the copy trick we did in other
incompatible cases :)
@gyfora Flink is now providing an experimental REST API specificatio
wangyang0918 commented on PR #217:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/217#issuecomment-1128328901
@morhidi You could find the following exception in the e2e tests with
default namespace. We do not print the operator logs when `watchNamespaces`
enabled. This also
wuchong merged PR #19728:
URL: https://github.com/apache/flink/pull/19728
--
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: issues-unsubscr...@flink.apach
[
https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537871#comment-17537871
]
Aitozi commented on FLINK-27576:
I have not started, I will prepare the PR this week.
>
zhipeng93 commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r874281393
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java:
##
@@ -100,4 +100,22 @@ public boolean validate(T value) {
public static ParamValidat
zhipeng93 commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r874284646
##
flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryclassfication/BinaryClassificationEvaluator.java:
##
@@ -0,0 +1,724 @@
+/*
+ * Licensed to the Apache S
zhipeng93 commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r874281393
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java:
##
@@ -100,4 +100,22 @@ public boolean validate(T value) {
public static ParamValidat
zhipeng93 commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r874281167
##
flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryclassfication/BinaryClassificationEvaluator.java:
##
@@ -0,0 +1,724 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-27652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27652:
--
Description:
h3. Issue Description
When enabling {{commit.force-compact}} for the partitioned managed
[
https://issues.apache.org/jira/browse/FLINK-27631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-27631:
-
Affects Version/s: 1.13.6
(was: 1.14.4)
> Datastream job combined with table
[
https://issues.apache.org/jira/browse/FLINK-27631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc updated FLINK-27631:
-
Affects Version/s: 1.14.4
(was: 1.13.6)
> Datastream job combined with table
Aitozi commented on code in PR #213:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/213#discussion_r874248265
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventUtils.java:
##
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the Apach
James Busche created FLINK-27654:
Summary: Older jackson-databind found in
/flink-kubernetes-shaded-1.0-SNAPSHOT.jar
Key: FLINK-27654
URL: https://issues.apache.org/jira/browse/FLINK-27654
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537814#comment-17537814
]
Yufan Sheng edited comment on FLINK-27611 at 5/16/22 9:50 PM:
[
https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537814#comment-17537814
]
Yufan Sheng commented on FLINK-27611:
-
I can. This should be a bug on the Pulsar con
[
https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537788#comment-17537788
]
Alexis Sarda-Espinosa commented on FLINK-27504:
---
But that wouldn't be a pr
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537773#comment-17537773
]
Thomas Weise commented on FLINK-27650:
--
That's as per
[https://github.com/apache/f
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27650:
-
Priority: Major (was: Blocker)
> First environment variable of top level pod template is lost
>
gyfora commented on PR #217:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/217#issuecomment-1128084664
@morhidi very confusing error message indeed. We can easily fix this
tomorrow by the copy trick we did in other incompatible cases :)
--
This is an automated message fro
morhidi commented on PR #217:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/217#issuecomment-1128077507
> @wangyang0918 Do you have any idea why the CI test `CI / e2e_ci (Default
configuration, default, flink:1.13, v1_13) (pull_request) ` is braking? Made a
simple test loca
MartijnVisser merged PR #19736:
URL: https://github.com/apache/flink/pull/19736
--
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: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537748#comment-17537748
]
Martijn Visser commented on FLINK-24433:
Merged db6baf47130872ccdcd56949510704bb
[
https://issues.apache.org/jira/browse/FLINK-27649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27649.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: 772ac6341e704c31fd4b820ce98dff
MartijnVisser merged PR #19735:
URL: https://github.com/apache/flink/pull/19735
--
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: issues-unsubscr...@flink
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27650:
---
Fix Version/s: kubernetes-operator-1.0.0
> First environment variable of top level pod template is l
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27650:
---
Priority: Blocker (was: Major)
> First environment variable of top level pod template is lost
> ---
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537743#comment-17537743
]
Gyula Fora commented on FLINK-27650:
[~thw] , I could reproduce this. Seems to be a
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27650:
---
Affects Version/s: kubernetes-operator-0.1.0
(was: 1.14.4)
> First enviro
[
https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537734#comment-17537734
]
Gyula Fora commented on FLINK-27650:
Thank you [~sparadis] for reporting this, we'll
gyfora commented on code in PR #216:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/216#discussion_r874060431
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SavepointObserver.java:
##
@@ -131,15 +136,72 @@ private Optiona
gyfora commented on code in PR #216:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/216#discussion_r874058450
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SavepointObserver.java:
##
@@ -131,15 +136,72 @@ private Optiona
gyfora commented on code in PR #213:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/213#discussion_r874051109
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventUtils.java:
##
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-27608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537721#comment-17537721
]
Zhilong Hong commented on FLINK-27608:
--
I've read the log you uploaded. In fact, th
flinkbot commented on PR #19737:
URL: https://github.com/apache/flink/pull/19737#issuecomment-1127944155
## CI report:
* 78c8d261f804f0d1f57b848db5b2dc6bd33c8a25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19736:
URL: https://github.com/apache/flink/pull/19736#issuecomment-1127944034
## CI report:
* cc5d7da1306f101a6e6f532130e8c7a8729cde4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1 - 100 of 273 matches
Mail list logo
