[jira] [Commented] (FLINK-4783) Allow to register TypeInfoFactories manually

2016-10-10 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562288#comment-15562288 ] Alexander Alexandrov commented on FLINK-4783: - Alright, I guess keeping

[jira] [Comment Edited] (FLINK-4783) Allow to register TypeInfoFactories manually

2016-10-10 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562288#comment-15562288 ] Alexander Alexandrov edited comment on FLINK-4783 at 10/10/16 1:18 PM:

[jira] [Commented] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Florian Koenig (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562289#comment-15562289 ] Florian Koenig commented on FLINK-4788: --- Thanks for the quick fix! Sorry about the links to the

[jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph

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

[GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG...

2016-10-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2577 Ah i see. I removed it since it was pretty much identical to the ExecutionConfigSummary class; it would've been a rename essentially. I like the interface idea, makes it a bit more organized. ---

[jira] [Closed] (FLINK-3263) Log task statistics on TaskManager

2016-10-10 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3263. - Resolution: Not A Problem The metrics subsystem can provide this functionality. > Log task statistics on

[jira] [Updated] (FLINK-4790) FlinkML - Error of type while using readCsvFile

2016-10-10 Thread Thomas FOURNIER (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas FOURNIER updated FLINK-4790: --- Priority: Minor (was: Major) > FlinkML - Error of type while using readCsvFile >

[jira] [Created] (FLINK-4790) FlinkML - Error of type while using readCsvFile

2016-10-10 Thread Thomas FOURNIER (JIRA)
Thomas FOURNIER created FLINK-4790: -- Summary: FlinkML - Error of type while using readCsvFile Key: FLINK-4790 URL: https://issues.apache.org/jira/browse/FLINK-4790 Project: Flink Issue

[jira] [Assigned] (FLINK-4783) Allow to register TypeInfoFactories manually

2016-10-10 Thread Alexander Alexandrov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Alexandrov reassigned FLINK-4783: --- Assignee: Alexander Alexandrov > Allow to register TypeInfoFactories

[jira] [Assigned] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

2016-10-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4497: --- Assignee: Chesnay Schepler > Add support for Scala tuples and case classes to

[jira] [Commented] (FLINK-4790) FlinkML - Error of type while using readCsvFile

2016-10-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562316#comment-15562316 ] Timo Walther commented on FLINK-4790: - When using the Scala API, make sure to import the package:

[GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0...

2016-10-10 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2369 Thank you for the review. I'll address your comments, rebase again, test it, and if it turns green merge it ;) --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r82591567 --- Diff: flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java --- @@ -36,6 +38,8 @@ private final

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r82590833 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,106 @@ +package

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r82590712 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,106 @@ +package

[jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph

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

[GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG...

2016-10-10 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2577 Thanks for the pr @zentol. Looks good to me! A couple of things I noticed: - The prefix of the interfaces (`Access*`) could be a bit confusing. What about these? - interface:

[GitHub] flink pull request #2477: [FLINK-4506] CsvOutputFormat defaults allowNullVal...

2016-10-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2477#discussion_r82594396 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java --- @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-10-10 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562191#comment-15562191 ] Anton Solovev commented on FLINK-4743: -- Should a new function provide various types like

[jira] [Commented] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r82594969 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,106 @@ +package

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink issue #2595: [FLINK-3656] [table] Test base for logical unit testing

2016-10-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2595 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Issue Comment Deleted] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4155: -- Comment: was deleted (was: This issue has been resolved with FLINK-4379.) > Get Kafka producer

[GitHub] flink issue #2330: FLINK-4311 Fixed several problems in TableInputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2330 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[GitHub] flink issue #2611: [FLINK-4778] Update program example in /docs/setup/cli.md...

2016-10-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2611 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-3656) Rework Table API tests

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

[jira] [Commented] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

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

[jira] [Commented] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562207#comment-15562207 ] Robert Metzger commented on FLINK-4155: --- This issue has been resolved with FLINK-4379. > Get Kafka

[jira] [Commented] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open()

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562211#comment-15562211 ] Robert Metzger commented on FLINK-4023: --- This has been resolved in FLINK-4379. > Move Kafka

[jira] [Resolved] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open()

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4023. --- Resolution: Fixed Assignee: Stefan Richter (was: Tzu-Li (Gordon) Tai) > Move Kafka

[jira] [Comment Edited] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open()

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562211#comment-15562211 ] Robert Metzger edited comment on FLINK-4023 at 10/10/16 12:48 PM: -- This

[jira] [Commented] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562226#comment-15562226 ] Stephan Ewen commented on FLINK-4788: - 1.1.3 fix in d619f51ac8f922c0cf1d1e789c5141076128f04e > State

[jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph

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

[GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG...

2016-10-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2577 I did not want to rename all usages of ExecutionGraph, correct. Otherwise i would've went with exactly the names you suggested. I am using the ExecutionConfigSummary (and removed my original

[GitHub] flink pull request #2545: [FLINK-4673] [core] TypeInfoFactory for Either typ...

2016-10-10 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2545#discussion_r82598976 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -675,38 +673,6 @@ else if (isClassType(t) &&

[jira] [Created] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption

2016-10-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4789: - Summary: Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption Key: FLINK-4789 URL:

[GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG...

2016-10-10 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2577 >I am using the ExecutionConfigSummary (and removed my original ArchivedExecutionConfig) when i rebased, so I'm not sure what you mean :/ That's what I meant, I wondered why you didn't use your

[jira] [Commented] (FLINK-4673) TypeInfoFactory for Either type

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

[jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph

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

[jira] [Commented] (FLINK-4781) Add User Defined Function(UDF) API for Table API

2016-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562063#comment-15562063 ] Fabian Hueske commented on FLINK-4781: -- [~sunjincheng121] Can you check if the features implemented

[jira] [Assigned] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API

2016-10-10 Thread Evgeny Kincharov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Kincharov reassigned FLINK-3133: --- Assignee: Evgeny Kincharov > Introduce collect()/coun()/print() methods in

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r82591316 --- Diff: flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java --- @@ -36,6 +38,8 @@ private final

[jira] [Commented] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562134#comment-15562134 ] Stephan Ewen commented on FLINK-4788: - Will look into this... > State backend class cannot be loaded,

[jira] [Assigned] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4788: --- Assignee: Stephan Ewen > State backend class cannot be loaded, because fully qualified name

[jira] [Updated] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4788: Fix Version/s: 1.1.3 1.2.0 > State backend class cannot be loaded, because fully

[jira] [Assigned] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3706: - Assignee: Robert Metzger > YARNSessionCapacitySchedulerITCase.testNonexistingQueue

[jira] [Commented] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562415#comment-15562415 ] Robert Metzger commented on FLINK-3706: --- Another instance

[jira] [Commented] (FLINK-4720) Implement an archived version of the execution graph

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

[GitHub] flink issue #2577: [FLINK-4720] Implement archived version of the ExecutionG...

2016-10-10 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2577 Thanks. Looks good to merge! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-4790) FlinkML - Error of type while using readCsvFile

2016-10-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562442#comment-15562442 ] Timo Walther commented on FLINK-4790: - I will close the issue for now. But you are welcome to open a

[jira] [Closed] (FLINK-4790) FlinkML - Error of type while using readCsvFile

2016-10-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-4790. --- Resolution: Won't Fix > FlinkML - Error of type while using readCsvFile >

[jira] [Commented] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

2016-10-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15562445#comment-15562445 ] Robert Metzger commented on FLINK-4398: --- Another instance: {code} Failed tests:

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

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

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-10-10 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 @rmetzger can you please take a look at the updated patch --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-3656) Rework Table API tests

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

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[jira] [Commented] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

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

[GitHub] flink pull request #2611: [FLINK-4778] Update program example in /docs/setup...

2016-10-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2611 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2595: [FLINK-3656] [table] Test base for logical unit te...

2016-10-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2595 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

2016-10-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2330 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4788. - Resolution: Fixed Fixed in - 1.1.3 via d619f51ac8f922c0cf1d1e789c5141076128f04e - 1.2.0 via

[jira] [Closed] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case

2016-10-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4788. --- > State backend class cannot be loaded, because fully qualified name converted > to lower-case >

[jira] [Created] (FLINK-4792) Update documentation - QuickStart - FlinkML

2016-10-10 Thread Thomas FOURNIER (JIRA)
Thomas FOURNIER created FLINK-4792: -- Summary: Update documentation - QuickStart - FlinkML Key: FLINK-4792 URL: https://issues.apache.org/jira/browse/FLINK-4792 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4792) Update documentation - FlinkML/QuickStart Guide

2016-10-10 Thread Thomas FOURNIER (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas FOURNIER updated FLINK-4792: --- Summary: Update documentation - FlinkML/QuickStart Guide (was: Update documentation -

[jira] [Commented] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

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

[jira] [Closed] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021

2016-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4778. Resolution: Fixed Fix Version/s: 1.2.0 1.1.4 Fixed for 1.1.x with

[jira] [Closed] (FLINK-4311) TableInputFormat fails when reused on next split

2016-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4311. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[jira] [Closed] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

2016-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2765. Resolution: Fixed Assignee: Fabian Hueske Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[jira] [Created] (FLINK-4794) partition_by_hash() crashes if no parameter is provided

2016-10-10 Thread Yakov Goldberg (JIRA)
Yakov Goldberg created FLINK-4794: - Summary: partition_by_hash() crashes if no parameter is provided Key: FLINK-4794 URL: https://issues.apache.org/jira/browse/FLINK-4794 Project: Flink

[jira] [Commented] (FLINK-1091) Allow joins with the solution set using key selectors

2016-10-10 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564179#comment-15564179 ] Neelesh Srinivas Salian commented on FLINK-1091: Hi, [~vkalavri], checking if this has

[jira] [Commented] (FLINK-4781) Add User Defined Function(UDF) API for Table API

2016-10-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564217#comment-15564217 ] sunjincheng commented on FLINK-4781: Thanks for taking time to check this, Fabian. when we try to

[jira] [Commented] (FLINK-1497) No documentation on MiniCluster

2016-10-10 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564170#comment-15564170 ] Neelesh Srinivas Salian commented on FLINK-1497: Checking if this is still valid, unless

[jira] [Commented] (FLINK-959) Automated bare-metal deployment of FLINK on Amazon EC2 and OpenStack instances

2016-10-10 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564177#comment-15564177 ] Neelesh Srinivas Salian commented on FLINK-959: --- Is this still applicable? [~rmetzger] or

[jira] [Closed] (FLINK-4781) Add User Defined Function(UDF) API for Table API

2016-10-10 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-4781. Resolution: Duplicate > Add User Defined Function(UDF) API for Table API >

[GitHub] flink issue #2611: [FLINK-4778] Update program example in /docs/setup/cli.md...

2016-10-10 Thread heytitle
Github user heytitle commented on the issue: https://github.com/apache/flink/pull/2611 @fhueske you're welcome 😄 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Created] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

2016-10-10 Thread Ted Dunning (JIRA)
Ted Dunning created FLINK-4793: -- Summary: Using a local method with :: notation in Java 8 causes index out of bounds Key: FLINK-4793 URL: https://issues.apache.org/jira/browse/FLINK-4793 Project: Flink

[jira] [Created] (FLINK-4795) CsvStringify crashes in case of tuple in tuple, t.e. ("a", True, (1,5))

2016-10-10 Thread Yakov Goldberg (JIRA)
Yakov Goldberg created FLINK-4795: - Summary: CsvStringify crashes in case of tuple in tuple, t.e. ("a", True, (1,5)) Key: FLINK-4795 URL: https://issues.apache.org/jira/browse/FLINK-4795 Project:

[jira] [Commented] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

2016-10-10 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564165#comment-15564165 ] Neelesh Srinivas Salian commented on FLINK-4627: Shall I work on this if no one has

[jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree

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

[GitHub] flink issue #2442: [FLINK-4148] incorrect calculation minDist distance in Qu...

2016-10-10 Thread nssalian
Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2442 Seems good to me. @zentol do you have time to add some extra review on this? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4792) Update documentation - FlinkML/QuickStart Guide

2016-10-10 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15564166#comment-15564166 ] Neelesh Srinivas Salian commented on FLINK-4792: Shall I work on this if no one has begun?

[GitHub] flink issue #2603: [FLINK-4745] [table] Convert KafkaTableSource test to uni...

2016-10-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2603 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Closed] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

2016-10-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4777. - Resolution: Fixed master: b949d42d9f16fe52126f03a960fdf23ad71e6e63 release-1.1:

[jira] [Commented] (FLINK-4738) Port TaskManager logic to TaskExecutor

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

[GitHub] flink pull request #2594: [FLINK-4738] [TaskManager] Port TaskManager logic ...

2016-10-10 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2594#discussion_r82563262 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java --- @@ -127,12 +195,423 @@ public void start() {

[GitHub] flink issue #2330: FLINK-4311 Fixed several problems in TableInputFormat

2016-10-10 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2330 I'll propose to drop the hadoop1 builds on the dev ML. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-4738) Port TaskManager logic to TaskExecutor

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

[GitHub] flink pull request #2594: [FLINK-4738] [TaskManager] Port TaskManager logic ...

2016-10-10 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2594#discussion_r82563195 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateRegistryGateway.java --- @@ -0,0 +1,57 @@ +/* + * Licensed to the

[GitHub] flink pull request #2594: [FLINK-4738] [TaskManager] Port TaskManager logic ...

2016-10-10 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2594#discussion_r82562672 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -507,12 +509,18 @@ public void suspendJob(final

[jira] [Created] (FLINK-4784) MetricQueryService actor name collision

2016-10-10 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4784: --- Summary: MetricQueryService actor name collision Key: FLINK-4784 URL: https://issues.apache.org/jira/browse/FLINK-4784 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4738) Port TaskManager logic to TaskExecutor

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

[jira] [Commented] (FLINK-4745) Convert KafkaTableSource test to unit tests

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

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

  1   2   >