[
https://issues.apache.org/jira/browse/FLINK-28286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-28286:
--
Fix Version/s: 1.16.0
> move “enablechangelog” constant out of flink-streaming-java mo
[
https://issues.apache.org/jira/browse/FLINK-28286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-28286:
-
Assignee: Yanfei Lei
> move “enablechangelog” constant out of flink-streaming-j
MartijnVisser commented on PR #17325:
URL: https://github.com/apache/flink/pull/17325#issuecomment-1177677859
Won't fix
--
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 u
MartijnVisser closed pull request #17325: [FLINK-24337] fix WEB UI build
failure on windows
URL: https://github.com/apache/flink/pull/17325
--
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 specif
[
https://issues.apache.org/jira/browse/FLINK-24337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24337.
--
Resolution: Won't Fix
> WEB UI build failure in Flink 1.15-SNAPSHOT current code
> ---
gyfora commented on code in PR #278:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/278#discussion_r915920165
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java:
##
@@ -494,4 +500,42 @@ public stati
echauchot commented on code in PR #19935:
URL: https://github.com/apache/flink/pull/19935#discussion_r915889897
##
flink-core/src/main/java/org/apache/flink/api/common/io/OutputFormatBase.java:
##
@@ -97,21 +108,35 @@ private void tryAcquire(int permits) throws IOException {
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563810#comment-17563810
]
Martijn Visser commented on FLINK-16419:
The default value for {{transactional.i
echauchot commented on PR #19935:
URL: https://github.com/apache/flink/pull/19935#issuecomment-1177697600
@flinkbot run azure
--
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 comm
[
https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563811#comment-17563811
]
Martijn Visser commented on FLINK-22739:
[~echauchot] Do you think we can close
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28338:
---
Summary: Enable the possibility to allow leading zeros for number in JSON
(was:
org.apache
MartijnVisser commented on PR #20061:
URL: https://github.com/apache/flink/pull/20061#issuecomment-1177700663
@liuzhuang2017 I think you'll need to rebase first
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
rkhachatryan commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1177700779
I've checked it locally and found that `WindowDistinctAggregateITCase` fails
with `Exceeded checkpoint tolerable failure threshold`, which is preceeded by
```
Caused by: org.a
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28338:
---
Issue Type: New Feature (was: Improvement)
> Enable the possibility to allow leading zeros
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28338:
---
Affects Version/s: (was: 1.13.6)
> Enable the possibility to allow leading zeros for num
mbalassi opened a new pull request, #301:
URL: https://github.com/apache/flink-kubernetes-operator/pull/301
Improves the current examples, so that they launch streaming jobs. Tested
locally. Screenshot if the statement set job below.
Resolution: Fixed
> CassandraSinkBaseTest.testTimeoutE
asfgit closed pull request #286: [FLINK-28300] Fix helm lint invalid Yaml
document separator
URL: https://github.com/apache/flink-kubernetes-operator/pull/286
--
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-28300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-28300.
--
Resolution: Fixed
[4c8875a|https://github.com/apache/flink-kubernetes-operator/commit/4c8875ab
[
https://issues.apache.org/jira/browse/FLINK-28447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-28447:
--
Assignee: Márton Balassi
> Create Kubernetes Operator PR template
> -
Márton Balassi created FLINK-28450:
--
Summary: Run helm linter in k8s operator ci
Key: FLINK-28450
URL: https://issues.apache.org/jira/browse/FLINK-28450
Project: Flink
Issue Type: Improvemen
gyfora opened a new pull request, #302:
URL: https://github.com/apache/flink-kubernetes-operator/pull/302
Clean up and formalize operator metric scopes:
- `system`: Operator level metrics
- `namespace`: Resource Namespace level metrics (belonging to one of the
watched namespaces)
gyfora commented on PR #302:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/302#issuecomment-1177748199
cc @SteNicholas @morhidi
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-28297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28297:
---
Labels: pull-request-available (was: )
> Incorrect metric group order for namespaced operat
gyfora closed pull request #268: [FLINK-27914] Integrate JOSDK metrics with
Flink Metrics reporter
URL: https://github.com/apache/flink-kubernetes-operator/pull/268
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
gyfora commented on PR #268:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/268#issuecomment-1177748816
closing this in favor of
https://github.com/apache/flink-kubernetes-operator/pull/302
--
This is an automated message from the Apache Git Service.
To respond to the
gyfora merged PR #301:
URL: https://github.com/apache/flink-kubernetes-operator/pull/301
--
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
syhily commented on code in PR #19972:
URL: https://github.com/apache/flink/pull/19972#discussion_r915990147
##
flink-python/pyflink/datastream/connectors/pulsar.py:
##
@@ -138,10 +138,10 @@ def latest() -> 'StartCursor':
return StartCursor(JStartCursor.latest())
zentol commented on code in PR #20187:
URL: https://github.com/apache/flink/pull/20187#discussion_r915953497
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/metrics/MetricsWrapper.java:
##
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
liuzhuang2017 commented on PR #20061:
URL: https://github.com/apache/flink/pull/20061#issuecomment-1177788282
@MartijnVisser , Thanks a lot for your suggestion, I will try it out.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
mbalassi opened a new pull request, #303:
URL: https://github.com/apache/flink-kubernetes-operator/pull/303
Adds helm chart linting to ci and fixes a warning in the chart.
Please observe this run I triggered on my own fork to simulate an
intentional failure:
https://github.com/mba
[
https://issues.apache.org/jira/browse/FLINK-28450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28450:
---
Labels: pull-request-available (was: )
> Run helm linter in k8s operator ci
> -
[
https://issues.apache.org/jira/browse/FLINK-28448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563839#comment-17563839
]
Weijie Guo commented on FLINK-28448:
cc [~kevin.cyj]
> BoundedDataTestBase has pot
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-28338:
-
Affects Version/s: 1.13.6
> Enable the possibility to allow leading zeros for number in JSON
> -
reswqa opened a new pull request, #20203:
URL: https://github.com/apache/flink/pull/20203
## What is the purpose of the change
*fix bug in BoundedDataTestBase when enable compression.*
## Brief change log
- *Migrate BoundedDataTestBase and it's subclass to JUnit
[
https://issues.apache.org/jira/browse/FLINK-28448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28448:
---
Labels: pull-request-available (was: )
> BoundedDataTestBase has potential problem when com
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-28338:
-
Issue Type: Improvement (was: New Feature)
> Enable the possibility to allow leading zeros for number i
flinkbot commented on PR #20203:
URL: https://github.com/apache/flink/pull/20203#issuecomment-1177825228
## CI report:
* de00941a4710784c39dd6f2772535b584060e7f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morhidi opened a new pull request, #304:
URL: https://github.com/apache/flink-kubernetes-operator/pull/304
- Added support for config overrides from an additional config folder,
specified by an env variable DYNAMIC_CONF_DIR
- Since it is a relative advanced feature added a kustomize e
[
https://issues.apache.org/jira/browse/FLINK-28445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28445:
---
Labels: pull-request-available (was: )
> Support operator configuration from multiple confi
rkhachatryan commented on code in PR #20152:
URL: https://github.com/apache/flink/pull/20152#discussion_r916034348
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeIteratorWithCache.java:
##
@@ -0,0 +1,367 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563894#comment-17563894
]
Yordan Pavlov commented on FLINK-16419:
---
[~martijnvisser] From what you are saying
MartijnVisser commented on PR #20126:
URL: https://github.com/apache/flink/pull/20126#issuecomment-1177954837
@zhuyufeng0809 @qingwei91 We now have the situation that there are two
identical Jira tickets with FLINK-16024 (which was there first) and FLINK-19651
(which is a duplicate). Both h
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r916115706
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/util/ClientMutableURLClassLoader.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foun
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r916119867
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/resource/ResourceManager.java:
##
@@ -69,43 +70,67 @@ public URLClassLoader getUserClassLoader(
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r916123571
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/utils/BatchTestBase.scala:
##
@@ -72,6 +72,17 @@ class BatchTestBase extends Ba
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r916126391
##
flink-core/src/main/java/org/apache/flink/util/MutableURLClassLoader.java:
##
@@ -31,10 +35,38 @@ public abstract class MutableURLClassLoader extends
URLClassLoader
dalongliu created FLINK-28451:
-
Summary: HiveFunctionDefinitionFactory load udf using user
classloader instead of thread context classloader
Key: FLINK-28451
URL: https://issues.apache.org/jira/browse/FLINK-28451
[
https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563906#comment-17563906
]
dalongliu commented on FLINK-28451:
---
cc [~luoyuxia]
> HiveFunctionDefinitionFactory
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r916138087
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/ExecutionContext.java:
##
@@ -53,12 +54,14 @@ public class ExecutionContext
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563910#comment-17563910
]
Martijn Visser commented on FLINK-16419:
[~YordanPavlov] Why do you think that's
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28338:
---
Issue Type: New Feature (was: Improvement)
> Enable the possibility to allow leading zeros
lsyldliu commented on code in PR #20001:
URL: https://github.com/apache/flink/pull/20001#discussion_r916142999
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/resource/ResourceManager.java:
##
@@ -69,43 +70,67 @@ public URLClassLoader getUserClassLoader(
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28338:
---
Affects Version/s: (was: 1.13.6)
> Enable the possibility to allow leading zeros for num
afedulov commented on code in PR #20127:
URL: https://github.com/apache/flink/pull/20127#discussion_r916163668
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java:
##
@@ -87,5 +87,11 @@ public class CsvFormatOptions {
afedulov commented on code in PR #20127:
URL: https://github.com/apache/flink/pull/20127#discussion_r916163668
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java:
##
@@ -87,5 +87,11 @@ public class CsvFormatOptions {
afedulov commented on code in PR #20127:
URL: https://github.com/apache/flink/pull/20127#discussion_r916163668
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java:
##
@@ -87,5 +87,11 @@ public class CsvFormatOptions {
pnowojski merged PR #20202:
URL: https://github.com/apache/flink/pull/20202
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563760#comment-17563760
]
Piotr Nowojski edited comment on FLINK-28357 at 7/7/22 7:18 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563927#comment-17563927
]
Yordan Pavlov commented on FLINK-16419:
---
Savepoint usability shouldn't be bound to
afedulov opened a new pull request, #20204:
URL: https://github.com/apache/flink/pull/20204
The settings layout changed in the newer IntelliJ versions. This hotfix
updates the docs to incorporate the up-to-date instructions.
--
This is an automated message from the Apache Git Service.
To
flinkbot commented on PR #20204:
URL: https://github.com/apache/flink/pull/20204#issuecomment-1178242624
## CI report:
* 52b07b72d0010d3cec91a8a226916e0b15de31fc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
alpinegizmo merged PR #554:
URL: https://github.com/apache/flink-web/pull/554
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16952:
---
Labels: auto-unassigned pull-request-available stale-assigned (was:
auto-unassigned pull-re
[
https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17231:
---
Labels: auto-unassigned pull-request-available stale-assigned (was:
auto-unassigned pull-re
[
https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13503:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was: a
[
https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14527:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Fli
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13247:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Fli
[
https://issues.apache.org/jira/browse/FLINK-11934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-11934:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
stale-assigned (w
[
https://issues.apache.org/jira/browse/FLINK-13218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13218:
---
Labels: auto-deprioritized-major auto-unassigned stale-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-13213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13213:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was: a
[
https://issues.apache.org/jira/browse/FLINK-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-13301:
---
Labels: auto-deprioritized-major auto-unassigned stale-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-12130:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was: a
[
https://issues.apache.org/jira/browse/FLINK-11463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-11463:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was: a
[
https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-9219:
--
Labels: auto-deprioritized-major auto-unassigned stale-minor (was:
auto-deprioritized-major au
[
https://issues.apache.org/jira/browse/FLINK-27891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27891:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-10740:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor usabilit
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-10206:
---
Labels: auto-deprioritized-major auto-unassigned stale-minor (was:
auto-deprioritized-major
charles-tan opened a new pull request, #20205:
URL: https://github.com/apache/flink/pull/20205
## What is the purpose of the change
The goal of this PR is to address a memory leak where the Kafka Producer
does not get cleaned up after kafka commit is successful.
##
[
https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28250:
---
Labels: pull-request-available (was: )
> exactly-once sink kafka cause out of memory
>
flinkbot commented on PR #20205:
URL: https://github.com/apache/flink/pull/20205#issuecomment-1178341140
## CI report:
* 7304f9dd3c2c65dd985f5de831496b091b58b556 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564023#comment-17564023
]
Jing Ge commented on FLINK-10206:
-
There is a new HBaseDynamicTableSink since the last c
bzhaoopenstack commented on PR #20193:
URL: https://github.com/apache/flink/pull/20193#issuecomment-1178417684
> @bzhaoopenstack Thanks for the PR, but in order to add support for MariaDB
I would also like to see a test and documentation in place.
Thanks very much for reply and sugges
JackWangCS opened a new pull request, #20206:
URL: https://github.com/apache/flink/pull/20206
## What is the purpose of the change
This PR adds HBaseDelegationTokenProvider to obtain HBase Delegation tokens
using the new delegation token framework.
## Brief change log
JackWangCS commented on code in PR #20206:
URL: https://github.com/apache/flink/pull/20206#discussion_r916381471
##
flink-runtime/src/main/resources/META-INF/services/org.apache.flink.runtime.security.token.DelegationTokenProvider:
##
@@ -14,3 +14,4 @@
# limitations under the L
[
https://issues.apache.org/jira/browse/FLINK-25909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25909:
---
Labels: pull-request-available (was: )
> Move HBase token obtain functionality into HBaseDe
flinkbot commented on PR #20206:
URL: https://github.com/apache/flink/pull/20206#issuecomment-1178425468
## CI report:
* 9ccb31920dd2de1f7c4aedce50fd1e194fc5ac80 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhangjingcun created FLINK-28452:
Summary: "Reduce" and "aggregate" operations of "window_all" are
supported in Python datastream API
Key: FLINK-28452
URL: https://issues.apache.org/jira/browse/FLINK-28452
[
https://issues.apache.org/jira/browse/FLINK-28452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-28452:
---
Assignee: zhangjingcun
> "Reduce" and "aggregate" operations of "window_all" are supported in Pytho
[
https://issues.apache.org/jira/browse/FLINK-28452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28452:
Affects Version/s: (was: 1.15.1)
> "Reduce" and "aggregate" operations of "window_all" are supported i
lincoln-lil commented on PR #19983:
URL: https://github.com/apache/flink/pull/19983#issuecomment-1178431723
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific co
wingwuyao closed pull request #20199: Update and rename
docs/content/docs/dev/datastream/event-time/generat…
URL: https://github.com/apache/flink/pull/20199
--
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
dianfu merged PR #20201:
URL: https://github.com/apache/flink/pull/20201
--
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-28439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28439.
---
Assignee: LuNing Wang
Resolution: Fixed
Merged to master via 90c8284b10ecad84d2c954efe0a98e8fe87cf1dd
wingwuyao opened a new pull request, #20207:
URL: https://github.com/apache/flink/pull/20207
There seems to be a problem with the spelling of 'punctuated', fix that
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the
flinkbot commented on PR #20207:
URL: https://github.com/apache/flink/pull/20207#issuecomment-1178449071
## CI report:
* 11628bdae7022960a7700d4c710225327d5b2675 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JesseAtSZ commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1178450932
@rkhachatryan If we modify `FINALIZE_CHECKPOINT_FAILURE` has a great impact,
we can change `initializeBaseLocationsForCheckpoint` first.
--
This is an automated message from the Apach
zoltar9264 commented on PR #20093:
URL: https://github.com/apache/flink/pull/20093#issuecomment-1178453865
Thanks @rkhachatryan . Done.
--
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 specifi
201 - 300 of 401 matches
Mail list logo
