[
https://issues.apache.org/jira/browse/FLINK-8709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371017#comment-16371017
]
Bowen Li commented on FLINK-8709:
-
Another https://travis-ci.org/apache/flink/builds/34408
[
https://issues.apache.org/jira/browse/FLINK-8709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-8709:
-
Another instance on latest master:
https://travis-ci.org/apache/flink/jobs/343910963
> Flaky
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370997#comment-16370997
]
Cristian commented on FLINK-4194:
-
Hi guys. This is a feature we miss.
Given the fact tha
[
https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370995#comment-16370995
]
ASF GitHub Bot commented on FLINK-8648:
---
Github user tweise commented on the issue:
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5480
@tzulitai any update?
---
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370981#comment-16370981
]
tarun razdan commented on FLINK-7756:
-
[~aljoscha]
I tried building your branch and t
[
https://issues.apache.org/jira/browse/FLINK-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370946#comment-16370946
]
mingleizhang commented on FLINK-8700:
-
Hi, [~aljoscha] I think we CAN not remove {{sta
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370944#comment-16370944
]
ASF GitHub Bot commented on FLINK-8560:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370943#comment-16370943
]
ASF GitHub Bot commented on FLINK-8710:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370942#comment-16370942
]
ASF GitHub Bot commented on FLINK-8667:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5481
cc @pnowojski @aljoscha
---
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5522
cc @tillrohrmann
---
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5500
cc @pnowojski @aljoscha
---
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370724#comment-16370724
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user cjolif commented on a diff in t
Github user cjolif commented on a diff in the pull request:
https://github.com/apache/flink/pull/4675#discussion_r169490640
--- Diff:
flink-connectors/flink-connector-elasticsearch5.3/src/main/java/org/apache/flink/streaming/connectors/elasticsearch53/BulkProcessorIndexer.java
---
[
https://issues.apache.org/jira/browse/FLINK-8720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dejan miljkovic updated FLINK-8720:
---
Summary: Logging exception with S3 connector and BucketingSink (was:
Logging exception )
> L
dejan miljkovic created FLINK-8720:
--
Summary: Logging exception
Key: FLINK-8720
URL: https://issues.apache.org/jira/browse/FLINK-8720
Project: Flink
Issue Type: Bug
Components: St
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370581#comment-16370581
]
ASF GitHub Bot commented on FLINK-8655:
---
GitHub user Bekreth opened a pull request:
GitHub user Bekreth opened a pull request:
https://github.com/apache/flink/pull/5538
[FLINK-8655] [DataSink] Added default keyspace to CassandraPojoSink
## What is the purpose of the change
Initial Issue : [https://issues.apache.org/jira/browse/FLINK-8655]
It is not unco
[
https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370487#comment-16370487
]
ASF GitHub Bot commented on FLINK-8660:
---
Github user kbialek commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370489#comment-16370489
]
ASF GitHub Bot commented on FLINK-8660:
---
Github user kbialek closed the pull request
Github user kbialek closed the pull request at:
https://github.com/apache/flink/pull/5530
---
Github user kbialek commented on the issue:
https://github.com/apache/flink/pull/5530
Closing without merge, because of:
1. Test failure
2. I'd like to implement Stephan's idea
---
[
https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370484#comment-16370484
]
Krzysztof Białek edited comment on FLINK-8660 at 2/20/18 7:17 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370484#comment-16370484
]
Krzysztof Białek commented on FLINK-8660:
-
[~StephanEwen] suggested to simplify co
[
https://issues.apache.org/jira/browse/FLINK-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370479#comment-16370479
]
ASF GitHub Bot commented on FLINK-8719:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5537
[FLINK-8719] add module description for flink-contrib to clarify its purpose
## What is the purpose of the change
flink-contrib currently doesn't have any clarification or description of
Bowen Li created FLINK-8719:
---
Summary: add module description for flink-contrib to clarify its
purpose
Key: FLINK-8719
URL: https://issues.apache.org/jira/browse/FLINK-8719
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-8599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370347#comment-16370347
]
ASF GitHub Bot commented on FLINK-8599:
---
Github user ChengzhiZhao commented on the i
Github user ChengzhiZhao commented on the issue:
https://github.com/apache/flink/pull/5521
Thanks @steveloughran for your feedbacks, I updated based on your
suggestions.
---
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370315#comment-16370315
]
Alexander Gardner commented on FLINK-8707:
--
Also, if you start to run a Flink job
Gary Yao created FLINK-8718:
---
Summary: Non-parallel DataStreamSource does not set max parallelism
Key: FLINK-8718
URL: https://issues.apache.org/jira/browse/FLINK-8718
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370301#comment-16370301
]
Ken Krugler commented on FLINK-8717:
Hi [~rrevol] - I believe what you're seeing is ca
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370246#comment-16370246
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on the issue:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5487
After rescaling `SocketWindowWordCount`, the parallelism exposed by the
REST API remains unchanged.
Steps to reproduce:
Start netcat.
```
nc -l 9001
```
Submit job with p
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8704:
---
Assignee: (was: Chesnay Schepler)
> Migrate tests from TestingCluster to MiniClus
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8704:
---
Assignee: Chesnay Schepler
> Migrate tests from TestingCluster to MiniClusterResource
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Gardner updated FLINK-8707:
-
Attachment: box2-jobmgr-lsof
box1-taskmgr-lsof
box1-jobmgr-
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370223#comment-16370223
]
Alexander Gardner commented on FLINK-8707:
--
Attaching the lsof output, removing a
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370219#comment-16370219
]
Alexander Gardner commented on FLINK-8707:
--
Hi Aljoscha
I'm adding some more inf
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370218#comment-16370218
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169374194
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -400,7 +410,7 @@ pub
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370209#comment-16370209
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169371872
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370205#comment-16370205
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370206#comment-16370206
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r16937
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,43 +1
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5535#discussion_r169370975
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/misc/MiscellaneousIssuesITCase.java
---
@@ -134,7 +106,8 @@ public void testAccumulatorsAfterNoOp()
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370195#comment-16370195
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370196#comment-16370196
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370197#comment-16370197
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169369352
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -211,24 +211,55 @@ protected CheckpointStreamFactory
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169369280
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,43 +1
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5535#discussion_r169369295
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/misc/MiscellaneousIssuesITCase.java
---
@@ -134,7 +106,8 @@ public void testAccumulatorsAfterNoOp
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370192#comment-16370192
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370191#comment-16370191
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370193#comment-16370193
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169368766
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,43 +1
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169368813
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,43 +1
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169368679
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,43 +1
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370190#comment-16370190
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370189#comment-16370189
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169368440
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -1991,43 +1
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169368355
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -266,9 +267
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370184#comment-16370184
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370183#comment-16370183
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169367889
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java
---
@@ -62,7 +62,7 @@
* @param state State variable f
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169367934
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -266,9 +267
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370167#comment-16370167
]
Aljoscha Krettek commented on FLINK-8543:
-
[~snowch] Do you see these failures for
[
https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-8574:
-
I'll also merge this to 1.4
> Add timestamps to travis logging messages
> ---
[
https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8574.
---
Resolution: Fixed
Fix Version/s: 1.4.2
1.4: a7df42485a6d96bb7167c6597b9b0d1c59390f4d
>
[
https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8621.
---
Resolution: Fixed
1.4: 45efe4702ac1d932afa1b322e93264c28aefbc4a
> PrometheusReporterTest.end
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5419
---
[
https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370158#comment-16370158
]
ASF GitHub Bot commented on FLINK-8621:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370159#comment-16370159
]
ASF GitHub Bot commented on FLINK-8574:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5473
---
[
https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370155#comment-16370155
]
Chesnay Schepler commented on FLINK-8621:
-
master: 6c9a5c7f3c63404657fc1da633bc22b
[
https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8574.
---
Resolution: Fixed
master: 86723314e5043d7b28faf30c000f54928f24d0da
> Add timestamps to travis
[
https://issues.apache.org/jira/browse/FLINK-8593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8593:
Component/s: Documentation
> Latency metric docs are outdated
>
[
https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Romain Revol updated FLINK-8717:
Description:
We are encountering what looks like a deadlock of Flink in one of our jobs with
an "it
[
https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Romain Revol updated FLINK-8717:
Description:
We are encountering what looks like a deadlock of Flink in one of our jobs with
an "it
Romain Revol created FLINK-8717:
---
Summary: Flink seems to deadlock due to buffer starvation when
iterating
Key: FLINK-8717
URL: https://issues.apache.org/jira/browse/FLINK-8717
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370125#comment-16370125
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zhangminglei commented on a dif
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5535#discussion_r169346590
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -38,33 +35,23 @@
* This experimental c
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370123#comment-16370123
]
chris snow commented on FLINK-8543:
---
[~aljoscha] - I’m using AvroKeyValueSinkWriter
[ht
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370117#comment-16370117
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5535#discussion_r169341512
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -38,33 +35,23 @@
* This experimental class i
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370094#comment-16370094
]
Aljoscha Krettek commented on FLINK-8543:
-
[~snowch] Btw, what is the writer you'r
[
https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370087#comment-16370087
]
ASF GitHub Bot commented on FLINK-8458:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/5317
@NicoK , I found most of the codes in this PR are already merged into
master by commit `0093bcbe771f296baf3857ef15fe7ec9b22bbc34` in your
`FLINK-8425`. Maybe I only need to add the `config.md` in t
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370083#comment-16370083
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zhangminglei commented on a dif
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5535#discussion_r169328894
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -38,33 +35,23 @@
* This experimental c
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370076#comment-16370076
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zhangminglei commented on a dif
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5535#discussion_r169327476
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -38,33 +35,23 @@
* This experimental c
[
https://issues.apache.org/jira/browse/FLINK-8714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370075#comment-16370075
]
ASF GitHub Bot commented on FLINK-8714:
---
GitHub user michalklempa opened a pull requ
GitHub user michalklempa opened a pull request:
https://github.com/apache/flink/pull/5536
[FLINK-8714][Documentation] Added either charsetName) or "utf-8" value in
examples of readTextFile
## What is the purpose of the change
When a newcomer (like me), goes through the docs, the
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370073#comment-16370073
]
Aljoscha Krettek commented on FLINK-8543:
-
[~ste...@apache.org] That would fix thi
[
https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370067#comment-16370067
]
Arvid Heise commented on FLINK-8716:
Btw, the current behavior is that it will fail wi
[
https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370052#comment-16370052
]
Arvid Heise commented on FLINK-8716:
In the email thread, [~till.rohrmann] also pointe
[
https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370051#comment-16370051
]
Aljoscha Krettek commented on FLINK-8716:
-
The idea is that when a {{TypeSerialize
1 - 100 of 203 matches
Mail list logo
