[jira] [Commented] (FLINK-8709) Flaky test: SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager

[ https://issues.apache.org/jira/browse/FLINK-8709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16371017#comment-16371017 ] Bowen Li commented on FLINK-8709: - Another https://travis-ci.org/apache/flink/builds/344089148 > Flaky

[jira] [Reopened] (FLINK-8709) Flaky test: SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager

[ 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 >

[jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370997#comment-16370997 ] Cristian commented on FLINK-4194: - Hi guys. This is a feature we miss. Given the fact that it's not

[jira] [Commented] (FLINK-8648) Allow for customization of emitRecordAndUpdateState in Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370995#comment-16370995 ] ASF GitHub Bot commented on FLINK-8648: --- Github user tweise commented on the issue:

[GitHub] flink issue #5480: [FLINK-8648] [kinesis] Allow for customization of emitRec...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/5480 @tzulitai any update? ---

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370981#comment-16370981 ] tarun razdan commented on FLINK-7756: - [~aljoscha] I tried building your branch and the build was

[jira] [Commented] (FLINK-8700) Port tests from FlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370946#comment-16370946 ] mingleizhang commented on FLINK-8700: - Hi, [~aljoscha] I think we CAN not remove {{startCluster}} in

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370944#comment-16370944 ] ASF GitHub Bot commented on FLINK-8560: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-8710) AbstractYarnClusterDescriptor doesn't use pre-defined configs in Hadoop's YarnConfiguration

[ https://issues.apache.org/jira/browse/FLINK-8710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370943#comment-16370943 ] ASF GitHub Bot commented on FLINK-8710: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer()

[ https://issues.apache.org/jira/browse/FLINK-8667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370942#comment-16370942 ] ASF GitHub Bot commented on FLINK-8667: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5481 cc @pnowojski @aljoscha ---

[GitHub] flink issue #5522: [FLINK-8710] [YARN] AbstractYarnClusterDescriptor doesn't...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5522 cc @tillrohrmann ---

[GitHub] flink issue #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFunction#...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5500 cc @pnowojski @aljoscha ---

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370724#comment-16370724 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on a diff in the pull request:

[GitHub] flink pull request #4675: [FLINK-7386] FIx Elasticsearch 5 connector is not ...

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 ---

[jira] [Updated] (FLINK-8720) Logging exception with S3 connector and BucketingSink

[ 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 ) >

[jira] [Created] (FLINK-8720) Logging exception

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:

[jira] [Commented] (FLINK-8655) Add a default keyspace to CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370581#comment-16370581 ] ASF GitHub Bot commented on FLINK-8655: --- GitHub user Bekreth opened a pull request:

[GitHub] flink pull request #5538: [FLINK-8655] [DataSink] Added default keyspace to ...

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

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370487#comment-16370487 ] ASF GitHub Bot commented on FLINK-8660: --- Github user kbialek commented on the issue:

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370489#comment-16370489 ] ASF GitHub Bot commented on FLINK-8660: --- Github user kbialek closed the pull request at:

[GitHub] flink pull request #5530: [FLINK-8660] Enable the user to provide custom HAS...

Github user kbialek closed the pull request at: https://github.com/apache/flink/pull/5530 ---

[GitHub] flink issue #5530: [FLINK-8660] Enable the user to provide custom HAServices...

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 ---

[jira] [Comment Edited] (FLINK-8660) Enable the user to provide custom HAServices implementation

[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370484#comment-16370484 ] Krzysztof Białek edited comment on FLINK-8660 at 2/20/18 7:17 PM: --

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370484#comment-16370484 ] Krzysztof Białek commented on FLINK-8660: - [~StephanEwen] suggested to simplify configuration

[jira] [Commented] (FLINK-8719) add module description for flink-contrib to clarify its purpose

[ https://issues.apache.org/jira/browse/FLINK-8719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370479#comment-16370479 ] ASF GitHub Bot commented on FLINK-8719: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #5537: [FLINK-8719] add module description for flink-cont...

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

[jira] [Created] (FLINK-8719) add module description for flink-contrib to clarify its purpose

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

[jira] [Commented] (FLINK-8599) Improve the failure behavior of the FileInputFormat for bad files

[ https://issues.apache.org/jira/browse/FLINK-8599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370347#comment-16370347 ] ASF GitHub Bot commented on FLINK-8599: --- Github user ChengzhiZhao commented on the issue:

[GitHub] flink issue #5521: [FLINK-8599] Improve the failure behavior of the FileInpu...

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. ---

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370315#comment-16370315 ] Alexander Gardner commented on FLINK-8707: -- Also, if you start to run a Flink job on the cluster

[jira] [Created] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

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:

[jira] [Commented] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating

[ https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370301#comment-16370301 ] Ken Krugler commented on FLINK-8717: Hi [~rrevol] - I believe what you're seeing is caused by circular

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

[ https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370246#comment-16370246 ] ASF GitHub Bot commented on FLINK-8656: --- Github user GJL commented on the issue:

[GitHub] flink issue #5487: [FLINK-8656] [flip6] Add modify CLI command to rescale Fl...

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

[jira] [Assigned] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

[ 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

[jira] [Assigned] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

[ 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

[jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager

[ 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

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370223#comment-16370223 ] Alexander Gardner commented on FLINK-8707: -- Attaching the lsof output, removing any refs to real

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370219#comment-16370219 ] Alexander Gardner commented on FLINK-8707: -- Hi Aljoscha I'm adding some more info from our DEV

[jira] [Commented] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState

[ https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370218#comment-16370218 ] ASF GitHub Bot commented on FLINK-8639: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

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 @@

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370209#comment-16370209 ] ASF GitHub Bot commented on FLINK-8679: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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 --- @@

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370205#comment-16370205 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370206#comment-16370206 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5535: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

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

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370195#comment-16370195 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370196#comment-16370196 ] ASF GitHub Bot commented on FLINK-8703: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370197#comment-16370197 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5535: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

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

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370192#comment-16370192 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370191#comment-16370191 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370193#comment-16370193 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370190#comment-16370190 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370189#comment-16370189 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370184#comment-16370184 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370183#comment-16370183 ] ASF GitHub Bot commented on FLINK-8679: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

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

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370167#comment-16370167 ] Aljoscha Krettek commented on FLINK-8543: - [~snowch] Do you see these failures for all files or

[jira] [Reopened] (FLINK-8574) 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 reopened FLINK-8574: - I'll also merge this to 1.4 > Add timestamps to travis logging messages >

[jira] [Closed] (FLINK-8574) 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

[jira] [Closed] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

[ 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 >

[GitHub] flink pull request #5419: [FLINK-8574][travis] Add timestamp to logging mess...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5419 ---

[jira] [Commented] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370158#comment-16370158 ] ASF GitHub Bot commented on FLINK-8621: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8574) Add timestamps to travis logging messages

[ https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370159#comment-16370159 ] ASF GitHub Bot commented on FLINK-8574: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5473: [FLINK-8621][prometheus][tests] Remove endpointIsU...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5473 ---

[jira] [Commented] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370155#comment-16370155 ] Chesnay Schepler commented on FLINK-8621: - master: 6c9a5c7f3c63404657fc1da633bc22b62c1c1178 >

[jira] [Closed] (FLINK-8574) 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 master: 86723314e5043d7b28faf30c000f54928f24d0da > Add timestamps to

[jira] [Updated] (FLINK-8593) Latency metric docs are outdated

[ 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 >

[jira] [Updated] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating

[ 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

[jira] [Updated] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating

[ 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

[jira] [Created] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370125#comment-16370125 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5535: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

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

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370123#comment-16370123 ] chris snow commented on FLINK-8543: --- [~aljoscha] - I’m using AvroKeyValueSinkWriter

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370117#comment-16370117 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5535: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

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

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370094#comment-16370094 ] Aljoscha Krettek commented on FLINK-8543: - [~snowch] Btw, what is the writer you're using in this

[jira] [Commented] (FLINK-8458) Add the switch for keeping both the old mode and the new credit-based mode

[ https://issues.apache.org/jira/browse/FLINK-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370087#comment-16370087 ] ASF GitHub Bot commented on FLINK-8458: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #5317: [FLINK-8458] Add the switch for keeping both the old mode...

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370083#comment-16370083 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5535: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

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

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370076#comment-16370076 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5535: [FLINK-8703][tests] Migrate tests from LocalFlinkM...

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

[jira] [Commented] (FLINK-8714) Suggest new users to use env.readTextFile method with 2 arguments (using the charset), not to rely on system charset (which varies across environments)

[ https://issues.apache.org/jira/browse/FLINK-8714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370075#comment-16370075 ] ASF GitHub Bot commented on FLINK-8714: --- GitHub user michalklempa opened a pull request:

[GitHub] flink pull request #5536: [FLINK-8714][Documentation] Added either charsetNa...

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,

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370073#comment-16370073 ] Aljoscha Krettek commented on FLINK-8543: - [~ste...@apache.org] That would fix this issue but I

[jira] [Commented] (FLINK-8716) AvroSerializer does not use schema of snapshot

[ https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370067#comment-16370067 ] Arvid Heise commented on FLINK-8716: Btw, the current behavior is that it will fail with an

[jira] [Commented] (FLINK-8716) AvroSerializer does not use schema of snapshot

[ https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370052#comment-16370052 ] Arvid Heise commented on FLINK-8716: In the email thread, [~till.rohrmann] also pointed out that

[jira] [Commented] (FLINK-8716) AvroSerializer does not use schema of snapshot

[ https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370051#comment-16370051 ] Aljoscha Krettek commented on FLINK-8716: - The idea is that when a {{TypeSerializer}} signals that

  1   2   3   >