[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403241#comment-16403241 ] ASF GitHub Bot commented on FLINK-8915: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5703: [FLINK-8915] CheckpointingStatisticsHandler fails to retu...

2018-03-16 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5703 cc @GJL : thanks for your suggestion, please review. ---

[jira] [Commented] (FLINK-9011) YarnResourceManager spamming log file at INFO level

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403233#comment-16403233 ] ASF GitHub Bot commented on FLINK-9011: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5712: [FLINK-9011] YarnResourceManager spamming log file at INF...

2018-03-16 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5712 Hi @GJL please look at this, if you have time, thanks! ---

[jira] [Commented] (FLINK-9011) YarnResourceManager spamming log file at INFO level

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403232#comment-16403232 ] ASF GitHub Bot commented on FLINK-9011: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5712: [FLINK-9011] YarnResourceManager spamming log file...

2018-03-16 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5712 [FLINK-9011] YarnResourceManager spamming log file at INFO level ## What is the purpose of the change *This pull request changed some log's level* ## Brief change log

[jira] [Commented] (FLINK-8970) Add more automated end-to-end tests

2018-03-16 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403210#comment-16403210 ] mingleizhang commented on FLINK-8970: - Very nice to me. > Add more automated end-to-end tests >

[jira] [Assigned] (FLINK-9011) YarnResourceManager spamming log file at INFO level

2018-03-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9011: --- Assignee: vinoyang > YarnResourceManager spamming log file at INFO level >

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-03-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 3/17/18 1:54 AM: In

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403198#comment-16403198 ] ASF GitHub Bot commented on FLINK-8843: --- Github user yanghua closed the pull request at:

[GitHub] flink pull request #5632: [FLINK-8843][REST] Decouple bind REST address from...

2018-03-16 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/5632 ---

[jira] [Updated] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

2018-03-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7917: -- Description: Currently in ExecutionJobVertex#getTaskInformationOrBlobKey: {code} } return

[GitHub] flink issue #5700: [FLINK-8833] [sql-client] Create a SQL Client JSON format...

2018-03-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5700 Since we are not shading anything we could also use the Maven JAR plugin: ``` org.apache.maven.plugins maven-jar-plugin 3.0.2

[jira] [Commented] (FLINK-8833) Create a SQL Client JSON format fat-jar

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403171#comment-16403171 ] ASF GitHub Bot commented on FLINK-8833: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403168#comment-16403168 ] ASF GitHub Bot commented on FLINK-8852: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5704: [FLINK-8852] [sql-client] Add FLIP-6 support to SQL Clien...

2018-03-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5704 Since we are not shading anything we could also use the Maven JAR plugin: ``` org.apache.maven.plugins maven-jar-plugin 3.0.2

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403095#comment-16403095 ] ASF GitHub Bot commented on FLINK-8903: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDDEV_SAMP, ...

2018-03-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5706 updated PR ---

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402691#comment-16402691 ] ASF GitHub Bot commented on FLINK-8903: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDDEV...

2018-03-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r175230116 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala --- @@ -103,6 +106,19 @@

[jira] [Created] (FLINK-9015) Upgrade Calcite dependency to 1.17

2018-03-16 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9015: - Summary: Upgrade Calcite dependency to 1.17 Key: FLINK-9015 URL: https://issues.apache.org/jira/browse/FLINK-9015 Project: Flink Issue Type: Task

[jira] [Assigned] (FLINK-8981) End-to-end test: Kerberos security

2018-03-16 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8981: - Assignee: Shuyi Chen > End-to-end test: Kerberos security > -- >

[jira] [Commented] (FLINK-8988) End-to-end test: Cassandra connector

2018-03-16 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402515#comment-16402515 ] Shuyi Chen commented on FLINK-8988: --- [~till.rohrmann], wondering if the current CassandraConnectorITCase

[jira] [Comment Edited] (FLINK-8988) End-to-end test: Cassandra connector

2018-03-16 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402515#comment-16402515 ] Shuyi Chen edited comment on FLINK-8988 at 3/16/18 8:50 PM: Hi

[jira] [Commented] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402416#comment-16402416 ] ASF GitHub Bot commented on FLINK-8894: --- GitHub user GJL opened a pull request:

[GitHub] flink pull request #5711: [FLINK-8894][REST] CurrentJobIdsHandler fails to s...

2018-03-16 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5711 [FLINK-8894][REST] CurrentJobIdsHandler fails to serialize response ## What is the purpose of the change *This fixes a serialization error in `CurrentJobIdsHandler`.* cc: @tillrohrmann

[jira] [Assigned] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

2018-03-16 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8894: --- Assignee: Gary Yao > CurrentJobIdsHandler fails to serialize response >

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402379#comment-16402379 ] ASF GitHub Bot commented on FLINK-8843: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5632: [FLINK-8843][REST] Decouple bind REST address from...

2018-03-16 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5632#discussion_r175192336 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java --- @@ -33,7 +33,7 @@ */ public static final ConfigOption

[jira] [Updated] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8946: Fix Version/s: 1.5.0 > TaskManager stop sending metrics after JobManager failover >

[jira] [Updated] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8946: Priority: Blocker (was: Major) > TaskManager stop sending metrics after JobManager

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402345#comment-16402345 ] ASF GitHub Bot commented on FLINK-8903: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDDEV...

2018-03-16 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r175183811 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala --- @@ -103,6 +106,19 @@

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402335#comment-16402335 ] ASF GitHub Bot commented on FLINK-8903: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDDEV...

2018-03-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r175181100 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala --- @@ -103,6 +106,19 @@

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402332#comment-16402332 ] ASF GitHub Bot commented on FLINK-8903: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDDEV_SAMP, ...

2018-03-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5706 Updated the PR with the Calcite issue. ---

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402328#comment-16402328 ] Stephan Ewen commented on FLINK-8922: - [~sihuazhou]'s findings could be the right fix. Could it be

[jira] [Comment Edited] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few

2018-03-16 Thread Pankaj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402323#comment-16402323 ] Pankaj edited comment on FLINK-9009 at 3/16/18 6:35 PM: No, Is not related with

[jira] [Comment Edited] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few

2018-03-16 Thread Pankaj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402323#comment-16402323 ] Pankaj edited comment on FLINK-9009 at 3/16/18 6:34 PM: No, Is not related with

[jira] [Commented] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few insta

2018-03-16 Thread Pankaj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402323#comment-16402323 ] Pankaj commented on FLINK-9009: --- No, Is not related with Kafka. I have already tried and check the problem

[jira] [Closed] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value

2018-03-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8364. --- Resolution: Invalid Fix Version/s: (was: 1.5.0) > Add iterator() to ListState

[jira] [Reopened] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value

2018-03-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8364: - reopen to change fixVersion > Add iterator() to ListState which returns empty iterator when

[jira] [Commented] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

2018-03-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402299#comment-16402299 ] Ted Yu commented on FLINK-7488: --- {code}

[jira] [Created] (FLINK-9014) Adapt BackPressureStatsTracker to work with credit-based flow control

2018-03-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9014: -- Summary: Adapt BackPressureStatsTracker to work with credit-based flow control Key: FLINK-9014 URL: https://issues.apache.org/jira/browse/FLINK-9014 Project: Flink

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402251#comment-16402251 ] Aljoscha Krettek commented on FLINK-8922: - [~sihuazhou] Unfortunately, I don't know why the

[jira] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402247#comment-16402247 ] ASF GitHub Bot commented on FLINK-8402: --- Github user NicoK commented on the issue:

[GitHub] flink issue #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT cases for...

2018-03-16 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5624 Unfortunately, this is not entirely under our control, since we rely on the underlying `FileSystem` implementation. I can probably reduce some parts of the tests that may lead to eventual consistent

[jira] [Commented] (FLINK-8948) RescalingITCase fails on Travis

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402229#comment-16402229 ] ASF GitHub Bot commented on FLINK-8948: --- Github user NicoK commented on the issue:

[GitHub] flink issue #5710: [FLINK-8948][runtime] Fix IllegalStateException when clos...

2018-03-16 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5710 it may be better to make `BufferBuilder#finish()` idempotent ---

[jira] [Commented] (FLINK-8945) Allow customization of the KinesisProxy

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402218#comment-16402218 ] ASF GitHub Bot commented on FLINK-8945: --- Github user tweise commented on the issue:

[GitHub] flink issue #5698: [FLINK-8945] [kinesis] Allow customization of KinesisProx...

2018-03-16 Thread tweise
Github user tweise commented on the issue: https://github.com/apache/flink/pull/5698 @StephanEwen thanks for unblocking our work! ---

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402053#comment-16402053 ] ASF GitHub Bot commented on FLINK-8915: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402055#comment-16402055 ] ASF GitHub Bot commented on FLINK-8915: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402054#comment-16402054 ] ASF GitHub Bot commented on FLINK-8915: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5703: [FLINK-8915] CheckpointingStatisticsHandler fails ...

2018-03-16 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5703#discussion_r175125460 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -438,4 +453,58 @@ public int

[GitHub] flink pull request #5703: [FLINK-8915] CheckpointingStatisticsHandler fails ...

2018-03-16 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5703#discussion_r175126334 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -438,4 +453,58 @@ public int

[GitHub] flink pull request #5703: [FLINK-8915] CheckpointingStatisticsHandler fails ...

2018-03-16 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5703#discussion_r175126066 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java --- @@ -273,7 +274,21 @@ public static

[jira] [Created] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-03-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9013: -- Summary: Document yarn.containers.vcores only being effective when adapting YARN config Key: FLINK-9013 URL: https://issues.apache.org/jira/browse/FLINK-9013 Project:

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402031#comment-16402031 ] ASF GitHub Bot commented on FLINK-8968: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-16 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 @StefanRRichter I have updated the code, could you please have a look... ---

[jira] [Commented] (FLINK-8976) End-to-end test: Resume with different parallelism

2018-03-16 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402023#comment-16402023 ] Sihua Zhou commented on FLINK-8976: --- Hi [~till.rohrmann] could I ask why this issue won't work with

[jira] [Assigned] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-9010: -- Assignee: Nico Kruber > NoResourceAvailableException with FLIP-6 >

[jira] [Commented] (FLINK-8948) RescalingITCase fails on Travis

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16402014#comment-16402014 ] ASF GitHub Bot commented on FLINK-8948: --- GitHub user pnowojski opened a pull request:

[GitHub] flink pull request #5710: [FLINK-8948][runtime] Fix IllegalStateException wh...

2018-03-16 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/5710 [FLINK-8948][runtime] Fix IllegalStateException when closing StreamTask All methods in org.apache.flink.streaming.runtime.tasks.OperatorChain#releaseOutputs shouldn't throw any exceptions and

[jira] [Created] (FLINK-9012) Shaded Hadoop S3A end-to-end test failing with S3 bucket in Ireland

2018-03-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9012: -- Summary: Shaded Hadoop S3A end-to-end test failing with S3 bucket in Ireland Key: FLINK-9012 URL: https://issues.apache.org/jira/browse/FLINK-9012 Project: Flink

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9010: --- Issue Type: Bug (was: Improvement) > NoResourceAvailableException with FLIP-6 >

[jira] [Created] (FLINK-9011) YarnResourceManager spamming log file at INFO level

2018-03-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9011: -- Summary: YarnResourceManager spamming log file at INFO level Key: FLINK-9011 URL: https://issues.apache.org/jira/browse/FLINK-9011 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9011) YarnResourceManager spamming log file at INFO level

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9011: --- Labels: flip-6 (was: ) > YarnResourceManager spamming log file at INFO level >

[jira] [Created] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-03-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9010: -- Summary: NoResourceAvailableException with FLIP-6 Key: FLINK-9010 URL: https://issues.apache.org/jira/browse/FLINK-9010 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9010: --- Labels: flip-6 (was: ) > NoResourceAvailableException with FLIP-6 >

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401994#comment-16401994 ] ASF GitHub Bot commented on FLINK-8968: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-16 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5705 You can cover it here and I will review it again 👍 ---

[jira] [Commented] (FLINK-8872) Yarn detached mode via -yd does not detach

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401983#comment-16401983 ] ASF GitHub Bot commented on FLINK-8872: --- Github user NicoK commented on the issue:

[GitHub] flink issue #5672: [FLINK-8872][flip6] fix yarn detached mode command parsin...

2018-03-16 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5672 thanks for the review, I also did not like the side-effect approach and after thinking a bit about your first message, I independently came up with the same thing as you proposed in the second one :p

[jira] [Commented] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

2018-03-16 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401958#comment-16401958 ] Gary Yao commented on FLINK-8073: - Another instance: https://travis-ci.org/apache/flink/jobs/354290449 >

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401952#comment-16401952 ] ASF GitHub Bot commented on FLINK-8968: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-16 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 @StefanRRichter Sorry for pinging you again in this PR, but I found there maybe be another issue for `full checkpoint`. It's about the `kvStateInformation`, we should create a deep copy of

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-16 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401945#comment-16401945 ] Sihua Zhou commented on FLINK-8922: --- [~srichter] Yes, the downside is obvious and I also feel it should

[jira] [Updated] (FLINK-8941) SpanningRecordSerializationTest fails on Travis

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8941: --- Component/s: Network > SpanningRecordSerializationTest fails on Travis >

[jira] [Updated] (FLINK-8941) SpanningRecordSerializationTest fails on Travis

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8941: --- Affects Version/s: 1.6.0 1.5.0 > SpanningRecordSerializationTest fails on

[jira] [Updated] (FLINK-8941) SpanningRecordSerializationTest fails on Travis

2018-03-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8941: --- Fix Version/s: 1.6.0 > SpanningRecordSerializationTest fails on Travis >

[GitHub] flink pull request #5709: [FLINK-8941][network][serializer] improve Spanning...

2018-03-16 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5709 [FLINK-8941][network][serializer] improve SpanningRecordSerializationTest and ensure unique spilling files ## What is the purpose of the change This PR contains two commits trying to tackle

[jira] [Commented] (FLINK-8941) SpanningRecordSerializationTest fails on Travis

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401936#comment-16401936 ] ASF GitHub Bot commented on FLINK-8941: --- GitHub user NicoK opened a pull request:

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-16 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401933#comment-16401933 ] Stefan Richter commented on FLINK-8922: --- Hmm, I wonder why that should be a fix? Does that mean that

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-16 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401925#comment-16401925 ] Sihua Zhou commented on FLINK-8922: --- Ah, happy to tell you guys that finally I find the way to make it

[jira] [Closed] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator

2018-03-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7851. Resolution: Won't Fix Reverted via 1.6.0: 91d346e9e7611be530509154cc7034cbde22653d 1.5.0:

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401917#comment-16401917 ] Stephan Ewen commented on FLINK-8922: - [~srichter] and me had a discussion about this today. *Can we

[jira] [Commented] (FLINK-8984) Disabling credit based flow control deadlocks Flink on checkpoint

2018-03-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401912#comment-16401912 ] ASF GitHub Bot commented on FLINK-8984: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #5708: [FLINK-8984][network] Drop taskmanager.exactly-once.block...

2018-03-16 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/5708 Thanks piotr, I agree with it. ---

[jira] [Commented] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few insta

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401901#comment-16401901 ] Stephan Ewen commented on FLINK-9009: - I assume that error is reported by Kafka? Can you past the

[jira] [Resolved] (FLINK-8945) Allow customization of the KinesisProxy

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8945. - Resolution: Fixed Assignee: Kailash Hassan Dayanand Fix Version/s: 1.5.0 Fixed in

[jira] [Closed] (FLINK-8945) Allow customization of the KinesisProxy

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8945. --- > Allow customization of the KinesisProxy > --- > >

[jira] [Assigned] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-: --- Assignee: Kailash Hassan Dayanand > Upgrade AWS SDK in flink-connector-kinesis >

[jira] [Closed] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-. --- > Upgrade AWS SDK in flink-connector-kinesis > -- > >

[jira] [Resolved] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in - 1.5.0 via

[jira] [Created] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few instanc

2018-03-16 Thread Pankaj (JIRA)
Pankaj created FLINK-9009: - Summary: Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few instances are created. Key:

[jira] [Created] (FLINK-9008) End-to-end test: Quickstarts

2018-03-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9008: Summary: End-to-end test: Quickstarts Key: FLINK-9008 URL: https://issues.apache.org/jira/browse/FLINK-9008 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9007) Cluster test: Kinesis connector

2018-03-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9007: Summary: Cluster test: Kinesis connector Key: FLINK-9007 URL: https://issues.apache.org/jira/browse/FLINK-9007 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9006) Cluster test: Run general purpose job with failures with Yarn and per-job mode

2018-03-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9006: Summary: Cluster test: Run general purpose job with failures with Yarn and per-job mode Key: FLINK-9006 URL: https://issues.apache.org/jira/browse/FLINK-9006

  1   2   >