flinkbot edited a comment on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439
## CI report:
* 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18297:
URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142
## CI report:
* 7407da5e58ed7e7d093ddfd048e08583a5b5f49e Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18320:
URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892
## CI report:
* bff97576f03c57c0f3fd436c84b4edebcd2ce78a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18320:
URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933540
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
flinkbot edited a comment on pull request #18297:
URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142
## CI report:
* 7407da5e58ed7e7d093ddfd048e08583a5b5f49e Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439
## CI report:
* 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
akalash opened a new pull request #18320:
URL: https://github.com/apache/flink/pull/18320
## What is the purpose of the change
*This PR fixes the hanging in test*
## Verifying this change
It is test
## Does this pull request potentially affect one of t
flinkbot edited a comment on pull request #18314:
URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781
## CI report:
* 0cb7e0c49e9b417f460573885d6d7ba483f18ba1 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439
## CI report:
* 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
fapaul commented on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1008922616
Thanks for the review @gaoyunhaii @alpreu I have addressed all your
comments. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
fapaul commented on a change in pull request #18302:
URL: https://github.com/apache/flink/pull/18302#discussion_r781234978
##
File path:
flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java
##
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software Foundat
fapaul commented on a change in pull request #18302:
URL: https://github.com/apache/flink/pull/18302#discussion_r781234514
##
File path:
flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Fo
fapaul commented on a change in pull request #18302:
URL: https://github.com/apache/flink/pull/18302#discussion_r781233508
##
File path:
flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Fo
flinkbot edited a comment on pull request #18314:
URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781
## CI report:
* 0cb7e0c49e9b417f460573885d6d7ba483f18ba1 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439
## CI report:
* 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
fapaul commented on a change in pull request #18302:
URL: https://github.com/apache/flink/pull/18302#discussion_r781231320
##
File path:
flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java
##
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software Foundat
fapaul commented on a change in pull request #18302:
URL: https://github.com/apache/flink/pull/18302#discussion_r781227987
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/operators/ProcessingTimeService.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache
XComp commented on a change in pull request #18189:
URL: https://github.com/apache/flink/pull/18189#discussion_r781224232
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
##
@@ -935,6 +942,19 @@ protected CleanupJobState
jobReached
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
XComp commented on a change in pull request #18189:
URL: https://github.com/apache/flink/pull/18189#discussion_r781224232
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
##
@@ -935,6 +942,19 @@ protected CleanupJobState
jobReached
Jing Zhang created FLINK-25596:
--
Summary: Specify hash/sortmerge join in SQL hint
Key: FLINK-25596
URL: https://issues.apache.org/jira/browse/FLINK-25596
Project: Flink
Issue Type: Sub-task
twalthr commented on a change in pull request #18215:
URL: https://github.com/apache/flink/pull/18215#discussion_r781220838
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##
@@ -683,12 +683,6 @@ public
flinkbot edited a comment on pull request #18319:
URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822
## CI report:
* eb853c67af624764b4e5c0c3fce054a7fdedbf0e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18274:
URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834
## CI report:
* c445781fa99453f887f9d91978e5bb9ca9d1f91a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18319:
URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822
## CI report:
* eb853c67af624764b4e5c0c3fce054a7fdedbf0e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
Jing Zhang created FLINK-25595:
--
Summary: Specify hash/sort aggregate strategy in SQL hint
Key: FLINK-25595
URL: https://issues.apache.org/jira/browse/FLINK-25595
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-25531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25531:
---
Labels: pull-request-available test-stability (was: test-stability)
> The test testRetryCom
flinkbot edited a comment on pull request #18274:
URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834
## CI report:
* c445781fa99453f887f9d91978e5bb9ca9d1f91a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
fapaul commented on a change in pull request #18302:
URL: https://github.com/apache/flink/pull/18302#discussion_r781214232
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java
##
@@ -806,6 +809,54 @@ public void te
Jing Zhang created FLINK-25594:
--
Summary: Take parquet metadata into consideration when source is
parquet files
Key: FLINK-25594
URL: https://issues.apache.org/jira/browse/FLINK-25594
Project: Flink
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18319:
URL: https://github.com/apache/flink/pull/18319#issuecomment-1008897334
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
[
https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-25592:
---
Description:
This is a parent JIRA to track improvements on Flink Batch SQL, including
parser, opti
alpreu opened a new pull request #18319:
URL: https://github.com/apache/flink/pull/18319
## What is the purpose of the change
testRetryComittableORetriableError is taking over an hour on CI runs. We
want to speed up the test.
The KafkaProducer doc states:
*
* To
Jing Zhang created FLINK-25593:
--
Summary: A redundant scan could be skipped if it is an input of
join and the other input is empty after partition prune
Key: FLINK-25593
URL: https://issues.apache.org/jira/browse/FLI
flinkbot edited a comment on pull request #18318:
URL: https://github.com/apache/flink/pull/18318#issuecomment-100611
## CI report:
* e8c0089788c0c0f2ac3f9d24d9204fcfff6a0785 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
XComp commented on a change in pull request #18189:
URL: https://github.com/apache/flink/pull/18189#discussion_r781204397
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
##
@@ -196,6 +198,8 @@ public Dispatcher(
this.rec
flinkbot commented on pull request #18318:
URL: https://github.com/apache/flink/pull/18318#issuecomment-100611
## CI report:
* e8c0089788c0c0f2ac3f9d24d9204fcfff6a0785 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18317:
URL: https://github.com/apache/flink/pull/18317#issuecomment-1008884033
## CI report:
* b243b63a00bd7ae1870eb2ddcb1bb83f02fc2ee2 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18318:
URL: https://github.com/apache/flink/pull/18318#issuecomment-1008885609
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
flinkbot commented on pull request #18317:
URL: https://github.com/apache/flink/pull/18317#issuecomment-1008884033
## CI report:
* b243b63a00bd7ae1870eb2ddcb1bb83f02fc2ee2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439
## CI report:
* 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-25095:
---
Parent: FLINK-25592
Issue Type: Sub-task (was: Bug)
> Case when would be translated into di
flinkbot commented on pull request #18317:
URL: https://github.com/apache/flink/pull/18317#issuecomment-1008883266
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
MartijnVisser edited a comment on pull request #18301:
URL: https://github.com/apache/flink/pull/18301#issuecomment-1008875216
@fapaul Can you merge? I'll also create a backport for 1.14 and 1.13
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
MartijnVisser opened a new pull request #18318:
URL: https://github.com/apache/flink/pull/18318
Backport of https://github.com/apache/flink/pull/18301
--
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 g
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-25095:
---
Summary: Case when would be translated into different expression in Hive
dialect and default dialect
[
https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-25592:
---
Description:
This is a parent JIRA to track improvements on Flink Batch SQL, including
parser, opti
Jing Zhang created FLINK-25592:
--
Summary: Improvement of parser, optimizer and execution for Flink
Batch SQL
Key: FLINK-25592
URL: https://issues.apache.org/jira/browse/FLINK-25592
Project: Flink
cuibo01 commented on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008881143
> @cuibo01 I know, but the CI won't pass without you rebasing since this is
still pointing to a CI installation that's no longer valid. Without a green CI
build, the PR can't g
MartijnVisser edited a comment on pull request #18301:
URL: https://github.com/apache/flink/pull/18301#issuecomment-1008875216
@fapaul Can you merge? I'll also create a backport for 1.14
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
flinkbot edited a comment on pull request #18316:
URL: https://github.com/apache/flink/pull/18316#issuecomment-1008874978
## CI report:
* 716ceb4e65626fde5dee8a5f0b11c6ed266e40fd Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439
## CI report:
* 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
MartijnVisser opened a new pull request #18317:
URL: https://github.com/apache/flink/pull/18317
Backport of https://github.com/apache/flink/pull/18301
--
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 g
fapaul commented on pull request #18302:
URL: https://github.com/apache/flink/pull/18302#issuecomment-1008877750
@zentol FYI 5c2fd49 adds public annotations to the metrics classes
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
flinkbot commented on pull request #18316:
URL: https://github.com/apache/flink/pull/18316#issuecomment-1008875688
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
MartijnVisser commented on pull request #18301:
URL: https://github.com/apache/flink/pull/18301#issuecomment-1008875216
@fapaul Can you merge? I'll also create a backport for 1.14 and 1.13 (to be
sure)
--
This is an automated message from the Apache Git Service.
To respond to the message
flinkbot commented on pull request #18316:
URL: https://github.com/apache/flink/pull/18316#issuecomment-1008874978
## CI report:
* 716ceb4e65626fde5dee8a5f0b11c6ed266e40fd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
MartijnVisser commented on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008874128
@cuibo01 I know, but the CI won't pass without you rebasing since this is
still pointing to a CI installation that's no longer valid. Without a green CI
build, the PR can
MartijnVisser commented on a change in pull request #18316:
URL: https://github.com/apache/flink/pull/18316#discussion_r781188418
##
File path: docs/content.zh/docs/dev/table/config.md
##
@@ -91,6 +91,39 @@ Flink SQL> SET 'table.exec.mini-batch.size' = '5000';
{{< /tab >}}
{{
MartijnVisser opened a new pull request #18316:
URL: https://github.com/apache/flink/pull/18316
## What is the purpose of the change
* This PR addresses multiple broken links (404s) existing throughout the
English and Chinese documentation.
## Brief change log
* Fixed
cuibo01 commented on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008868247
> @cuibo01 Can you also please rebase on master and squash your commits?
Sorry for the hassle.
hi @MartijnVisser , github provides rebase and squash, and does not need to
flinkbot edited a comment on pull request #18305:
URL: https://github.com/apache/flink/pull/18305#issuecomment-1008223896
## CI report:
* f20decd97ab0a9fded76ab714f7f7f0b33c9f9f0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
alpreu commented on pull request #17819:
URL: https://github.com/apache/flink/pull/17819#issuecomment-1008866360
> I believe it is the right direction to use the `KubernetesLabel` for
generating and validating labels and names. I have one more concern about this
PR. IIRC, only the labels,
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* a4cbe47def1a55221c40be3e16ab532662c4d336 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18313:
URL: https://github.com/apache/flink/pull/18313#issuecomment-1008743407
## CI report:
* 9e65f5754e07a6f0f31839cf297369c439098ef4 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
cuibo01 commented on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008848874
> @cuibo01 Can you also please rebase on master and squash your commits?
Sorry for the hassle.
ok thx @MartijnVisser
--
This is an automated message from the Apache G
twalthr commented on pull request #18221:
URL: https://github.com/apache/flink/pull/18221#issuecomment-1008847150
Thanks for the investigation. I would be fine with the hex approach. It is
definitely more useful than the current master implementation and allows for
the "round trip" cast.
[
https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471970#comment-17471970
]
Darron Fuller edited comment on FLINK-25579 at 1/10/22, 12:53 PM:
[
https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471970#comment-17471970
]
Darron Fuller commented on FLINK-25579:
---
Thanks [~hxbks2ks]. That was my copy-and-
MartijnVisser commented on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008845958
@cuibo01 Can you also please rebase on master and squash your commits? Sorry
for the hassle.
--
This is an automated message from the Apache Git Service.
To respond to
MartijnVisser removed a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008845462
@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 t
MartijnVisser commented on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-1008845462
@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 sp
[
https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471969#comment-17471969
]
Alexander Preuss commented on FLINK-25589:
--
Thank you [~biyuhao] , I assigned y
[
https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss reassigned FLINK-25589:
Assignee: Yuhao Bi
> Update Chinese version of Elasticsearch connector docs
> ---
[
https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Darron Fuller updated FLINK-25579:
--
Description:
CODE:
{quote}in_tbl = create_ingest_table()
result =
in_tbl.select(col('*')).win
flinkbot edited a comment on pull request #17907:
URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179
## CI report:
* d38720331e663bd081f72831ed48487e4931d570 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
fapaul merged pull request #18116:
URL: https://github.com/apache/flink/pull/18116
--
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
flinkbot edited a comment on pull request #18301:
URL: https://github.com/apache/flink/pull/18301#issuecomment-1007423214
## CI report:
* 6e5cb6cd44e7e91335c04d68448ab2c5ec013935 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
fapaul merged pull request #18180:
URL: https://github.com/apache/flink/pull/18180
--
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
fapaul merged pull request #18184:
URL: https://github.com/apache/flink/pull/18184
--
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
[
https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471953#comment-17471953
]
Yuhao Bi commented on FLINK-25589:
--
I volunteer to help with this task
> Update Chine
[
https://issues.apache.org/jira/browse/FLINK-25591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul updated FLINK-25591:
Description:
Evaluate whether it is possible to replace the internals of
StreamExecutionEnvironme
Fabian Paul created FLINK-25591:
---
Summary: Use FileSource for StreamExecutionEnvironment.readFiles
Key: FLINK-25591
URL: https://issues.apache.org/jira/browse/FLINK-25591
Project: Flink
Issue T
flinkbot edited a comment on pull request #18220:
URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981
## CI report:
* f80e3635619ddb32f054090170799ee6cd49313a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471920#comment-17471920
]
Aitozi commented on FLINK-23031:
[~wenlong.lwl] I lose sight of the Window Operator can
zentol closed pull request #18315:
URL: https://github.com/apache/flink/pull/18315
--
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
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15861:
URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848
## CI report:
* 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18311:
URL: https://github.com/apache/flink/pull/18311#issuecomment-1008683024
## CI report:
* 6d9cda7d8a3b8e002ed7d9685d9e76322604ad7d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Airblader commented on pull request #17711:
URL: https://github.com/apache/flink/pull/17711#issuecomment-1008796327
@yangjunhan I apologize for the late response; I was on vacation over the
holidays.
The changes overall look fine to me, except for the open point around the
linting o
wangyang0918 commented on pull request #17819:
URL: https://github.com/apache/flink/pull/17819#issuecomment-1008794107
Really thanks @alpreu for working on this PR and @XComp helping with review.
I believe it is the right direction to use the `KubernetesLabel` for
generating and vali
flinkbot edited a comment on pull request #17819:
URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182
## CI report:
* 2a61cd825f421777b5420b90fdc54193ea76b79a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18312:
URL: https://github.com/apache/flink/pull/18312#issuecomment-1008686402
## CI report:
* 93dbd0a2c4f931c1248c2c4ae23175af1115e6ce Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
301 - 400 of 524 matches
Mail list logo