[jira] [Closed] (FLINK-5215) Close checkpoint streams upon cancellation

2016-12-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5215. --- Resolution: Duplicate Duplicated by FLINK-5218 Closed in favor of the newer issue (which is already

[jira] [Issue Comment Deleted] (FLINK-4604) Add support for standard deviation/variance

2016-12-01 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin updated FLINK-4604: Comment: was deleted (was: what if do try return the type of source column instead null?) > Add

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion

2016-12-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15711997#comment-15711997 ] Stephan Ewen commented on FLINK-5217: - Agreed, this should add a comment to refer to the

[jira] [Commented] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-12-01 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712083#comment-15712083 ] Kurt Young commented on FLINK-5185: --- Hi [~fhueske], you are right about the schema thing. It's indeed

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2762 Hi @mushketyk, do you plan to continue with this PR? Thanks, Fabian --- 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

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2762 HI @fhueske, sorry I was a bit busy lately. I'll update the PR tonight. Best regards, Ivan --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink issue #2811: [FLINK-5159] Improve perfomance of inner joins with a sin...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2811 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-2821) Change Akka configuration to allow accessing actors from different URLs

2016-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712187#comment-15712187 ] ASF GitHub Bot commented on FLINK-2821: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-01 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2917 [FLINK-2821] use custom Akka build to listen on all interfaces This uses Flakka (a custom Akka 2.3 build) to resolve the issue that the bind address needs to be matching the external address of the

[GitHub] flink issue #2811: [FLINK-5159] Improve perfomance of inner joins with a sin...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2811 Thanks for the update @AlexanderShoshin. PR is 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

[jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation

2016-12-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15711988#comment-15711988 ] Stephan Ewen commented on FLINK-5218: - True, will close one of the issues. > Eagerly close checkpoint

[GitHub] flink issue #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics

2016-12-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2902 Looks good to merge, +1 :) --- 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

[GitHub] flink pull request #2908: [maven] properly attach the CEP Scala source code

2016-12-01 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2908#discussion_r90469083 --- Diff: flink-libraries/flink-cep-scala/pom.xml --- @@ -93,6 +93,8 @@ under the License. + +src/main/scala

[GitHub] flink pull request #2790: [FLINK-4491] Handle index.number_of_shards in the ...

2016-12-01 Thread ddolzan
Github user ddolzan closed the pull request at: https://github.com/apache/flink/pull/2790 --- 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 issue #2790: [FLINK-4491] Handle index.number_of_shards in the ES conn...

2016-12-01 Thread ddolzan
Github user ddolzan commented on the issue: https://github.com/apache/flink/pull/2790 Index template and index mapping creation/configuration will be kept outside of flink. An example on how to do it can be found on https://github.com/okkam-it/flink-examples. --- If your

[jira] [Commented] (FLINK-5209) Fix TaskManager metrics

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

[jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector

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

[jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector

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

[jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods

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

[jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector

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

[GitHub] flink issue #2790: [FLINK-4491] Handle index.number_of_shards in the ES conn...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2790 Thank you @ddolzan --- 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,

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink pull request #2910: [backport] [FLINK-5193] [jm] Harden job recovery i...

2016-12-01 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2910#discussion_r90446364 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -505,37 +507,31 @@ class JobManager(

[GitHub] flink issue #2901: [FLINK-3921] StringParser encoding

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2901 Hi @greghogan, thanks for working on this. The changes look good. However, I think we need to propagate the configured charset also to the `DelimitedInputFormat`. `DelimitedInputFormat` splits

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to...

2016-12-01 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2842 @vasia You are right. The `TypeExtractor` doesn't support functions with more than 2 inputs. That has never been required so far as the runtime operators always have two inputs. You could open an

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2762 No worries and no need to hurry! :-) Thanks, Fabian --- 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-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails

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

[jira] [Commented] (FLINK-4554) Add support for array types

2016-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712445#comment-15712445 ] ASF GitHub Bot commented on FLINK-4554: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-12-01 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712488#comment-15712488 ] Flavio Pompermaier commented on FLINK-5122: --- Hi @static-max, we've closed our PR to add the

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria...

2016-12-01 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2762#discussion_r90504858 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java --- @@

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[jira] [Closed] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

2016-12-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5216. --- > CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint > start rather then

[jira] [Commented] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

2016-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712443#comment-15712443 ] ASF GitHub Bot commented on FLINK-5214: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #2918: [FLINK-5214] Clean up checkpoint data in case of a...

2016-12-01 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2918 [FLINK-5214] Clean up checkpoint data in case of a failing checkpoint operation Adds exception handling to the stream operators for the snapshotState method. In case of an exception while

[GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria...

2016-12-01 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2762#discussion_r90505208 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/AvroDeserializationSchemaTest.java

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ...

2016-12-01 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2653#discussion_r90479434 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala --- @@ -451,6 +452,28 @@ object

[jira] [Resolved] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

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

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

2016-12-01 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2870#discussion_r90497004 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala --- @@ -78,6 +78,69 @@ object

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

2016-12-01 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2870#discussion_r90495217 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/In.scala --- @@ -0,0 +1,73 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

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

[GitHub] flink issue #2873: [backport] [FLINK-5158] [ckPtCoord] Handle exceptions fro...

2016-12-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2873 Thanks for the review @uce. I have addressed your comments. --- 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

[GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria...

2016-12-01 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2762#discussion_r90504878 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java --- @@

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria...

2016-12-01 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2762#discussion_r90504916 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowSerializationSchema.java

[GitHub] flink pull request #2762: [FLINK-3871] Add Kafka TableSource with Avro seria...

2016-12-01 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2762#discussion_r90504943 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowDeserializationSchema.java

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-01 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90498149 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1372,6 +1381,12 @@ /** The environment variable

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

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

[jira] [Closed] (FLINK-4826) Add keytab based kerberos support for Mesos environment

2016-12-01 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4826. --- Resolution: Fixed This is fixed in PR #2900. > Add keytab based kerberos support for Mesos

[jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation

2016-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712704#comment-15712704 ] ASF GitHub Bot commented on FLINK-5218: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request #2920: [FLINK-5218] [state backends] Eagerly close checkp...

2016-12-01 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2920 [FLINK-5218] [state backends] Eagerly close checkpoint streams on cancellation When a task is canceled during a checkpoint operation, the operation needs to cancel fast. This is a

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client

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

[GitHub] flink issue #2766: [FLINK-4898] Refactor HTTP handlers and Netty server/clie...

2016-12-01 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/2766 @uce it would be nice to get this PR in, to counteract the growing duplication of Netty code in the codebase. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2762 The `String -> String` mapping would be a name mapping of fields from the `GenericRecord` to `Row` attributes. This would allow users to freely choose the attribute names of a table which is

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Closed] (FLINK-4541) Support for SQL NOT IN operator

2016-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4541. Resolution: Fixed Fix Version/s: 1.2.0 Fixed via FLINK-5159 > Support for SQL NOT IN

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-01 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2917#discussion_r90511221 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1891,8 +1891,8 @@ object JobManager { //

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2762 @fhueske Just a small question about your comment. You wrote: "users should be able to provide a Schema and a String ->String to convert aGenericRecordinto a Row" What is String ->

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2016-12-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2917 It's a cool fix to help Flink run in container environments. There is one concern I have with the code, though: Previously, we decided explicitly to encode IP addresses in the Akka URLs,

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

2016-12-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712941#comment-15712941 ] Fabian Hueske commented on FLINK-4541: -- With FLINK-5159 being fixed, the query posted in this issue

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

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

[GitHub] flink pull request #2917: [FLINK-2821] use custom Akka build to listen on al...

2016-12-01 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2917#discussion_r90510382 --- Diff: flink-core/src/main/java/org/apache/flink/util/NetUtils.java --- @@ -309,6 +313,19 @@ public static ServerSocket createSocketFromPorts(Iterator

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

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

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-12-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2811 --- 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] [Closed] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2762 Are there any other cases when a user needs a custom conversion from a `GenericRecord` to a `Row` instance? `String -> String` will definitely work, but I also can think about a generic

[jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation

2016-12-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15712693#comment-15712693 ] Stephan Ewen commented on FLINK-5218: - Fixed in 1.1.4 via 59f61bf6cb8351cec9369e2de39c6eeffbda10ea >

[jira] [Commented] (FLINK-5218) Eagerly close checkpoint streams on cancellation

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

[GitHub] flink issue #2920: [FLINK-5218] [state backends] Eagerly close checkpoint st...

2016-12-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2920 @StefanRRichter There is one change of semantics that would be good to get your input on: A checkpoint stream to which a `byte[0]` array was written is now actually empty and returns a `null`

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[GitHub] flink pull request #2918: [FLINK-5214] Clean up checkpoint data in case of a...

2016-12-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2918 --- 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 issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2762 Would be good if the TableSource could be used by providing parameters and without extending it. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ...

2016-12-01 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2653#discussion_r90478025 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala --- @@ -334,18 +337,33 @@ class CodeGenerator(

[GitHub] flink pull request #2919: [FLINK-4554] [table] Add support for array types

2016-12-01 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2919 [FLINK-4554] [table] Add support for array types This PR adds array support for the Table API and SQL. It adds support for both primitive arrays and object arrays. It adds literals, element access,

[GitHub] flink issue #2910: [backport] [FLINK-5193] [jm] Harden job recovery in case ...

2016-12-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2910 Thanks for the review @StephanEwen & @uce. Will address your comment with the malformed job id. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

2016-12-01 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2870#discussion_r90499247 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/InITCase.java --- @@ -0,0 +1,161 @@ +/* + * Licensed to

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

2016-12-01 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2870#discussion_r90496100 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala --- @@ -78,6 +78,69 @@ object

[jira] [Closed] (FLINK-4918) Add SSL support to Mesos artifact server

2016-12-01 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4918. --- Resolution: Fixed This is fixed in PR #2900. > Add SSL support to Mesos artifact server >

[jira] [Created] (FLINK-5223) Add documentation of UDTF in Table API & SQL

2016-12-01 Thread Jark Wu (JIRA)
Jark Wu created FLINK-5223: -- Summary: Add documentation of UDTF in Table API & SQL Key: FLINK-5223 URL: https://issues.apache.org/jira/browse/FLINK-5223 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-5223) Add documentation of UDTF in Table API & SQL

2016-12-01 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-5223: --- Issue Type: Improvement (was: Bug) > Add documentation of UDTF in Table API & SQL >

[jira] [Updated] (FLINK-5223) Add documentation of UDTF in Table API & SQL

2016-12-01 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-5223: --- Component/s: Table API & SQL > Add documentation of UDTF in Table API & SQL >

  1   2   3   >