[jira] [Updated] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-19 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7251: Description: This issue removes the flink-java8 module and merges some tests into flink-core/flink-

[jira] [Resolved] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-19 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7251. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.7.0: ddba1b69f43cbb885e178dfaafa120f1fe1

[jira] [Commented] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-19 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550288#comment-16550288 ] Congxian Qiu commented on FLINK-8163: - I ran the NonHAQueryableStateFsBackendITCase#t

[GitHub] flink pull request #6120: [FLINK-7251] [types] Remove the flink-java8 module...

2018-07-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6120 ---

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550283#comment-16550283 ] ASF GitHub Bot commented on FLINK-7251: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550249#comment-16550249 ] 陈梓立 commented on FLINK-9894: FLINK-9875 would definitely raise data race on current data base

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550246#comment-16550246 ] ASF GitHub Bot commented on FLINK-9894: --- Github user tison1 commented on the issue:

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550247#comment-16550247 ] ASF GitHub Bot commented on FLINK-9894: --- Github user tison1 closed the pull request

[GitHub] flink pull request #6370: [FLINK-9894] [runtime] Potential Data Race

2018-07-19 Thread tison1
Github user tison1 closed the pull request at: https://github.com/apache/flink/pull/6370 ---

[GitHub] flink issue #6370: [FLINK-9894] [runtime] Potential Data Race

2018-07-19 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6370 @zentol ok ... close as suggested, would be resolved in #6353 ---

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550231#comment-16550231 ] ASF GitHub Bot commented on FLINK-9894: --- Github user zentol commented on the issue:

[GitHub] flink issue #6370: [FLINK-9894] [runtime] Potential Data Race

2018-07-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6370 If another PR introduces race conditions, then these race conditions should be resolved in that very PR. ---

[jira] [Commented] (FLINK-8058) Queryable state should check types

2018-07-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550229#comment-16550229 ] Chesnay Schepler commented on FLINK-8058: - I don't know much about how queryable

[jira] [Commented] (FLINK-8058) Queryable state should check types

2018-07-19 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550174#comment-16550174 ] Congxian Qiu commented on FLINK-8058: - Hi, [~Zentol] could I check the state type and

[jira] [Commented] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550141#comment-16550141 ] Ted Yu commented on FLINK-9849: --- I generated the dependency tree where I don't see SNAPSHOT

[jira] [Updated] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9849: -- Attachment: hbase-2.1.0.dep > Upgrade hbase version to 2.0.1 for hbase connector >

[jira] [Updated] (FLINK-9901) Refactor InputStreamReader to Channels.newReader

2018-07-19 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9901: Description: From this benchmark report https://arnaudroger.github.io/blog/2017/03/20/faster-reader

[jira] [Commented] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550139#comment-16550139 ] ASF GitHub Bot commented on FLINK-9849: --- Github user zhangminglei commented on the

[GitHub] flink issue #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-19 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6365 Thanks @yanghua for pointing this out! ---

[jira] [Assigned] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9899: --- Assignee: vinoyang > Add more metrics to the Kinesis source connector >

[jira] [Updated] (FLINK-9901) Refactor InputStreamReader to Channels.newReader

2018-07-19 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9901: Description: From this benchmark report https://arnaudroger.github.io/blog/2017/03/20/faster-reader

[jira] [Created] (FLINK-9901) Refactor InputStreamReader to Channels.newReader

2018-07-19 Thread zhangminglei (JIRA)
zhangminglei created FLINK-9901: --- Summary: Refactor InputStreamReader to Channels.newReader Key: FLINK-9901 URL: https://issues.apache.org/jira/browse/FLINK-9901 Project: Flink Issue Type: Sub-

[jira] [Assigned] (FLINK-9896) Fix flink documentation error

2018-07-19 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-9896: --- Assignee: zhangminglei > Fix flink documentation error > - > >

[jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

2018-07-19 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9900: Description: https://api.travis-ci.org/v3/job/405843617/log.txt Tests run: 1, Failures: 0, Errors:

[jira] [Created] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

2018-07-19 Thread zhangminglei (JIRA)
zhangminglei created FLINK-9900: --- Summary: Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Key: FLINK-9900 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-19 Thread Lakshmi Rao (JIRA)
Lakshmi Rao created FLINK-9899: -- Summary: Add more metrics to the Kinesis source connector Key: FLINK-9899 URL: https://issues.apache.org/jira/browse/FLINK-9899 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-9898) Prometheus metrics reporter doesn't respect `metrics.scope`

2018-07-19 Thread Prithvi Raj (JIRA)
Prithvi Raj created FLINK-9898: -- Summary: Prometheus metrics reporter doesn't respect `metrics.scope` Key: FLINK-9898 URL: https://issues.apache.org/jira/browse/FLINK-9898 Project: Flink Issue

[jira] [Commented] (FLINK-9679) Implement AvroSerializationSchema

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549851#comment-16549851 ] ASF GitHub Bot commented on FLINK-9679: --- Github user medcv commented on the issue:

[GitHub] flink issue #6259: [FLINK-9679] Implement AvroSerializationSchema

2018-07-19 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6259 @tillrohrmann Please review ---

[jira] [Commented] (FLINK-9679) Implement AvroSerializationSchema

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549847#comment-16549847 ] ASF GitHub Bot commented on FLINK-9679: --- Github user medcv commented on the issue:

[GitHub] flink issue #6259: [FLINK-9679] Implement AvroSerializationSchema

2018-07-19 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6259 @dawidwys Thanks for your suggestions. New commit extend `SchemaCoder` with `writeSchema` method that helps to move the writing schema logic away from `AvroSerializationSchema` as you suggested.

[jira] [Commented] (FLINK-9641) Pulsar Source Connector

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549828#comment-16549828 ] ASF GitHub Bot commented on FLINK-9641: --- Github user cckellogg commented on a diff

[GitHub] flink pull request #6200: [FLINK-9641] [streaming-connectors] Flink pulsar s...

2018-07-19 Thread cckellogg
Github user cckellogg commented on a diff in the pull request: https://github.com/apache/flink/pull/6200#discussion_r203863637 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarConsumerSource.java --- @@ -0,0 +1,203

[jira] [Commented] (FLINK-9732) Report more detailed error message on JobSubmissionFailure

2018-07-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549805#comment-16549805 ] Chesnay Schepler commented on FLINK-9732: - please read the discussion in the link

[jira] [Resolved] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

2018-07-19 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9435. Resolution: Fixed Fix Version/s: 1.6.0 Fixed in: - master: 95eadfe15203ee0ab1459a9ade943234d

[jira] [Created] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

2018-07-19 Thread Lakshmi Rao (JIRA)
Lakshmi Rao created FLINK-9897: -- Summary: Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops Key: FLINK-9897 URL: https://issues.apache.org/jira/browse/FLINK-989

[jira] [Resolved] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-19 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9755. Resolution: Fixed Fixed in master: 5857f5543a7d9d3082d2f74342758d5a452a3c13 1.6: 0fec75c03bba0fa85a

[jira] [Commented] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549711#comment-16549711 ] ASF GitHub Bot commented on FLINK-9755: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549712#comment-16549712 ] ASF GitHub Bot commented on FLINK-9435: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6115: [FLINK-9435][java] Remove per-key selection Tuple ...

2018-07-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6115 ---

[GitHub] flink pull request #6272: [FLINK-9755][network] forward exceptions in Remote...

2018-07-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6272 ---

[jira] [Comment Edited] (FLINK-9732) Report more detailed error message on JobSubmissionFailure

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549450#comment-16549450 ] vinoyang edited comment on FLINK-9732 at 7/19/18 3:52 PM: -- Hi [~

[jira] [Commented] (FLINK-9732) Report more detailed error message on JobSubmissionFailure

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549450#comment-16549450 ] vinoyang commented on FLINK-9732: - Hi [~Zentol] a little question, if the code "Job submi

[jira] [Updated] (FLINK-9732) Report more detailed error message on JobSubmissionFailure

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9732: Summary: Report more detailed error message on JobSubmissionFailure (was: Report more detailed error messa

[jira] [Comment Edited] (FLINK-9814) CsvTableSource "lack of column" warning

2018-07-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549347#comment-16549347 ] François Lacombe edited comment on FLINK-9814 at 7/19/18 3:19 PM: -

[jira] [Created] (FLINK-9896) Fix flink documentation error

2018-07-19 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-9896: -- Summary: Fix flink documentation error Key: FLINK-9896 URL: https://issues.apache.org/jira/browse/FLINK-9896 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549407#comment-16549407 ] ASF GitHub Bot commented on FLINK-9755: --- Github user NicoK commented on the issue:

[GitHub] flink issue #6272: [FLINK-9755][network] forward exceptions in RemoteInputCh...

2018-07-19 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/6272 Thanks for the review, merging... ---

[jira] [Commented] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549406#comment-16549406 ] ASF GitHub Bot commented on FLINK-9435: --- Github user NicoK commented on the issue:

[GitHub] flink issue #6115: [FLINK-9435][java] Remove per-key selection Tuple instant...

2018-07-19 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/6115 Thanks for the review, merging... ---

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

2018-07-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549386#comment-16549386 ] Greg Hogan commented on FLINK-9061: --- Not that we shouldn't implement the general purpos

[jira] [Comment Edited] (FLINK-9774) Allow to pass a string-based cluster identifier to command line

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549382#comment-16549382 ] vinoyang edited comment on FLINK-9774 at 7/19/18 2:55 PM: -- I thi

[jira] [Commented] (FLINK-9774) Allow to pass a string-based cluster identifier to command line

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549382#comment-16549382 ] vinoyang commented on FLINK-9774: - I think [~twalthr] gave a good example, the existed "-

[jira] [Commented] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549361#comment-16549361 ] ASF GitHub Bot commented on FLINK-9609: --- GitHub user zhangminglei opened a pull req

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9609: -- Labels: pull-request-available (was: ) > Add bucket ready mechanism for BucketingSink when che

[GitHub] flink pull request #6375: [FLINK-9609] [connectors] Add bucket ready mechani...

2018-07-19 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/6375 [FLINK-9609] [connectors] Add bucket ready mechanism for BucketingSin… ## What is the purpose of the change Currently, BucketingSink only support ```notifyCheckpointComplete```. However,

[GitHub] flink pull request #:

2018-07-19 Thread tison1
Github user tison1 commented on the pull request: https://github.com/apache/flink/commit/8231b62ff42aae53ca3a7b552980838ccab824ab#commitcomment-29765803 In flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroup.java: In flink-runtime/src/main/ja

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549354#comment-16549354 ] ASF GitHub Bot commented on FLINK-9850: --- Github user tison1 commented on the issue:

[GitHub] flink issue #6367: [FLINK-9850] Add a string to the print method to identify...

2018-07-19 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6367 @yanghua also +1 this is a net win. ---

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549352#comment-16549352 ] ASF GitHub Bot commented on FLINK-9894: --- Github user tison1 commented on the issue:

[GitHub] flink issue #6370: [FLINK-9894] [runtime] Potential Data Race

2018-07-19 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6370 but the original `ensureConstraints` is wired. For example it calls `ensureCapacity` twice and the only code path is from `ExecutionJobVertex` construct `ExecutionVertex` which calls `ensureConstraint

[jira] [Commented] (FLINK-9814) CsvTableSource "lack of column" warning

2018-07-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549347#comment-16549347 ] François Lacombe commented on FLINK-9814: - Hi Fabian, Ok to add option to check

[jira] [Comment Edited] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549333#comment-16549333 ] François Lacombe edited comment on FLINK-9813 at 7/19/18 2:17 PM: -

[jira] [Commented] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-19 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549333#comment-16549333 ] François Lacombe commented on FLINK-9813: - Hi Fabian, Nice we agree on that :)

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549334#comment-16549334 ] ASF GitHub Bot commented on FLINK-9850: --- Github user hequn8128 commented on the iss

[GitHub] flink issue #6367: [FLINK-9850] Add a string to the print method to identify...

2018-07-19 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/6367 @yanghua Thanks for your update. +1 to merge ---

[jira] [Commented] (FLINK-9675) Avoid FileInputStream/FileOutputStream

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549300#comment-16549300 ] ASF GitHub Bot commented on FLINK-9675: --- Github user hequn8128 commented on the iss

[GitHub] flink issue #6335: [FLINK-9675] [fs] Avoid FileInputStream/FileOutputStream

2018-07-19 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/6335 @zhangminglei It sounds great :-) ---

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549255#comment-16549255 ] ASF GitHub Bot commented on FLINK-9894: --- Github user tison1 commented on the issue:

[GitHub] flink issue #6370: [FLINK-9894] [runtime] Potential Data Race

2018-07-19 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6370 @yanghua AFAIK, yes. ---

[jira] [Assigned] (FLINK-9791) Outdated savepoint compatibility table

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9791: --- Assignee: (was: vinoyang) > Outdated savepoint compatibility table > ---

[jira] [Assigned] (FLINK-9806) Add a canonical link element to documentation HTML

2018-07-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9806: --- Assignee: (was: vinoyang) > Add a canonical link element to documentation HTML > ---

[jira] [Commented] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549216#comment-16549216 ] ASF GitHub Bot commented on FLINK-9755: --- Github user NicoK commented on the issue:

[GitHub] flink issue #6272: [FLINK-9755][network] forward exceptions in RemoteInputCh...

2018-07-19 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/6272 rebased to solve the merge conflict (auto-solved by git though) ---

[jira] [Assigned] (FLINK-6222) YARN: setting environment variables in an easier fashion

2018-07-19 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6222: --- Assignee: Dawid Wysakowicz (was: Craig Foster) > YARN: setting environment variable

[jira] [Closed] (FLINK-9860) Netty resource leak on receiver side

2018-07-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9860. --- Resolution: Fixed master: 6a56e48c78caecda84d0995f67bf92dad37b1791 1.6: 49c6f385df97958cda779

[jira] [Reopened] (FLINK-9860) Netty resource leak on receiver side

2018-07-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9860: - > Netty resource leak on receiver side > > >

[jira] [Closed] (FLINK-9860) Netty resource leak on receiver side

2018-07-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9860. --- Resolution: Fixed 1.5: c1c4bcb34b421eff12bc52c2e56219233acbd290 > Netty resource leak on rec

[jira] [Resolved] (FLINK-9871) Use Description class for ConfigOptions with rich formatting

2018-07-19 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-9871. - Resolution: Fixed > Use Description class for ConfigOptions with rich formatting > --

[jira] [Commented] (FLINK-9871) Use Description class for ConfigOptions with rich formatting

2018-07-19 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549188#comment-16549188 ] Dawid Wysakowicz commented on FLINK-9871: - Fixed in 1.6: 41d4d8d00ee0a9a73a7674a3

[jira] [Commented] (FLINK-9871) Use Description class for ConfigOptions with rich formatting

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549185#comment-16549185 ] ASF GitHub Bot commented on FLINK-9871: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6371: [FLINK-9871] Use Description class for ConfigOptio...

2018-07-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6371 ---

[jira] [Commented] (FLINK-9888) Remove unsafe defaults from release scripts

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549183#comment-16549183 ] ASF GitHub Bot commented on FLINK-9888: --- Github user yanghua commented on the issue

[GitHub] flink issue #6362: [FLINK-9888][release] Remove unsafe defaults from release...

2018-07-19 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6362 +1 ---

[jira] [Commented] (FLINK-9895) Ensure correct logging settings for NettyLeakDetectionResource

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549182#comment-16549182 ] ASF GitHub Bot commented on FLINK-9895: --- Github user yanghua commented on the issue

[GitHub] flink issue #6374: [FLINK-9895][tests] Ensure error logging for NettyLeakDet...

2018-07-19 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6374 +1 ---

[jira] [Commented] (FLINK-9895) Ensure correct logging settings for NettyLeakDetectionResource

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549171#comment-16549171 ] ASF GitHub Bot commented on FLINK-9895: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-9894) Potential Data Race

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549170#comment-16549170 ] ASF GitHub Bot commented on FLINK-9894: --- Github user yanghua commented on the issue

[jira] [Updated] (FLINK-9895) Ensure correct logging settings for NettyLeakDetectionResource

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9895: -- Labels: pull-request-available (was: ) > Ensure correct logging settings for NettyLeakDetectio

[GitHub] flink pull request #6374: [FLINK-9895][tests] Ensure error logging for Netty...

2018-07-19 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6374 [FLINK-9895][tests] Ensure error logging for NettyLeakDetectionResource ## What is the purpose of the change This PR is a small addition to #6363 to ensure that ERROR logging is enabled for

[GitHub] flink issue #6370: [FLINK-9894] [runtime] Potential Data Race

2018-07-19 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6370 @tison1 I think PR #6353 and #6370 has causal relationship, the current codebase may not trigger this race condition, right? ---

[jira] [Created] (FLINK-9895) Ensure correct logging settings for NettyLeakDetectionResource

2018-07-19 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9895: --- Summary: Ensure correct logging settings for NettyLeakDetectionResource Key: FLINK-9895 URL: https://issues.apache.org/jira/browse/FLINK-9895 Project: Flink

[jira] [Resolved] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

2018-07-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9762. -- Resolution: Fixed Fixed via master: 6bdec86e31d82d7c38d2509a039a1a03ab9f246e ec28f92ffd0423084

[jira] [Commented] (FLINK-9871) Use Description class for ConfigOptions with rich formatting

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549155#comment-16549155 ] ASF GitHub Bot commented on FLINK-9871: --- Github user zentol commented on a diff in

[GitHub] flink pull request #6371: [FLINK-9871] Use Description class for ConfigOptio...

2018-07-19 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6371#discussion_r203692344 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java --- @@ -42,22 +45,27 @@ public static final ConfigOption WATCH_HEAR

[GitHub] flink pull request #6372: [Flink 9353] Tests running per job standalone clus...

2018-07-19 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6372#discussion_r203692186 --- Diff: flink-end-to-end-tests/README.md --- @@ -31,6 +31,12 @@ You can also run tests individually via $ FLINK_DIR= flink-end-to-end-tests/run-single-

[jira] [Commented] (FLINK-9838) Slot request failed Exceptions after completing a job

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549148#comment-16549148 ] ASF GitHub Bot commented on FLINK-9838: --- Github user yanghua commented on the issue

[GitHub] flink issue #6373: [FLINK-9838][logging] Don't log slot request failures on ...

2018-07-19 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6373 +1 ---

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

2018-07-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549146#comment-16549146 ] ASF GitHub Bot commented on FLINK-9860: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6363: [FLINK-9860][REST] fix buffer leak in FileUploadHa...

2018-07-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6363 ---

  1   2   >