[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204394#comment-16204394 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 12:46 AM: >From

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204394#comment-16204394 ] Michael Fong commented on FLINK-7839: - >From above comment, I propose we could put a note in document

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204390#comment-16204390 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 12:41 AM: I can help

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204390#comment-16204390 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 12:34 AM: I can help

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204390#comment-16204390 ] Michael Fong commented on FLINK-7839: - I can help update the document since I also encountered the

[jira] [Assigned] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Michael Fong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Fong reassigned FLINK-7839: --- Assignee: Michael Fong > Creating Quickstart project for SNAPSHOT version fails >

[GitHub] flink pull request #3688: [FLINK-6273] [core] don't convert hostname to lowe...

2017-10-13 Thread barcahead
Github user barcahead closed the pull request at: https://github.com/apache/flink/pull/3688 ---

[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204289#comment-16204289 ] ASF GitHub Bot commented on FLINK-6273: --- Github user barcahead closed the pull request at:

[GitHub] flink pull request #4816: [hotfix][docs] CEP docs review to remove weasel wo...

2017-10-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4816 ---

[jira] [Assigned] (FLINK-7799) Improve performance of windowed joins

2017-10-13 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7799: -- Assignee: Xingcan Cui > Improve performance of windowed joins >

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204015#comment-16204015 ] ASF GitHub Bot commented on FLINK-7798: --- GitHub user xccui opened a pull request:

[GitHub] flink pull request #4825: [FLINK-7798] [table] Add support for stream window...

2017-10-13 Thread xccui
GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/4825 [FLINK-7798] [table] Add support for stream windowed inner joins to Table API ## What is the purpose of the change The PR enables the time-windowed inner join for

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203933#comment-16203933 ] ASF GitHub Bot commented on FLINK-6225: --- Github user PangZhi commented on the issue:

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-13 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol @fhueske Can you take another look. ---

[GitHub] flink issue #4559: [FLINK-7468][network] Implement sender backlog logic for ...

2017-10-13 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4559 @pnowojski , this PR is ready for review. :) ---

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203825#comment-16203825 ] ASF GitHub Bot commented on FLINK-7468: --- Github user zhijiangW commented on the issue:

[jira] [Commented] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203810#comment-16203810 ] ASF GitHub Bot commented on FLINK-7456: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #4552: [FLINK-7456][network] Implement Netty sender incoming pip...

2017-10-13 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4552 @pnowojski , this PR is ready for review. It covers almost all the logics of credit-based on sender side. In addition, I replace the current `PartitionRequestClientHandler` with

[jira] [Updated] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7839: Description: The documentation on creating quickstart projects is broken for SNAPSHOT releases. For

[jira] [Created] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Gary Yao (JIRA)
Gary Yao created FLINK-7839: --- Summary: Creating Quickstart project for SNAPSHOT version fails Key: FLINK-7839 URL: https://issues.apache.org/jira/browse/FLINK-7839 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5808: --- Assignee: (was: Aljoscha Krettek) > Missing verification for setParallelism and

[jira] [Assigned] (FLINK-6113) Implement split/select with Side Outputs

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-6113: --- Assignee: (was: Aljoscha Krettek) > Implement split/select with Side Outputs >

[jira] [Assigned] (FLINK-5363) Fire timers when window state is currently empty

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5363: --- Assignee: (was: Aljoscha Krettek) > Fire timers when window state is currently

[jira] [Closed] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3582. --- Resolution: Fixed Fix Version/s: 1.4.0 Implemented in FLINK-7683 > Add Iterator over

[jira] [Closed] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2706. --- Resolution: Won't Fix This has been superseded by the work to make the {{BucketingSink}} our

[jira] [Assigned] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2747: --- Assignee: (was: Aljoscha Krettek) > TypeExtractor does not correctly analyze

[jira] [Commented] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203760#comment-16203760 ] Kostas Kloudas commented on FLINK-7830: --- I closed the issues here because, as I wrote in the JIRAs

[jira] [Closed] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2600. --- Resolution: Cannot Reproduce Hasn't occurred in about a year. > Failing

[jira] [Closed] (FLINK-2506) HBase connection closing down (table distributed over more than 1 region server - Flink Cluster-Mode)

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2506. --- Resolution: Won't Fix Closing after too much inactivity and code changed in between. > HBase

[jira] [Assigned] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-987: -- Assignee: (was: Aljoscha Krettek) > Extend TypeSerializers and -Comparators to work

[jira] [Assigned] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-4072: --- Assignee: (was: Aljoscha Krettek) >

[jira] [Closed] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7830. --- Resolution: Fixed > Problematic interaction of CEP and asynchronous snapshots >

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

2017-10-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7756. - Resolution: Fixed Hi, We just merged 2 in the master fixes for the following issues.

[jira] [Closed] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-10-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6321. - Resolution: Fixed Hi, We just merged 2 in the master fixes for the following issues.

[jira] [Updated] (FLINK-7838) Kafka 0.11 producer exactly-once test failure

2017-10-13 Thread Piotr Nowojski (JIRA)
/287502990/log.txt?X-Amz-Expires=30=20171013T125617Z=AWS4-HMAC-SHA256=AKIAJRYRXRSVGNKPKO5A/20171013/us-east-1/s3/aws4_request=host=c93f6270805b97e693b396d1283c28a62a99e6fff152a54c6fd5a42507f48e5d) > Kafka 0.11 producer exactly-once test fail

[jira] [Updated] (FLINK-7838) Kafka 0.11 producer exactly-once test failure

2017-10-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-7838: -- Attachment: log.txt > Kafka 0.11 producer exactly-once test failure >

[jira] [Closed] (FLINK-7435) FsStateBackend with incremental backup enable does not work with Keyed CEP

2017-10-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7435. - Resolution: Fixed Hi, We just merged 2 in the master fixes for the following issues.

[jira] [Closed] (FLINK-7760) Restore failing from external checkpointing metadata.

2017-10-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7760. - Resolution: Fixed Hi, We just merged 2 in the master fixes for the following issues.

[jira] [Created] (FLINK-7838) Kafka 0.11 producer exactly-once test failure

2017-10-13 Thread Piotr Nowojski (JIRA)
=AKIAJRYRXRSVGNKPKO5A/20171013/us-east-1/s3/aws4_request=host=c93f6270805b97e693b396d1283c28a62a99e6fff152a54c6fd5a42507f48e5d -- This message was sent by Atlassian JIRA (v6.4.14#64029)

[jira] [Created] (FLINK-7837) AggregatingFunction does not work with immutable types

2017-10-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7837: --- Summary: AggregatingFunction does not work with immutable types Key: FLINK-7837 URL: https://issues.apache.org/jira/browse/FLINK-7837 Project: Flink

[jira] [Assigned] (FLINK-5968) Document WindowedStream.aggregate()

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5968: --- Assignee: Aljoscha Krettek > Document WindowedStream.aggregate() >

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203642#comment-16203642 ] ASF GitHub Bot commented on FLINK-7648: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4824: [FLINK-7648] [flip6] Add TaskManagersHandler

2017-10-13 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4824 [FLINK-7648] [flip6] Add TaskManagersHandler ## What is the purpose of the change Add the `TaskManagersHandler` for the new REST server endpoint. ## Brief change log

[jira] [Commented] (FLINK-7812) Log system resources as metrics

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203618#comment-16203618 ] ASF GitHub Bot commented on FLINK-7812: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4801: [FLINK-7812] Log system resources metrics

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4801 Eclipse Public License is not impossible, but tricky. I am not a lawyer, but this is what I picked up over the year: EPL is weak copyleft, meaning linking is okay, but modifying not

[jira] [Closed] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7484. --- Resolution: Fixed Fixed on release-1.3 in 664a04c8977c04698576d788b878b4c89f16acc6 Fixed on

[GitHub] flink issue #4816: [hotfix][docs] CEP docs review to remove weasel words, fi...

2017-10-13 Thread ChrisChinchilla
Github user ChrisChinchilla commented on the issue: https://github.com/apache/flink/pull/4816 @StephanEwen I noticed that just as I submitted it, will look next week :) ---

[jira] [Commented] (FLINK-7832) SlotManager should return number of registered slots

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203555#comment-16203555 ] ASF GitHub Bot commented on FLINK-7832: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4823: [FLINK-7832] [flip6] Extend SlotManager to report ...

2017-10-13 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4823 [FLINK-7832] [flip6] Extend SlotManager to report free slots per TM ## What is the purpose of the change Extend the `SlotManager` such that we count the free slots per `TaskManager`.

[GitHub] flink issue #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4807 I think this is good now, +1 ---

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203546#comment-16203546 ] ASF GitHub Bot commented on FLINK-7810: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203540#comment-16203540 ] ASF GitHub Bot commented on FLINK-5706: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4818: [FLINK-5706] [file systems] Add S3 file systems without H...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4818 Thanks @steveloughran for the comments. I am actually using Hadoop 2.8.1 here with AWS SDK 1.11.95. The shaded artifacts are only a few MBs large, so this seems okay. ---

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203534#comment-16203534 ] ASF GitHub Bot commented on FLINK-5706: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #4818: [FLINK-5706] [file systems] Add S3 file systems wi...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4818#discussion_r144546384 --- Diff: flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/S3FileSystemFactory.java --- @@ -0,0 +1,145 @@ +/* +

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203518#comment-16203518 ] ASF GitHub Bot commented on FLINK-6615: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4787 I think here is an interesting example of why I am often hesitant with cleanup refactorings, unless there is a pressing need to clean up. It is very hard to judge if the cleaned up

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4787 Actually, going back here. I would like to not merge this after all. The reason being that in my test run, I found that this does not handle concurrent deletes correctly after all:

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203514#comment-16203514 ] ASF GitHub Bot commented on FLINK-6615: --- Github user StephanEwen commented on the issue:

[jira] [Assigned] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7484: --- Assignee: Aljoscha Krettek > CaseClassSerializer.duplicate() does not perform proper

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203500#comment-16203500 ] ASF GitHub Bot commented on FLINK-7388: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4786: [FLINK-7388][DataStream API] ProcessFunction.onTimer() se...

2017-10-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4786 @fhueske is this what you had in mind? ---

[jira] [Closed] (FLINK-7414) Hardcode scala.version to 2.11 in flink-quickstart-scala

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7414. --- Resolution: Fixed Fixed in 85b2f27067ce2fe5b16b3126c816b27e916477d8 > Hardcode scala.version

[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203485#comment-16203485 ] ASF GitHub Bot commented on FLINK-6273: --- Github user aljoscha commented on the issue:

[jira] [Closed] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6273. --- Resolution: Duplicate This has been superseded by FLINK-7540 > Client can't connect to

[GitHub] flink issue #3688: [FLINK-6273] [core] don't convert hostname to lower cases...

2017-10-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3688 @barcahead could you please close this because it has been superseded by #4812 ---

[GitHub] flink issue #4801: [FLINK-7812] Log system resources metrics

2017-10-13 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4801 As on dev mailing list discussion, this feature uses https://github.com/oshi/oshi library licensed under EPL 1.0. It seems to be compatible with ours: https://www.apache.org/legal/resolved.html .

[jira] [Closed] (FLINK-7835) Fix duplicate() method in NFASerializer

2017-10-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7835. - Resolution: Fixed Merged on master with ff9cefb36c70a9b6c55f607fc2b56644c57f7057 > Fix

[jira] [Commented] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled

2017-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203440#comment-16203440 ] Fabian Hueske commented on FLINK-7763: -- Fixed for 1.4.0 with 57333c62271253248bf3699be31ae7224e97de75

[jira] [Commented] (FLINK-7835) Fix duplicate() method in NFASerializer

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203428#comment-16203428 ] ASF GitHub Bot commented on FLINK-7835: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7812) Log system resources as metrics

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203432#comment-16203432 ] ASF GitHub Bot commented on FLINK-7812: --- Github user pnowojski commented on the issue:

[GitHub] flink pull request #4821: [FLINK-7835][cep] Fix duplicate() in NFASerializer...

2017-10-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4821 ---

[jira] [Commented] (FLINK-7835) Fix duplicate() method in NFASerializer

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203427#comment-16203427 ] ASF GitHub Bot commented on FLINK-7835: --- Github user kl0u commented on the issue:

[GitHub] flink issue #4821: [FLINK-7835][cep] Fix duplicate() in NFASerializer.

2017-10-13 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4821 Merging this. ---

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203412#comment-16203412 ] ASF GitHub Bot commented on FLINK-7810: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-13 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144530220 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerComponentsStartupShutdownTest.java --- @@ -202,8 +202,6 @@ protected

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-13 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144529895 --- Diff: .travis.yml --- @@ -61,31 +61,6 @@ matrix: - TEST="misc" - PROFILE="-Dhadoop.version=2.8.0" -

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203410#comment-16203410 ] ASF GitHub Bot commented on FLINK-7810: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-5944) Flink should support reading Snappy Files

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203408#comment-16203408 ] ASF GitHub Bot commented on FLINK-5944: --- Github user mlipkovich commented on the issue:

[GitHub] flink issue #4683: [FLINK-5944] Support reading of Snappy files

2017-10-13 Thread mlipkovich
Github user mlipkovich commented on the issue: https://github.com/apache/flink/pull/4683 @aljoscha @haohui , thank you for your comments. Marked hadoop dependency as provided, set Hadoop codec as default one ---

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-13 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144528124 --- Diff: flink-queryable-state/flink-queryable-state-java/pom.xml --- @@ -110,8 +110,8 @@ under the License. -

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203402#comment-16203402 ] ASF GitHub Bot commented on FLINK-7810: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #4822: [FLINK-7484] Perform proper deep copy in CaseClass...

2017-10-13 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4822 [FLINK-7484] Perform proper deep copy in CaseClassSerializer.duplicate() R: @kl0u You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203390#comment-16203390 ] ASF GitHub Bot commented on FLINK-7484: --- GitHub user aljoscha opened a pull request:

[jira] [Updated] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2017-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7484: Summary: CaseClassSerializer.duplicate() does not perform proper deep copy (was:

[GitHub] flink issue #4816: [hotfix][docs] CEP docs review to remove weasel words, fi...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4816 Would be great to also have this in the 1.3 docs, but cherry-picking the committ does not work... ---

[GitHub] flink issue #4816: [hotfix][docs] CEP docs review to remove weasel words, fi...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4816 Thanks, merging this... ---

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144518821 --- Diff: flink-queryable-state/flink-queryable-state-java/pom.xml --- @@ -110,8 +110,8 @@ under the License.

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203365#comment-16203365 ] ASF GitHub Bot commented on FLINK-7810: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144518199 --- Diff: .travis.yml --- @@ -61,31 +61,6 @@ matrix: - TEST="misc" - PROFILE="-Dhadoop.version=2.8.0" -

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203366#comment-16203366 ] ASF GitHub Bot commented on FLINK-7810: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203364#comment-16203364 ] ASF GitHub Bot commented on FLINK-7810: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4807#discussion_r144519154 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerComponentsStartupShutdownTest.java --- @@ -202,8 +202,6 @@

[GitHub] flink issue #4801: [FLINK-7812] Log system resources metrics

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4801 Thanks for this addition. Few comments: - Please try to follow the common (though not enforced) code style when it comes to empty lines between class declarations, fields, methods,

[jira] [Commented] (FLINK-7812) Log system resources as metrics

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203354#comment-16203354 ] ASF GitHub Bot commented on FLINK-7812: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203348#comment-16203348 ] ASF GitHub Bot commented on FLINK-6505: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4798: [FLINK-6505] Proactively cleanup local FS for RocksDBKeye...

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4798 Probably good change for now. I think in the long run, the TaskManager should give each Task a sub-directory and make sure that sub directory is cleared whenever tasks

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203341#comment-16203341 ] ASF GitHub Bot commented on FLINK-6615: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

2017-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4787 Fair enough. Seems there are tests for the behavior already, so +1 to merge this Merging... ---

[jira] [Commented] (FLINK-7835) Fix duplicate() method in NFASerializer

2017-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203338#comment-16203338 ] ASF GitHub Bot commented on FLINK-7835: --- Github user aljoscha commented on a diff in the pull

  1   2   >