morhidi commented on code in PR #244:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r884442238
##
flink-kubernetes-webhook/pom.xml:
##
@@ -36,6 +36,19 @@ under the License.
org.apache.flink
flink-kubernetes-operator
wangyang0918 commented on PR #237:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/237#issuecomment-1140726331
For Flink batch jobs, we do not require all the tasks running to indicate
that the Flink job is running. So it does not make sense when we want to use
morhidi commented on code in PR #244:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r884434216
##
flink-kubernetes-webhook/pom.xml:
##
@@ -36,6 +36,19 @@ under the License.
org.apache.flink
flink-kubernetes-operator
zou-can commented on PR #19828:
URL: https://github.com/apache/flink/pull/19828#issuecomment-1140717266
As i commented on https://issues.apache.org/jira/browse/FLINK-27762
The exception we met is in method
**KafkaPartitionSplitReader#removeEmptySplits**. But i can't find any action
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543770#comment-17543770
]
Márton Balassi commented on FLINK-27009:
[~wangyang0918] I do not have well-formed thoughts yet,
[
https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543769#comment-17543769
]
Márton Balassi commented on FLINK-27831:
On second thought the example has heavy dependencies on
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543768#comment-17543768
]
Zili Chen edited comment on FLINK-27834 at 5/30/22 3:42 AM:
Thanks for your
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543768#comment-17543768
]
Zili Chen commented on FLINK-27834:
---
Thanks for your notification [~wangyang0918]. I'll try a look
LadyForest commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884394501
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java:
##
@@ -183,6 +204,84 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543767#comment-17543767
]
Márton Balassi commented on FLINK-27831:
I managed to get the Beam
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543766#comment-17543766
]
Qingsheng Ren commented on FLINK-27762:
---
Thanks a lot for the review [~zoucan] ! What about moving
LadyForest commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884390344
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java:
##
@@ -61,20 +61,24 @@ public
JingsongLi commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884388037
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java:
##
@@ -183,6 +204,84 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543762#comment-17543762
]
Yang Wang commented on FLINK-27834:
---
cc [~Tison] I remember you also have the same idea when fixing
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543761#comment-17543761
]
Gyula Fora commented on FLINK-27834:
Maybe this is not a big concern, would love to hear what
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543760#comment-17543760
]
Gyula Fora commented on FLINK-27834:
yes, the user can have anything in their local directory by
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543759#comment-17543759
]
Yang Wang commented on FLINK-27834:
---
Do you mean we might accidentally bundle the credentials into the
[
https://issues.apache.org/jira/browse/FLINK-25865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-25865:
-
Assignee: Aitozi
> Support to set restart policy of TaskManager pod for native K8s integration
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543758#comment-17543758
]
Gyula Fora commented on FLINK-27834:
I have bad feelings about this, it might lead to accidentally
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543756#comment-17543756
]
zoucan edited comment on FLINK-27762 at 5/30/22 2:50 AM:
-
[~renqs]
Thanks for
flinkbot commented on PR #19843:
URL: https://github.com/apache/flink/pull/19843#issuecomment-1140628091
## CI report:
* 056a8e7e0028e39bd5428a8b40b22454e01a0560 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543756#comment-17543756
]
zoucan edited comment on FLINK-27762 at 5/30/22 2:46 AM:
-
[~renqs]
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543756#comment-17543756
]
zoucan edited comment on FLINK-27762 at 5/30/22 2:45 AM:
-
[~renqs]
Thanks for
deadwind4 opened a new pull request, #19843:
URL: https://github.com/apache/flink/pull/19843
Fix comment typo in TypeExtractor class. Add a `the` before `highest`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
JingsongLi commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884378698
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/TableStoreManagedFactoryTest.java:
##
@@ -256,9 +284,288 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543756#comment-17543756
]
zoucan commented on FLINK-27762:
[~renqs]
Thanks for your effort for this issue.
I‘ve reviewed your
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543756#comment-17543756
]
zoucan edited comment on FLINK-27762 at 5/30/22 2:44 AM:
-
[~renqs]
Thanks for
JingsongLi commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884379183
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java:
##
@@ -55,14 +56,14 @@ public FileStoreReadImpl(
[
https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543753#comment-17543753
]
Yang Wang commented on FLINK-27834:
---
[~gyfora] Given that the copied directory is only used for
Yang Wang created FLINK-27834:
-
Summary: Flink kubernetes operator dockerfile could not work with
podman
Key: FLINK-27834
URL: https://issues.apache.org/jira/browse/FLINK-27834
Project: Flink
tsreaper commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r884370488
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AggregationITCase.java:
##
@@ -0,0 +1,206 @@
+/*
+ * Licensed to the Apache
JingsongLi commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884375368
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -155,7 +155,7 @@ static Map
Aitozi commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r884374610
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java:
##
@@ -79,8 +81,19 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543748#comment-17543748
]
Gyula Fora commented on FLINK-26179:
I think the question of configurable native/canonical savepoint
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543744#comment-17543744
]
Yang Wang commented on FLINK-26179:
---
It is harmless to introduce such a new feature. Do we need to
Huang Xingbo created FLINK-27833:
Summary: PulsarSourceITCase.testTaskManagerFailure failed with
AssertionError
Key: FLINK-27833
URL: https://issues.apache.org/jira/browse/FLINK-27833
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543743#comment-17543743
]
Yang Wang commented on FLINK-27009:
---
[~mbalassi] Maybe you could also share some use cases from your
JingsongLi commented on PR #133:
URL:
https://github.com/apache/flink-table-store/pull/133#issuecomment-1140603513
```
Error: Failures:
Error:DataFilePathFactoryTest.testNoPartition:46
expected:
Huang Xingbo created FLINK-27832:
Summary: SplitAggregateITCase tests failed with Could not acquire
the minimum required resources
Key: FLINK-27832
URL: https://issues.apache.org/jira/browse/FLINK-27832
[
https://issues.apache.org/jira/browse/FLINK-27625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-27625:
Description:
The hint name discuss thread:
[
https://issues.apache.org/jira/browse/FLINK-27625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-27625:
Description:
The hint name discuss thread:
flinkbot commented on PR #19842:
URL: https://github.com/apache/flink/pull/19842#issuecomment-1140596253
## CI report:
* aa380f29ca66553b6f168a177dcedb4563efb05a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-27826:
--
Description:
There is limited support for training high dimensional machine learning models
[
https://issues.apache.org/jira/browse/FLINK-27522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27522:
---
Labels: pull-request-available (was: )
> Ignore max buffers per channel when allocate
1996fanrui opened a new pull request, #19842:
URL: https://github.com/apache/flink/pull/19842
## What is the purpose of the change
Ignore max buffers per channel when allocate buffer
## Brief change log
Ignore max buffers per channel when allocate buffer
##
Márton Balassi created FLINK-27831:
--
Summary: Provide example of Beam on the k8s operator
Key: FLINK-27831
URL: https://issues.apache.org/jira/browse/FLINK-27831
Project: Flink
Issue Type:
KarmaGYZ commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r884357127
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java:
##
@@ -79,8 +81,19 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andreas Hailu updated FLINK-27827:
--
Description:
When creating a {{{}DataStreamSource{}}}, an explicitly bounded input is only
[
https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andreas Hailu updated FLINK-27827:
--
Description:
When creating a {{{}DataStreamSource{}}}, an explicitly bounded input is only
[
https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andreas Hailu updated FLINK-27827:
--
Description:
When creating a {{{}DataStreamSource{}}}, an explicitly bounded input is only
[
https://issues.apache.org/jira/browse/FLINK-27593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543551#comment-17543551
]
Jing Ge edited comment on FLINK-27593 at 5/29/22 9:13 PM:
--
[~lsy] would you
NicoK closed pull request #10607: [FLINK-15298][docs] Fix dependences in the
DataStream API Tutorial doc
URL: https://github.com/apache/flink/pull/10607
--
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
NicoK commented on PR #10607:
URL: https://github.com/apache/flink/pull/10607#issuecomment-1140516269
sorry for not re-reviewing it earlier - since 1.9 is a bit too old now, let
me close this PR
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-27830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TongMeng updated FLINK-27830:
-
Environment:
python 3.6.9
Flink 1.13.0
PyFlink 1.13.0
zookeeper 3.4.14
hadoop 2.10.1
> My Pyflink
[
https://issues.apache.org/jira/browse/FLINK-27830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TongMeng updated FLINK-27830:
-
Description:
I use commd
{code:java}
./flink run --python /home/ubuntu/pyflink/main.py
[
https://issues.apache.org/jira/browse/FLINK-27830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TongMeng updated FLINK-27830:
-
Description:
I use commd
{code:java}
./flink run --python /home/ubuntu/pyflink/main.py
TongMeng created FLINK-27830:
Summary: My Pyflink job could not submit to Flink cluster
Key: FLINK-27830
URL: https://issues.apache.org/jira/browse/FLINK-27830
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543656#comment-17543656
]
Márton Balassi commented on FLINK-26179:
Agreed, based on recent discussion with multiple users
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543655#comment-17543655
]
Márton Balassi commented on FLINK-27009:
[~bgeng777] cool, I assigned the ticket to you then.
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-27009:
--
Assignee: Biao Geng
> Support SQL job submission in flink kubernetes opeartor
>
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r884283585
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegressionParams.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the
itaykat commented on PR #7598:
URL: https://github.com/apache/flink/pull/7598#issuecomment-1140457071
Any updates regarding this one?
--
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543637#comment-17543637
]
Galen Warren commented on FLINK-27813:
--
Cool! Glad it was something simple.
>
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr closed FLINK-27813.
-
Resolution: Won't Fix
> java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0
>
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543624#comment-17543624
]
Oleksandr commented on FLINK-27813:
---
[~galenwarren] I found the issue in the configuration in
[ https://issues.apache.org/jira/browse/FLINK-27813 ]
Oleksandr deleted comment on FLINK-27813:
---
was (Author: JIRAUSER290114):
We have job manager running that is configured via module.yaml(egress and
ingress for kafka topics).
Our stateful
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543616#comment-17543616
]
Oleksandr edited comment on FLINK-27813 at 5/29/22 11:13 AM:
-
We have job
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543616#comment-17543616
]
Oleksandr edited comment on FLINK-27813 at 5/29/22 11:06 AM:
-
[~galenwarren]
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543616#comment-17543616
]
Oleksandr edited comment on FLINK-27813 at 5/29/22 11:06 AM:
-
We have job
gyfora commented on code in PR #244:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r884251881
##
flink-kubernetes-webhook/pom.xml:
##
@@ -36,6 +36,19 @@ under the License.
org.apache.flink
flink-kubernetes-operator
gyfora commented on PR #239:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/239#issuecomment-1140423713
+1 for waiting 1-2 days for the JOSDK fixes before merging
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543616#comment-17543616
]
Oleksandr commented on FLINK-27813:
---
We have job manager running that is configured via
gyfora commented on code in PR #247:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/247#discussion_r884250202
##
docs/content/docs/operations/configuration.md:
##
@@ -50,11 +50,50 @@ defaultConfiguration:
To learn more about metrics and logging configuration
Aitozi commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r884246309
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java:
##
@@ -79,8 +81,19 @@ public class
KarmaGYZ commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r884242067
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java:
##
@@ -79,8 +81,19 @@ public class
ChengkaiYang2022 commented on PR #19681:
URL: https://github.com/apache/flink/pull/19681#issuecomment-1140390388
Hi,Could you @MartijnVisser help to check it ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ChengkaiYang2022 commented on PR #19496:
URL: https://github.com/apache/flink/pull/19496#issuecomment-1140390220
Could you @leonardBang help to check it ?
--
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-27829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27829:
---
Labels: pull-request-available (was: )
> Remove Calcite usages in flink-python
>
flinkbot commented on PR #19841:
URL: https://github.com/apache/flink/pull/19841#issuecomment-1140389937
## CI report:
* 350c8e6fcdb05ca2c890b69b001dbdc4f58f89f4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Chesnay Schepler created FLINK-27829:
Summary: Remove Calcite usages in flink-python
Key: FLINK-27829
URL: https://issues.apache.org/jira/browse/FLINK-27829
Project: Flink
Issue Type:
81 matches
Mail list logo
