[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519961#comment-16519961
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519968#comment-16519968
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519962#comment-16519962
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519960#comment-16519960
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519966#comment-16519966
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519967#comment-16519967
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519959#comment-16519959
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519964#comment-16519964
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519958#comment-16519958
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519963#comment-16519963
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519965#comment-16519965
]
ASF GitHub Bot commented on FLINK-9513:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197329976
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,204 @@
+package
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197331145
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197330095
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,204 @@
+package
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197330813
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java
---
@@ -48,7 +48,8 @@
KeyedStateBackend,
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197331820
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197329533
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,204 @@
+package
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197331211
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197331898
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197330596
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
---
@@ -0,0 +1,204 @@
+package
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197331741
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197331764
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519949#comment-16519949
]
xueyu commented on FLINK-4301:
--
Does this refer to the script https://flink.apache.org/q/quickstart.sh? If
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Youjun Yuan updated FLINK-9630:
---
Description:
when the Kafka topic got deleted, during task starting process,
[
https://issues.apache.org/jira/browse/FLINK-9641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519815#comment-16519815
]
ASF GitHub Bot commented on FLINK-9641:
---
GitHub user cckellogg opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9641:
--
Labels: pull-request-available (was: )
> Pulsar Source Connector
> ---
>
GitHub user cckellogg opened a pull request:
https://github.com/apache/flink/pull/6200
[FLINK-9641] [streaming-connectors] Flink pulsar source connector
## What is the purpose of the change
This pull request adds a
[pulsar](https://github.com/apache/incubator-pulsar)
Chris Kellogg created FLINK-9641:
Summary: Pulsar Source Connector
Key: FLINK-9641
URL: https://issues.apache.org/jira/browse/FLINK-9641
Project: Flink
Issue Type: New Feature
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197279905
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/ClientUtils.java ---
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519784#comment-16519784
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519783#comment-16519783
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197279550
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -323,17 +325,18 @@ public JobSubmissionResult
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519781#comment-16519781
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519782#comment-16519782
]
ASF GitHub Bot commented on FLINK-9624:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197279258
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/client/ClientUtilsTest.java
---
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9624:
--
Labels: pull-request-available (was: )
> Move jar/artifact upload logic out of JobGraph
>
[
https://issues.apache.org/jira/browse/FLINK-9624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519779#comment-16519779
]
ASF GitHub Bot commented on FLINK-9624:
---
GitHub user zentol opened a pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6199#discussion_r197279307
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java ---
@@ -552,96 +550,33 @@ public boolean hasUsercodeJarFiles() {
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/6199
[FLINK-9624][runtime] Move jar/artifact upload out of jobgraph
## What is the purpose of the change
This PR moves the logic for uploading jars/artifacts from the jobgraph into
a separate
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519658#comment-16519658
]
ASF GitHub Bot commented on FLINK-8468:
---
Github user GJL commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8468:
--
Labels: pull-request-available (was: )
> Make the connector to take advantage of AMQP
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5410
Taking a look once more.
---
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9599.
---
Resolution: Fixed
Fix Version/s: 1.5.1
master:
[
https://issues.apache.org/jira/browse/FLINK-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9467:
Labels: (was: pull-request-available)
> No Watermark display on Web UI
>
[
https://issues.apache.org/jira/browse/FLINK-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9467.
---
Resolution: Fixed
master: a3f290020c6d0d15d993dcdc24fa1ef98c63739b
1.5:
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519614#comment-16519614
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519616#comment-16519616
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519617#comment-16519617
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6189#discussion_r197217551
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -239,6 +322,45 @@ public void shutdown(Time timeout) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6189#discussion_r197217460
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -184,7 +206,64 @@ public void shutdown(Time timeout) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6189#discussion_r197217367
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -184,7 +206,64 @@ public void shutdown(Time timeout) {
[
https://issues.apache.org/jira/browse/FLINK-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-9640:
Description:
steps to reproduce:
1. build a standalone flink cluster.
2. submit a test job like this
[
https://issues.apache.org/jira/browse/FLINK-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-9640:
Affects Version/s: (was: 1.3.2)
> Checkpointing is aways aborted if any task has been finished
>
Hai Zhou created FLINK-9640:
---
Summary: Checkpointing is aways aborted if any task has been
finished
Key: FLINK-9640
URL: https://issues.apache.org/jira/browse/FLINK-9640
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519551#comment-16519551
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197192870
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlConfig.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519550#comment-16519550
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6189
I've rebased the PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519539#comment-16519539
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197188305
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValue.java ---
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-9639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guilherme Nobre updated FLINK-9639:
---
Description:
The *User Configuration* list is not ordered alphabetically. Would be nice to
[
https://issues.apache.org/jira/browse/FLINK-9639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guilherme Nobre updated FLINK-9639:
---
Description:
The *User Configuration* list is not ordered alphabetically. Would be nice to
[
https://issues.apache.org/jira/browse/FLINK-9639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guilherme Nobre updated FLINK-9639:
---
Description:
The *User Configuration* list is not ordered alphabetically. Would be nice to
[
https://issues.apache.org/jira/browse/FLINK-9522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-9522.
Resolution: Done
Assignee: Fabian Hueske
Merged to flink-web/asf-site with
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519507#comment-16519507
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519511#comment-16519511
]
ASF GitHub Bot commented on FLINK-9514:
---
Github user azagrebin commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519506#comment-16519506
]
ASF GitHub Bot commented on FLINK-9467:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519505#comment-16519505
]
ASF GitHub Bot commented on FLINK-9623:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6187
---
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6186#discussion_r197179238
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValue.java ---
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6178
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6152
---
Guilherme Nobre created FLINK-9639:
--
Summary: Order "User Configuration" Alphabetically on Flink
Dashboard
Key: FLINK-9639
URL: https://issues.apache.org/jira/browse/FLINK-9639
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9623.
---
Resolution: Fixed
master: 3f07ecc652c07101ae1b1a8fb17f89a2d1206e1e
> Move zipping logic out
[
https://issues.apache.org/jira/browse/FLINK-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9627:
--
Labels: pull-request-available (was: )
> Extending 'KafkaJsonTableSource' according to
[
https://issues.apache.org/jira/browse/FLINK-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519453#comment-16519453
]
ASF GitHub Bot commented on FLINK-9627:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6198
[FLINK-9627] Extending KafkaJsonTableSource according to comments will
result in NPE
## What is the purpose of the change
* This pull request fixed a NPE when customize
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519405#comment-16519405
]
Triones Deng edited comment on FLINK-9411 at 6/21/18 2:29 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519412#comment-16519412
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6021
Thanks @fmthoma, will proceed to merge this ..
---
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519405#comment-16519405
]
Triones Deng commented on FLINK-9411:
-
[~StephanEwen] sure a design is necessary, here there may be
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6197
Tried this locally, and it works.
+1, will merge this ..
---
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519402#comment-16519402
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on the issue:
Github user fmthoma commented on the issue:
https://github.com/apache/flink/pull/6021
@tzulitai Thanks for your last review comments! I addressed them, and
rebased the branch against master.
---
[
https://issues.apache.org/jira/browse/FLINK-9638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519399#comment-16519399
]
ASF GitHub Bot commented on FLINK-9638:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519396#comment-16519396
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519395#comment-16519395
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519397#comment-16519397
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in the pull
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r197143428
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r197143312
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/TimeoutLatch.java
---
@@ -0,0 +1,41 @@
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r197143254
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -326,6
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519393#comment-16519393
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user zentol commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6189#discussion_r197142993
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -106,7 +106,7 @@ protected void channelRead0(final
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519390#comment-16519390
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in the pull
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r197142648
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -144,6
Github user fmthoma commented on a diff in the pull request:
https://github.com/apache/flink/pull/6021#discussion_r197141591
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -55,6
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519386#comment-16519386
]
ASF GitHub Bot commented on FLINK-9374:
---
Github user fmthoma commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519381#comment-16519381
]
ASF GitHub Bot commented on FLINK-9638:
---
GitHub user florianschmidt1994 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9638:
--
Labels: pull-request-available (was: )
> Add helper script to run single e2e test
>
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16519380#comment-16519380
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 288 matches
Mail list logo
