[
https://issues.apache.org/jira/browse/FLINK-19549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Di Xu updated FLINK-19549:
--
Description:
The CI pipeline has a timeout of 260 minutes, which is not enough after we add
more e2e tests
flinkbot edited a comment on pull request #13449:
URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354
## CI report:
* 25dbaee00978fc3ca2995a4fa7bdb4b88e3c4dc3 Azure:
flinkbot edited a comment on pull request #13311:
URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434
## CI report:
* b7660009b48d48261b767855d8973c63741ab493 UNKNOWN
* f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN
*
flinkbot edited a comment on pull request #13311:
URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434
## CI report:
* b7660009b48d48261b767855d8973c63741ab493 UNKNOWN
* f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN
*
flinkbot edited a comment on pull request #13558:
URL: https://github.com/apache/flink/pull/13558#issuecomment-705296235
## CI report:
* 96fe5b695afe4db5a654b4c2c30bad6310574a82 Azure:
flinkbot edited a comment on pull request #13449:
URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354
## CI report:
* 25dbaee00978fc3ca2995a4fa7bdb4b88e3c4dc3 Azure:
flinkbot edited a comment on pull request #13449:
URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354
## CI report:
* 25dbaee00978fc3ca2995a4fa7bdb4b88e3c4dc3 Azure:
fsk119 commented on a change in pull request #13449:
URL: https://github.com/apache/flink/pull/13449#discussion_r502181535
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WatermarkAssignerProjectTransposeRule.java
wuchong commented on a change in pull request #13472:
URL: https://github.com/apache/flink/pull/13472#discussion_r502180974
##
File path:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java
##
@@ -359,13 +359,13 @@ public
scottxusayhi commented on pull request #13555:
URL: https://github.com/apache/flink/pull/13555#issuecomment-705958481
Blocked by FLINK-19549
This is an automated message from the Apache Git Service.
To respond to the
Di Xu created FLINK-19549:
-
Summary: [CI] ##[error]The job running on agent Azure Pipelines 5
ran longer than the maximum time of 260 minutes.
Key: FLINK-19549
URL: https://issues.apache.org/jira/browse/FLINK-19549
wuchong commented on pull request #13214:
URL: https://github.com/apache/flink/pull/13214#issuecomment-705956351
Hi @pyscala , thanks for the updating.
However, the new added `discoverOptionalFactory` method still no generic
method for all kinds of fatories. What I mean was that
fsk119 commented on a change in pull request #13449:
URL: https://github.com/apache/flink/pull/13449#discussion_r502177717
##
File path:
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanRuleTest.java
wuchong commented on a change in pull request #13487:
URL: https://github.com/apache/flink/pull/13487#discussion_r502173323
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/dataview/ListView.java
##
@@ -73,17 +73,11 @@
*
* public
[
https://issues.apache.org/jira/browse/FLINK-19547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-19547:
-
Description:
Partial records happen if a record can not fit into one buffer, then the
remaining part
wuchong commented on pull request #13516:
URL: https://github.com/apache/flink/pull/13516#issuecomment-705951099
Shall we also deprecate the interfaces `AppendStreamTableSink`,
`RetractStreamTableSink`, `UpsertStreamTableSink`, `StreamTableSource`... which
are located in
KarmaGYZ commented on a change in pull request #13311:
URL: https://github.com/apache/flink/pull/13311#discussion_r502170774
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerDriverTest.java
##
@@ -0,0 +1,544 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-17341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210588#comment-17210588
]
huweihua commented on FLINK-17341:
--
I think we can put the slots that need to be free in a list, and
fa zheng created FLINK-19548:
Summary: Report correct progress to yarn resource manager
Key: FLINK-19548
URL: https://issues.apache.org/jira/browse/FLINK-19548
Project: Flink
Issue Type:
flinkbot edited a comment on pull request #11502:
URL: https://github.com/apache/flink/pull/11502#issuecomment-603330429
## CI report:
* f15ad0726ba02072f1b2bb0e6d697bf24865ac9d Azure:
[
https://issues.apache.org/jira/browse/FLINK-19534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210580#comment-17210580
]
Dian Fu commented on FLINK-19534:
-
cc [~hxbks2ks] Could you help to take a look at this issue?
>
flinkbot edited a comment on pull request #13566:
URL: https://github.com/apache/flink/pull/13566#issuecomment-705941691
## CI report:
* b139f0662c5c86ae97742c6dc6742aaef4f97a97 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-19547:
-
Summary: Partial record clean up after receiver task fails and restart
(was: Partial record clean Up
JingsongLi commented on pull request #13515:
URL: https://github.com/apache/flink/pull/13515#issuecomment-705945069
Is this related to https://github.com/apache/flink/pull/13479?
This is an automated message from the Apache
Yuan Mei created FLINK-19547:
Summary: Partial record clean Up after receiver task fails and
restart
Key: FLINK-19547
URL: https://issues.apache.org/jira/browse/FLINK-19547
Project: Flink
Issue
flinkbot edited a comment on pull request #11502:
URL: https://github.com/apache/flink/pull/11502#issuecomment-603330429
## CI report:
* f15ad0726ba02072f1b2bb0e6d697bf24865ac9d Azure:
[
https://issues.apache.org/jira/browse/FLINK-18410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-18410.
Resolution: Fixed
master: b9e78b65e363f09d6d80721c01bd8a64e8482c51
> Flink SQL filesystem
JingsongLi merged pull request #13522:
URL: https://github.com/apache/flink/pull/13522
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
KarmaGYZ commented on a change in pull request #13311:
URL: https://github.com/apache/flink/pull/13311#discussion_r502162885
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java
##
@@ -0,0 +1,609 @@
+/*
+ * Licensed to the Apache
Jiayi-Liao commented on pull request #11502:
URL: https://github.com/apache/flink/pull/11502#issuecomment-705944125
@pnowojski I just came back from a vacation, sorry for the late reply. The
current CI failure is
```
The job running on agent Azure Pipelines 3 ran longer than the
xintongsong commented on a change in pull request #13313:
URL: https://github.com/apache/flink/pull/13313#discussion_r502162586
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriver.java
##
@@ -0,0 +1,713 @@
+/*
+ *
shuiqiangchen commented on pull request #16:
URL: https://github.com/apache/flink-playgrounds/pull/16#issuecomment-705944280
@alpinegizmo Thank you for your comments, I have adjusted some content order
to make the README to be more well-organized. And here are the answers for you
Yang Wang created FLINK-19546:
-
Summary: Add document for native Kubernetes HA
Key: FLINK-19546
URL: https://issues.apache.org/jira/browse/FLINK-19546
Project: Flink
Issue Type: Sub-task
Yang Wang created FLINK-19545:
-
Summary: Add e2e test for native Kubernetes HA
Key: FLINK-19545
URL: https://issues.apache.org/jira/browse/FLINK-19545
Project: Flink
Issue Type: Sub-task
Yang Wang created FLINK-19544:
-
Summary: Implement CheckpointRecoveryFactory based on Kubernetes
API
Key: FLINK-19544
URL: https://issues.apache.org/jira/browse/FLINK-19544
Project: Flink
Issue
flinkbot commented on pull request #13566:
URL: https://github.com/apache/flink/pull/13566#issuecomment-705941691
## CI report:
* b139f0662c5c86ae97742c6dc6742aaef4f97a97 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
Yang Wang created FLINK-19543:
-
Summary: Implement RunningJobsRegistry, JobGraphStore based on
Kubernetes API
Key: FLINK-19543
URL: https://issues.apache.org/jira/browse/FLINK-19543
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19541:
-
Description:
Now the hiveConfDir must be a local path.
* We can let it accept a remote path.
[
https://issues.apache.org/jira/browse/FLINK-19522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19522:
Component/s: (was: Table SQL / API)
Table SQL / Ecosystem
> Add ability to set auto
Yang Wang created FLINK-19542:
-
Summary: Implement LeaderElectionService and
LeaderRetrievalService based on Kubernetes API
Key: FLINK-19542
URL: https://issues.apache.org/jira/browse/FLINK-19542
flinkbot commented on pull request #13566:
URL: https://github.com/apache/flink/pull/13566#issuecomment-705938959
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
hehuiyuan opened a new pull request #13566:
URL: https://github.com/apache/flink/pull/13566
## What is the purpose of the change
This pull resquest fixes Kafka connector. There is a cast problem when use
properties method.
```
Properties props = new Properties();
[
https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-12884:
--
Component/s: Deployment / Kubernetes
> FLIP-144: Native Kubernetes HA Service
>
[
https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-12884:
--
Fix Version/s: 1.12.0
> FLIP-144: Native Kubernetes HA Service
>
hehuiyuan closed pull request #13494:
URL: https://github.com/apache/flink/pull/13494
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
[
https://issues.apache.org/jira/browse/FLINK-19541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19541:
-
Description:
Now the hiveConfDir must be a local path.
* We can let it accept a remote path.
[
https://issues.apache.org/jira/browse/FLINK-19541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210570#comment-17210570
]
Jingsong Lee commented on FLINK-19541:
--
CC: [~lirui]
> Improve hiveConfDir for HiveCatalog
>
Jingsong Lee created FLINK-19541:
Summary: Improve hiveConfDir for HiveCatalog
Key: FLINK-19541
URL: https://issues.apache.org/jira/browse/FLINK-19541
Project: Flink
Issue Type: Task
KarmaGYZ commented on a change in pull request #13311:
URL: https://github.com/apache/flink/pull/13311#discussion_r502152387
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java
##
@@ -385,14 +385,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-19521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210566#comment-17210566
]
Yang Wang commented on FLINK-19521:
---
Just a nit comment. Currently, {{FlinkYarnSessionCli}} is using
[
https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated FLINK-16579:
---
Summary: Upgrade Calcite version to 1.26 for Flink SQL (was: Upgrade
Calcite version to 1.23 for
[
https://issues.apache.org/jira/browse/FLINK-19517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210563#comment-17210563
]
Jark Wu commented on FLINK-19517:
-
Hi [~ksp0422],
1) It is determined whether it is used as source or
xintongsong commented on a change in pull request #13313:
URL: https://github.com/apache/flink/pull/13313#discussion_r502139646
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerDriver.java
##
@@ -0,0 +1,713 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-16093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16093:
---
Assignee: chunfa ge
> Translate "System Functions" page of "Functions" into Chinese
>
weizheng92 commented on pull request #13506:
URL: https://github.com/apache/flink/pull/13506#issuecomment-705927238
@klion26 could plz have a review?
This is an automated message from the Apache Git Service.
To respond to
flinkbot edited a comment on pull request #13558:
URL: https://github.com/apache/flink/pull/13558#issuecomment-705296235
## CI report:
* 1f4f2c56473eddab43cdbd1d7d3ff7474113abdf Azure:
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* bc7f0db4d137fdd415ca36942165dd9ad992baca UNKNOWN
*
flinkbot edited a comment on pull request #13558:
URL: https://github.com/apache/flink/pull/13558#issuecomment-705296235
## CI report:
* 1f4f2c56473eddab43cdbd1d7d3ff7474113abdf Azure:
flinkbot edited a comment on pull request #13563:
URL: https://github.com/apache/flink/pull/13563#issuecomment-705571075
## CI report:
* 682caad02b0b1155862661a12f65c015ccf79e5b Azure:
flinkbot edited a comment on pull request #13565:
URL: https://github.com/apache/flink/pull/13565#issuecomment-705730164
## CI report:
* 5feafbbf87c7cefaf7ebe3a36c1e3f346386d629 Azure:
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* bb689c444aea5e6480635ce6a5e976ff6b8169d5 Azure:
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* bb689c444aea5e6480635ce6a5e976ff6b8169d5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-18459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinhao Li closed FLINK-18459.
-
Resolution: Fixed
> ClassNotFoundException in ProcessFunction property object's callback and
> promise
Xinhao Li created FLINK-19540:
-
Summary: How to reduce or disable checkpoint logs in Flink
Key: FLINK-19540
URL: https://issues.apache.org/jira/browse/FLINK-19540
Project: Flink
Issue Type:
flinkbot edited a comment on pull request #13564:
URL: https://github.com/apache/flink/pull/13564#issuecomment-705651851
## CI report:
* 29eb9920d726629cb5d7c3b0a1093e46393b65eb Azure:
flinkbot edited a comment on pull request #13556:
URL: https://github.com/apache/flink/pull/13556#issuecomment-704987982
## CI report:
* 455e21d91670cb0e2ea2a5cb3330d8b1b67a11ef Azure:
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* bb689c444aea5e6480635ce6a5e976ff6b8169d5 Azure:
flinkbot edited a comment on pull request #13563:
URL: https://github.com/apache/flink/pull/13563#issuecomment-705571075
## CI report:
* eef43a83c0155010f865c084eebc53206bc5f021 Azure:
flinkbot edited a comment on pull request #13563:
URL: https://github.com/apache/flink/pull/13563#issuecomment-705571075
## CI report:
* eef43a83c0155010f865c084eebc53206bc5f021 Azure:
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* bb689c444aea5e6480635ce6a5e976ff6b8169d5 Azure:
flinkbot edited a comment on pull request #13565:
URL: https://github.com/apache/flink/pull/13565#issuecomment-705730164
## CI report:
* 5feafbbf87c7cefaf7ebe3a36c1e3f346386d629 Azure:
flinkbot edited a comment on pull request #13529:
URL: https://github.com/apache/flink/pull/13529#issuecomment-702193043
## CI report:
* 9d86c10c66fd25983de29f905b79d35b5aedd85b Azure:
flinkbot commented on pull request #13565:
URL: https://github.com/apache/flink/pull/13565#issuecomment-705730164
## CI report:
* 5feafbbf87c7cefaf7ebe3a36c1e3f346386d629 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* e60b28287696df3780e6aff0a61b6e324a344373 Azure:
flinkbot commented on pull request #13565:
URL: https://github.com/apache/flink/pull/13565#issuecomment-705726642
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
rkhachatryan opened a new pull request #13565:
URL: https://github.com/apache/flink/pull/13565
## What is the purpose of the change
This PR includes changes from #13040 and some refactorings of new and
existing code.
## Verifying this change
Changes for backpressure
pnowojski commented on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-705722866
I fixed one bug that was causing test failures, please @AHeise take special
look at the new changes in `DefaultActionSuspension#resume` and `TaskMailbox`
class (replaced
pnowojski commented on a change in pull request #13562:
URL: https://github.com/apache/flink/pull/13562#discussion_r501864082
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java
##
@@ -31,68 +31,49 @@
private static
[
https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-16430.
---
Release Note: Beginning from Flink 1.12, jobs will be scheduled in the unit
of pipelined regions. A
Jason-liujc commented on pull request #5415:
URL: https://github.com/apache/flink/pull/5415#issuecomment-705717389
Thanks Fabian!
After switching to using `StreamExecutionEnvironment.addSource()`, I
encountered this error in Flink 1.8:
```
[
https://issues.apache.org/jira/browse/FLINK-19514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19514:
---
Attachment: tests-1601994365.tgz
>
[
https://issues.apache.org/jira/browse/FLINK-19539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-19539:
--
Description:
The following build failed
[
https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-18662:
---
Release Note:
This is modifing the {{checkpointAlignmentTime}} metric for the at-least-once
flinkbot edited a comment on pull request #13551:
URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051
## CI report:
* a875c6b63432a371dd2928d6c3bdb2d4627c5f81 Azure:
Roman Khachatryan created FLINK-19539:
-
Summary: JMXReporterFactoryTest fails on Azure
Key: FLINK-19539
URL: https://issues.apache.org/jira/browse/FLINK-19539
Project: Flink
Issue Type:
ricardopereira33 commented on pull request #12472:
URL: https://github.com/apache/flink/pull/12472#issuecomment-705698142
Hi @rmetzger
Are you any idea when this PR will be reviewed? I'm working in a Flink
Cluster where there are several jobs running and it is hard to
flinkbot edited a comment on pull request #11326:
URL: https://github.com/apache/flink/pull/11326#issuecomment-595547530
## CI report:
* 905c3ad232c2a602c61a9cca7c465e4c438b4a48 Azure:
flinkbot edited a comment on pull request #13547:
URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372
## CI report:
* 268d260399e598943726839a254f004a61f5ba66 UNKNOWN
* 562aa94b5969e0699b852626c287c5e1afc35140 Azure:
rkhachatryan commented on pull request #13351:
URL: https://github.com/apache/flink/pull/13351#issuecomment-705687454
I rebased the PR and resolved conflicts with FLINK-19027 by moving the
assignment of exclusive buffers for `RecoveredInputChannel` into it's
`requestBufferBlocking`
pnowojski commented on a change in pull request #13562:
URL: https://github.com/apache/flink/pull/13562#discussion_r501845717
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -76,7 +76,7 @@
flinkbot edited a comment on pull request #13562:
URL: https://github.com/apache/flink/pull/13562#issuecomment-70471
## CI report:
* a745916e6c50b5e07d27c208165080f002887a28 UNKNOWN
* e60b28287696df3780e6aff0a61b6e324a344373 Azure:
flinkbot edited a comment on pull request #13351:
URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492
## CI report:
* 3041c4816637a7e1686723ec0e04d99db5cce14c UNKNOWN
* 59ca6fe974dd7270f5b6de4880b9de845eda830f Azure:
AHeise commented on a change in pull request #13562:
URL: https://github.com/apache/flink/pull/13562#discussion_r501721584
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -76,7 +76,7 @@
flinkbot edited a comment on pull request #13556:
URL: https://github.com/apache/flink/pull/13556#issuecomment-704987982
## CI report:
* 40f3f7d289665256ea5a8a938cbbf4ded64396f1 Azure:
flinkbot edited a comment on pull request #13561:
URL: https://github.com/apache/flink/pull/13561#issuecomment-705507172
## CI report:
* b5a1938350a935a8d24ee93c1f83114e65819bc1 Azure:
flinkbot edited a comment on pull request #13564:
URL: https://github.com/apache/flink/pull/13564#issuecomment-705651851
## CI report:
* 29eb9920d726629cb5d7c3b0a1093e46393b65eb Azure:
dawidwys commented on a change in pull request #13529:
URL: https://github.com/apache/flink/pull/13529#discussion_r501825284
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.java
##
@@ -62,6 +62,16 @@ public
flinkbot commented on pull request #13564:
URL: https://github.com/apache/flink/pull/13564#issuecomment-705651851
## CI report:
* 29eb9920d726629cb5d7c3b0a1093e46393b65eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13556:
URL: https://github.com/apache/flink/pull/13556#issuecomment-704987982
## CI report:
* 40f3f7d289665256ea5a8a938cbbf4ded64396f1 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-19538:
-
Description:
Ingresses defined via Yaml route messages with an implicit key pulled via the
1 - 100 of 244 matches
Mail list logo
