lindong28 commented on code in PR #71:
URL: https://github.com/apache/flink-ml/pull/71#discussion_r843468258
##
flink-ml-benchmark/README.md:
##
@@ -0,0 +1,172 @@
+# Flink ML Benchmark Getting Started
+
+This document provides instructions on how to run benchmarks on Flink ML's
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517832#comment-17517832
]
Gyula Fora commented on FLINK-27029:
Yes
> DeploymentValidator should take default flink config
mayuehappy commented on PR #19259:
URL: https://github.com/apache/flink/pull/19259#issuecomment-1089823724
> @mayuehappy, thanks for your contribution to reduce the frequency of the
timer registration. I left the minor comments for your changes. BTW,
@mayuehappy, could you fix the typo in
mayuehappy commented on code in PR #19259:
URL: https://github.com/apache/flink/pull/19259#discussion_r843463168
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java:
##
@@ -333,6 +337,10 @@ private boolean isStateTimedOut(final ComputationState
state,
flinkbot commented on PR #19366:
URL: https://github.com/apache/flink/pull/19366#issuecomment-1089820185
## CI report:
* 4b990b04e506d2c5cb9837413b98d86f11dc109a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-24660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517821#comment-17517821
]
Mason Chen commented on FLINK-24660:
[~renqs] would you or someone else be able to look at this
[
https://issues.apache.org/jira/browse/FLINK-24660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24660:
---
Labels: pull-request-available stale-assigned starter (was: stale-assigned
starter)
>
mas-chen opened a new pull request, #19366:
URL: https://github.com/apache/flink/pull/19366
## What is the purpose of the change
Allow setting KafkaSubscriber in KafkaSourceBuilder so that users can supply
custom implementations.
## Brief change log
* Expose a setter
[
https://issues.apache.org/jira/browse/FLINK-27068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517816#comment-17517816
]
CaoYu commented on FLINK-27068:
---
This problem may arise with a very small probability. But in any case, it
[
https://issues.apache.org/jira/browse/FLINK-27068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517815#comment-17517815
]
CaoYu commented on FLINK-27068:
---
It may be because the order in which the data is passed to the downstream
luoyuxia commented on code in PR #19193:
URL: https://github.com/apache/flink/pull/19193#discussion_r843440633
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTable.java:
##
@@ -94,4 +97,15 @@ public SqlNodeList getPartitionSpec() {
[
https://issues.apache.org/jira/browse/FLINK-25716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517810#comment-17517810
]
Tianjun Weng commented on FLINK-25716:
--
Hi [~martijnvisser], I'm interesting in this, can assigned
[
https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-26394:
---
Assignee: Gen Luo
> CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires
>
[
https://issues.apache.org/jira/browse/FLINK-27028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517805#comment-17517805
]
Yang Wang commented on FLINK-27028:
---
Actually, I am not sure about the current situation of "JarUpload
Huang Xingbo created FLINK-27068:
Summary: test_keyed_min_and_max and test_keyed_min_by_and_max_by
failed in py36,37
Key: FLINK-27068
URL: https://issues.apache.org/jira/browse/FLINK-27068
Project:
[
https://issues.apache.org/jira/browse/FLINK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517801#comment-17517801
]
Dian Fu commented on FLINK-27025:
-
[~marsupialtail] I just closed this ticket as I think it should not
[
https://issues.apache.org/jira/browse/FLINK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517800#comment-17517800
]
Dian Fu commented on FLINK-27025:
-
[~martijnvisser] From the attachment, I think [~marsupialtail] is
[
https://issues.apache.org/jira/browse/FLINK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27025.
---
Resolution: Not A Problem
> Cannot read parquet file, after putting the jar in the right place with right
yunfengzhou-hub commented on PR #71:
URL: https://github.com/apache/flink-ml/pull/71#issuecomment-1089759537
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
luoyuxia commented on PR #19329:
URL: https://github.com/apache/flink/pull/19329#issuecomment-1089751497
BTW, the CI is failed.
--
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
luoyuxia commented on code in PR #19329:
URL: https://github.com/apache/flink/pull/19329#discussion_r843408437
##
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl:
##
@@ -548,6 +551,18 @@ SqlAlterTable SqlAlterTable() :
mayuehappy commented on code in PR #19259:
URL: https://github.com/apache/flink/pull/19259#discussion_r843428783
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java:
##
@@ -97,6 +100,18 @@ public void
setNewPartialMatches(PriorityQueue
[
https://issues.apache.org/jira/browse/FLINK-27011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517799#comment-17517799
]
Dian Fu commented on FLINK-27011:
-
[~martijnvisser] Good advice. There is still no such validation. I
Dian Fu created FLINK-27067:
---
Summary: Prevent usage of deprecated APIs in PyFlink examples
Key: FLINK-27067
URL: https://issues.apache.org/jira/browse/FLINK-27067
Project: Flink
Issue Type:
mayuehappy commented on code in PR #19259:
URL: https://github.com/apache/flink/pull/19259#discussion_r843427786
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java:
##
@@ -417,6 +405,9 @@ private void processEvent(NFAState nfaState, IN
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517797#comment-17517797
]
Yang Wang commented on FLINK-27029:
---
I think what you mean is we need to verify the effective flink
[
https://issues.apache.org/jira/browse/FLINK-27065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517796#comment-17517796
]
Yang Wang commented on FLINK-27065:
---
This is a reasonable change for me. AFAIK, it just looks like
[
https://issues.apache.org/jira/browse/FLINK-26140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517793#comment-17517793
]
Yang Wang commented on FLINK-26140:
---
Introducing the lastStableSpec makes sense to me. Once the job is
[
https://issues.apache.org/jira/browse/FLINK-26952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517788#comment-17517788
]
Zhu Zhu edited comment on FLINK-26952 at 4/6/22 3:14 AM:
-
[~slinkydeveloper]
[
https://issues.apache.org/jira/browse/FLINK-26952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517788#comment-17517788
]
Zhu Zhu edited comment on FLINK-26952 at 4/6/22 3:12 AM:
-
[~slinkydeveloper]
[
https://issues.apache.org/jira/browse/FLINK-26952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517788#comment-17517788
]
Zhu Zhu commented on FLINK-26952:
-
[~slinkydeveloper] FYI, there is already a ticket to migrate TPCDS
[
https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517785#comment-17517785
]
jeff-zou commented on FLINK-27018:
--
It had the same problem when i tried it with flink 1.14.4.
Martijn
[
https://issues.apache.org/jira/browse/FLINK-26748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leishuiyu updated FLINK-26748:
--
Summary: flink taskmanager metaspace oom (was: flink jobmanager metaspace
oom)
> flink taskmanager
[
https://issues.apache.org/jira/browse/FLINK-26748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leishuiyu updated FLINK-26748:
--
Description:
submit job to flink,the flink taskmanager metaspace keep increase ,until oom
h1.
[
https://issues.apache.org/jira/browse/FLINK-26748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leishuiyu closed FLINK-26748.
-
Fix Version/s: (was: 1.14.3)
Resolution: Done
> flink jobmanager metaspace oom
>
[
https://issues.apache.org/jira/browse/FLINK-26748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517782#comment-17517782
]
leishuiyu commented on FLINK-26748:
---
the question is fix
the message pipeline is
[
https://issues.apache.org/jira/browse/FLINK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517781#comment-17517781
]
Kenny Ma commented on FLINK-27055:
--
Seems to be related to Watermark as we can see in the stacktrace. I
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517779#comment-17517779
]
Yang Wang commented on FLINK-27060:
---
I am afraid only the job related config options(e.g.
[
https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517778#comment-17517778
]
jinfeng commented on FLINK-20951:
-
[~jark] [~lirui] I encountered the same problem in version 1.12.2.
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517773#comment-17517773
]
LuNng Wang edited comment on FLINK-27010 at 4/6/22 2:25 AM:
[~martijnvisser]
schumiyi commented on PR #18914:
URL: https://github.com/apache/flink/pull/18914#issuecomment-1089674015
Appreciate if you can help take a look. @godfreyhe @wuchong
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517773#comment-17517773
]
LuNng Wang commented on FLINK-27010:
[~martijnvisser] [~fsk119] When we use SQL Client, '-i', '-l'
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27010:
---
Description:
'-i' '-j' and '-l' only be set in startup options.
I want to add the following
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27010:
---
Description:
'-i' '-j' and '-l' only be set in startup options.
I want to add the following
[
https://issues.apache.org/jira/browse/FLINK-27032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517769#comment-17517769
]
Dian Fu commented on FLINK-27032:
-
[~mapohl] It should have been fixed in release-1.15. Could you rebase
[
https://issues.apache.org/jira/browse/FLINK-27032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-27032:
Fix Version/s: (was: 1.15.0)
> PyFlink end-to-end test failed due to str object not having expected
[
https://issues.apache.org/jira/browse/FLINK-27032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27032.
---
Resolution: Invalid
> PyFlink end-to-end test failed due to str object not having expected
> attribute
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517768#comment-17517768
]
Shengkai Fang commented on FLINK-27010:
---
[~martijnvisser] +1. The flink-conf.yaml is cluster-level
[
https://issues.apache.org/jira/browse/FLINK-25480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25480:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-26796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26796:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25814:
---
Labels: auto-deprioritized-major test-stability (was: stale-major
test-stability)
[
https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26569:
---
Labels: auto-deprioritized-critical test-stability (was: stale-critical
test-stability)
[
https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22090:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
auto-deprioritized-minor
[
https://issues.apache.org/jira/browse/FLINK-19033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19033:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-19366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19366:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
flinkbot commented on PR #19365:
URL: https://github.com/apache/flink/pull/19365#issuecomment-1089429467
## CI report:
* 7084d3171bea953c4326c023b37a3fdad7d282b9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27064:
---
Labels: pull-request-available (was: )
> Centralize ArchUnit rules for production code
>
JingGe opened a new pull request, #19365:
URL: https://github.com/apache/flink/pull/19365
## What is the purpose of the change
This PR will move ArchUnit rules defined for production code test from the
test source folder to the source folder. The reason is that the rules built
mbalassi commented on code in PR #155:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/155#discussion_r843292106
##
docs/content/docs/operations/helm.md:
##
@@ -109,3 +109,24 @@ spec:
skipCrds: true
...
```
+
+## Advanced customization techniques
+The
[
https://issues.apache.org/jira/browse/FLINK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517716#comment-17517716
]
Kenny Ma commented on FLINK-27055:
--
I have seen this issue in 1.11.2 and 1.12.0. Will try the newer
[
https://issues.apache.org/jira/browse/FLINK-27066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-27066:
-
Assignee: Alexander Fedulov
> Reintroduce e2e tests in ES as Java tests.
>
Alexander Fedulov created FLINK-27066:
-
Summary: Reintroduce e2e tests in ES as Java tests.
Key: FLINK-27066
URL: https://issues.apache.org/jira/browse/FLINK-27066
Project: Flink
Issue
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r843175972
##
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java:
##
@@ -57,6 +58,10 @@
/** A collection of utility methods for
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517631#comment-17517631
]
Gyula Fora edited comment on FLINK-27029 at 4/5/22 6:25 PM:
What I mean is
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517631#comment-17517631
]
Gyula Fora edited comment on FLINK-27029 at 4/5/22 6:25 PM:
What I mean is
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517631#comment-17517631
]
Gyula Fora commented on FLINK-27029:
What I mean is that we should merge the default config with the
[
https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27023:
--
Assignee: Nicholas Jiang
> Merge default flink and operator configuration settings for the
[
https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517627#comment-17517627
]
Gyula Fora commented on FLINK-27023:
that would be great, thank you
> Merge default flink and
[
https://issues.apache.org/jira/browse/FLINK-27065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27065:
---
Description:
Currently we store complete spec objects in the status. This leads to large CRD
[
https://issues.apache.org/jira/browse/FLINK-27065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517622#comment-17517622
]
Gyula Fora commented on FLINK-27065:
cc [~thw]
[~wangyang0918] do you see any problems with this
[
https://issues.apache.org/jira/browse/FLINK-27005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27005:
--
Assignee: Gyula Fora
> Bump CRD version to v1beta1
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-27065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27065:
--
Assignee: Gyula Fora
> Store lastReconciledSpec as String in status
>
[
https://issues.apache.org/jira/browse/FLINK-27065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27065:
---
Parent: FLINK-27021
Issue Type: Sub-task (was: Improvement)
> Store lastReconciledSpec as
Jing Ge created FLINK-27064:
---
Summary: Centralize ArchUnit rules for production code
Key: FLINK-27064
URL: https://issues.apache.org/jira/browse/FLINK-27064
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27065:
--
Summary: Store lastReconciledSpec as String in status
Key: FLINK-27065
URL: https://issues.apache.org/jira/browse/FLINK-27065
Project: Flink
Issue Type:
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r843115118
##
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java:
##
@@ -296,10 +296,10 @@ private static IntermediateResult
flinkbot commented on PR #19364:
URL: https://github.com/apache/flink/pull/19364#issuecomment-1089117617
## CI report:
* f21e0c16f92211144877351735df2f21c0624628 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27063:
---
Labels: pull-request-available (was: )
> Upgrade Hive 2.3 connector to version 2.3.6
>
MartijnVisser opened a new pull request, #19364:
URL: https://github.com/apache/flink/pull/19364
## What is the purpose of the change
* Upgrade the Hive 2.3 connector to the latest available version, 2.3.9
## Brief change log
* Renamed connector from Hive 2.3.6 to 2.3.9
Martijn Visser created FLINK-27063:
--
Summary: Upgrade Hive 2.3 connector to version 2.3.6
Key: FLINK-27063
URL: https://issues.apache.org/jira/browse/FLINK-27063
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517603#comment-17517603
]
Martijn Visser commented on FLINK-27010:
[~ana4] The link you've provided
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r843084714
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/SchedulerBenchmarkBase.java:
##
@@ -18,16 +18,19 @@
package
[
https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517581#comment-17517581
]
Nicholas Jiang commented on FLINK-27023:
[~gyfora], do anyone work on this ticket? If no, I
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r843083347
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/SchedulerBenchmarkBase.java:
##
@@ -18,16 +18,19 @@
package
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517576#comment-17517576
]
Nicholas Jiang commented on FLINK-27029:
[~gyfora], do you mean that in
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517570#comment-17517570
]
Jay Ghiya edited comment on FLINK-26793 at 4/5/22 5:04 PM:
---
Hi [~echauchot] -
[
https://issues.apache.org/jira/browse/FLINK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517569#comment-17517569
]
Martijn Visser commented on FLINK-27055:
[~kma] I don't, but there have been many changes since
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517570#comment-17517570
]
Jay Ghiya commented on FLINK-26793:
---
Hi [~echauchot] - Regardin "query is not prepared ..." -> No this
[
https://issues.apache.org/jira/browse/FLINK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517561#comment-17517561
]
Kenny Ma commented on FLINK-27055:
--
[~martijnvisser] Thanks for the suggestion. I can give it a try but
mbalassi commented on PR #129:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/129#issuecomment-1089016628
Thanks @zeus1ammon I will merge this latest tomorrow, might slightly modify
wording of the comment. In principle I like it.
--
This is an automated message from the
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r843011335
##
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java:
##
@@ -57,6 +58,10 @@
/** A collection of utility methods for
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r843010096
##
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingDefaultExecutionGraphBuilder.java:
##
@@ -56,12 +57,23 @@
private static final Logger
MartijnVisser closed pull request #6: [FLINK-X] This is a PR title that
doesn't meet the requirements
URL: https://github.com/apache/flink-connector-elasticsearch/pull/6
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-27062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27062.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master:
MartijnVisser merged PR #1:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/1
--
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:
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r842964196
##
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerBuilder.java:
##
@@ -66,13 +66,8 @@ private
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r842960738
##
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesBuilder.java:
##
@@ -180,7 +172,7 @@ public TaskManagerServices build() {
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r842959738
##
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskSubmissionTestEnvironment.java:
##
@@ -112,9 +111,15 @@ private TaskSubmissionTestEnvironment(
zentol commented on code in PR #19351:
URL: https://github.com/apache/flink/pull/19351#discussion_r842959149
##
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotUtils.java:
##
@@ -71,11 +77,8 @@ public static ResourceProfile
[
https://issues.apache.org/jira/browse/FLINK-27062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27062:
---
Labels: pull-request-available (was: )
> Add Boring Cyborg bot to
1 - 100 of 207 matches
Mail list logo
