[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071033#comment-16071033 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071034#comment-16071034 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #4229: [FLINK-7038] [docs] Correct misused term to KeyedS...

2017-06-30 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4229#discussion_r125155752 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/FoldingState.java --- @@ -28,7 +28,7 @@ * The state is accessed and modified by u

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071036#comment-16071036 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071035#comment-16071035 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #4229: [FLINK-7038] [docs] Correct misused term to KeyedS...

2017-06-30 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4229#discussion_r125155753 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/State.java --- @@ -23,7 +23,7 @@ /** * Interface that different types of par

[GitHub] flink pull request #4229: [FLINK-7038] [docs] Correct misused term to KeyedS...

2017-06-30 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4229#discussion_r125155746 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/AggregatingState.java --- @@ -33,7 +33,7 @@ * The state is accessed and modified

[GitHub] flink pull request #4229: [FLINK-7038] [docs] Correct misused term to KeyedS...

2017-06-30 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4229#discussion_r125155750 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/AppendingState.java --- @@ -29,7 +29,7 @@ * The state is accessed and modified b

[jira] [Commented] (FLINK-6674) Update release 1.3 docs

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16071032#comment-16071032 ] ASF GitHub Bot commented on FLINK-6674: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4211: [FLINK-6674] [FLINK-6680] [docs] Update migration docs fo...

2017-06-30 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4211 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 th

[jira] [Commented] (FLINK-7060) Change annotation in TypeInformation subclasses

2017-06-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070908#comment-16070908 ] Greg Hogan commented on FLINK-7060: --- The {{Public}} annotation denotes stable inheritanc

[jira] [Commented] (FLINK-6877) Activate checkstyle for runtime/security

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070869#comment-16070869 ] ASF GitHub Bot commented on FLINK-6877: --- Github user hsaputra commented on the issue

[GitHub] flink issue #4095: [FLINK-6877] [runtime] Activate checkstyle for runtime/se...

2017-06-30 Thread hsaputra
Github user hsaputra commented on the issue: https://github.com/apache/flink/pull/4095 +1 for merging. The longer it waits the more conflicts it will cause --- 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 d

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3889 --- 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 enab

[jira] [Commented] (FLINK-7044) Add methods to the client API that take the stateDescriptor.

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070478#comment-16070478 ] ASF GitHub Bot commented on FLINK-7044: --- Github user kl0u commented on the issue:

[GitHub] flink issue #4225: [FLINK-7044] [queryable-st] Allow to specify namespace an...

2017-06-30 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4225 @aljoscha thanks for the review, I updated the PR. --- 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 feat

[jira] [Created] (FLINK-7060) Change annotation in TypeInformation subclasses

2017-06-30 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7060: - Summary: Change annotation in TypeInformation subclasses Key: FLINK-7060 URL: https://issues.apache.org/jira/browse/FLINK-7060 Project: Flink Issue Type: I

[GitHub] flink issue #4209: [FLINK-7030] Build with scala-2.11 by default

2017-06-30 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4209 I'm aware of that. I will merge it over the weekend with a bunch of other PR's when the Flink Travis isn't so busy. --- If your project is set up for it, you can reply to this email and have your rep

[jira] [Commented] (FLINK-7030) Build with scala-2.11 by default

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

[jira] [Commented] (FLINK-6043) Display time when exceptions/root cause of failure happened

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070449#comment-16070449 ] ASF GitHub Bot commented on FLINK-6043: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3583: [FLINK-6043] [web] Display exception timestamp

2017-06-30 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3583#discussion_r125088693 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -1070,9 +1088,9 @@ public void suspend(Throwab

[jira] [Updated] (FLINK-7003) "select * from" in Flink SQL should not flatten all fields in the table by default

2017-06-30 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-7003: -- Description: Currently, CompositeRelDataType is extended from RelRecordType(StructKind.PEEK_FIELDS, ...

[jira] [Created] (FLINK-7059) Queryable state does not work with ListState

2017-06-30 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7059: - Summary: Queryable state does not work with ListState Key: FLINK-7059 URL: https://issues.apache.org/jira/browse/FLINK-7059 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7058) flink-scala-shell unintended dependencies for scala 2.11

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070419#comment-16070419 ] ASF GitHub Bot commented on FLINK-7058: --- GitHub user pnowojski opened a pull request

[GitHub] flink pull request #4240: [FLINK-7058] Fix scala-2.10 dependencies

2017-06-30 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4240 [FLINK-7058] Fix scala-2.10 dependencies First commit is from #4209 and should be ignored in this PR Before fixup: ``` $ mvn dependency:tree -pl flink-scala | grep quasi [

[jira] [Updated] (FLINK-7058) flink-scala-shell unintended dependencies for scala 2.11

2017-06-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-7058: -- Affects Version/s: 1.3.0 1.3.1 > flink-scala-shell unintended dependencie

[jira] [Assigned] (FLINK-7058) flink-scala-shell unintended dependencies for scala 2.11

2017-06-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-7058: - Assignee: Piotr Nowojski > flink-scala-shell unintended dependencies for scala 2.11 > ---

[jira] [Created] (FLINK-7058) flink-scala-shell unintended dependencies for scala 2.11

2017-06-30 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-7058: - Summary: flink-scala-shell unintended dependencies for scala 2.11 Key: FLINK-7058 URL: https://issues.apache.org/jira/browse/FLINK-7058 Project: Flink Issu

[jira] [Commented] (FLINK-7030) Build with scala-2.11 by default

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070388#comment-16070388 ] ASF GitHub Bot commented on FLINK-7030: --- Github user pnowojski commented on the issu

[GitHub] flink issue #4209: [FLINK-7030] Build with scala-2.11 by default

2017-06-30 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4209 @zentol build is passing :) --- 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 wi

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-06-30 Thread mpouttuclarke
Github user mpouttuclarke commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125076287 --- Diff: docs/dev/connectors/kinesis.md --- @@ -72,12 +72,80 @@ Before consuming data from Kinesis streams, make sure that all streams are creat

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-06-30 Thread mpouttuclarke
Github user mpouttuclarke commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125074194 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java --- @@ -171

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-06-30 Thread mpouttuclarke
Github user mpouttuclarke commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125073534 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java --- @@ -171

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070319#comment-16070319 ] ASF GitHub Bot commented on FLINK-6988: --- GitHub user pnowojski opened a pull request

[GitHub] flink pull request #4239: [FLINK-6988] Initial flink-connector-kafka-0.11 wi...

2017-06-30 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4239 [FLINK-6988] Initial flink-connector-kafka-0.11 with at-least-once semantic Couple of first commits are from other PRs #4206 #4209 #4213 You can merge this pull request into a Git repository by r

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070310#comment-16070310 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3714: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3714 @rtudoran can you please close this PR? Thank you --- 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 fe

[jira] [Commented] (FLINK-7050) RFC Compliant CSV Parser for Table Source

2017-06-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070301#comment-16070301 ] Fabian Hueske commented on FLINK-7050: -- Thanks for opening this JIRA [~uybhatti]. An

[jira] [Commented] (FLINK-7057) move BLOB ref-counting from LibraryCacheManager to BlobCache

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070255#comment-16070255 ] ASF GitHub Bot commented on FLINK-7057: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4238: [FLINK-7057][blob] move BLOB ref-counting from Lib...

2017-06-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4238 [FLINK-7057][blob] move BLOB ref-counting from LibraryCacheManager to BlobCache Currently, the `LibraryCacheManager` is doing some ref-counting for JAR files managed by it. Instead, we want the `Blob

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r125006340 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala --- @@ -92,8 +92,19 @@ class RelTimeIndi

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r125058559 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggregate/TimeSortProcessFunctionTest.scala --- @@ -122,6 +130,11 @@ cla

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r125058944 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggregate/TimeSortProcessFunctionTest.scala --- @@ -0,0 +1,256 @@ +/

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070252#comment-16070252 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070250#comment-16070250 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070248#comment-16070248 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070253#comment-16070253 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070249#comment-16070249 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070251#comment-16070251 ] ASF GitHub Bot commented on FLINK-6075: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r125006376 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala --- @@ -92,8 +92,19 @@ class RelTimeIndi

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r125063072 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortITCase.scala --- @@ -0,0 +1,127 @@ +/* + * Lice

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-06-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r125040180 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,212 @@ +/* + *

[jira] [Commented] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070243#comment-16070243 ] ASF GitHub Bot commented on FLINK-6916: --- Github user NicoK closed the pull request a

[jira] [Commented] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

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

[GitHub] flink issue #4176: [FLINK-6916][blob] add API to allow job-related BLOBs to ...

2017-06-30 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4176 superseeded by #4237 --- 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, o

[GitHub] flink pull request #4176: [FLINK-6916][blob] add API to allow job-related BL...

2017-06-30 Thread NicoK
Github user NicoK closed the pull request at: https://github.com/apache/flink/pull/4176 --- 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 enabl

[GitHub] flink pull request #4237: [FLINK-7056][blob] add API to allow job-related BL...

2017-06-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4237 [FLINK-7056][blob] add API to allow job-related BLOBs to be stored To ease cleanup, we will make job-related BLOBs be reflected in the blob storage so that they may be removed along with the job. This

[jira] [Commented] (FLINK-7056) add API to allow job-related BLOBs to be stored

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070239#comment-16070239 ] ASF GitHub Bot commented on FLINK-7056: --- GitHub user NicoK opened a pull request:

[jira] [Updated] (FLINK-7055) refactor BlobService#getURL() methods to return a File object

2017-06-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7055: --- Description: As a relic from its use by the {{URLClassLoader}}, {{BlobService#getURL()}} methods alway

[jira] [Commented] (FLINK-7055) refactor BlobService#getURL() methods to return a File object

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070237#comment-16070237 ] ASF GitHub Bot commented on FLINK-7055: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4236: [FLINK-7055][blob] refactor BlobService#getURL() m...

2017-06-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4236 [FLINK-7055][blob] refactor BlobService#getURL() methods to return a File object As a relic from its use by the `URLClassLoader`, `BlobService#getURL()` methods always returned URL objects although t

[jira] [Commented] (FLINK-7054) remove LibraryCacheManager#getFile()

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070232#comment-16070232 ] ASF GitHub Bot commented on FLINK-7054: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4235: [FLINK-7054] [blob] remove LibraryCacheManager#get...

2017-06-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4235 [FLINK-7054] [blob] remove LibraryCacheManager#getFile() `LibraryCacheManager#getFile()` was only used in tests where it is avoidable but if used anywhere else, it may have caused cleanup issues.

[jira] [Commented] (FLINK-7053) improve code quality in some tests

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070228#comment-16070228 ] ASF GitHub Bot commented on FLINK-7053: --- GitHub user NicoK opened a pull request:

[jira] [Updated] (FLINK-7053) improve code quality in some tests

2017-06-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7053: --- Description: * {{BlobClientTest}} and {{BlobClientSslTest}} share a lot of common code * the received

[GitHub] flink pull request #4234: [FLINK-7053] improve code quality in some tests

2017-06-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4234 [FLINK-7053] improve code quality in some tests * `BlobClientTest` and `BlobClientSslTest` share a lot of common code * the received buffers there are currently not verified for being equal to the

[jira] [Created] (FLINK-7057) move BLOB ref-counting from LibraryCacheManager to BlobCache

2017-06-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7057: -- Summary: move BLOB ref-counting from LibraryCacheManager to BlobCache Key: FLINK-7057 URL: https://issues.apache.org/jira/browse/FLINK-7057 Project: Flink Issue

[jira] [Updated] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

2017-06-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6916: --- Component/s: Distributed Coordination > FLIP-19: Improved BLOB storage architecture >

[jira] [Updated] (FLINK-7052) remove NAME_ADDRESSABLE mode

2017-06-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7052: --- Component/s: Distributed Coordination > remove NAME_ADDRESSABLE mode > >

[jira] [Commented] (FLINK-6789) Remove duplicated test utility reducer in optimizer

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070210#comment-16070210 ] ASF GitHub Bot commented on FLINK-6789: --- Github user zhangminglei commented on the i

[GitHub] flink issue #4216: [FLINK-6789] [optimizer] Remove duplicated test utility r...

2017-06-30 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4216 Thanks for review. --- 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 s

[jira] [Created] (FLINK-7056) add API to allow job-related BLOBs to be stored

2017-06-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7056: -- Summary: add API to allow job-related BLOBs to be stored Key: FLINK-7056 URL: https://issues.apache.org/jira/browse/FLINK-7056 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-7055) refactor BlobService#getURL() methods to return a File object

2017-06-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7055: -- Summary: refactor BlobService#getURL() methods to return a File object Key: FLINK-7055 URL: https://issues.apache.org/jira/browse/FLINK-7055 Project: Flink Issu

[jira] [Created] (FLINK-7054) remove LibraryCacheManager#getFile()

2017-06-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7054: -- Summary: remove LibraryCacheManager#getFile() Key: FLINK-7054 URL: https://issues.apache.org/jira/browse/FLINK-7054 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7053) improve code quality in some tests

2017-06-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7053: -- Summary: improve code quality in some tests Key: FLINK-7053 URL: https://issues.apache.org/jira/browse/FLINK-7053 Project: Flink Issue Type: Sub-task C

[GitHub] flink issue #4174: [FLINK-6916][blob] more code style and test improvements

2017-06-30 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4174 let's split this up into two parts... --- 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

[jira] [Commented] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

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

[jira] [Commented] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070174#comment-16070174 ] ASF GitHub Bot commented on FLINK-6916: --- Github user NicoK closed the pull request a

[GitHub] flink pull request #4174: [FLINK-6916][blob] more code style and test improv...

2017-06-30 Thread NicoK
Github user NicoK closed the pull request at: https://github.com/apache/flink/pull/4174 --- 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 enabl

[jira] [Commented] (FLINK-7047) Reorganize build profiles

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

[GitHub] flink issue #4233: [FLINK-7047] [travis] Reorganize build profiles

2017-06-30 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 I would merge this PR in any case. It's a nice short-term option that is more stable than the previous approach; regardless of how many times we add in flink-runtime we can still test connectors/libs

[jira] [Created] (FLINK-7052) remove NAME_ADDRESSABLE mode

2017-06-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7052: -- Summary: remove NAME_ADDRESSABLE mode Key: FLINK-7052 URL: https://issues.apache.org/jira/browse/FLINK-7052 Project: Flink Issue Type: Sub-task Compone

[jira] [Updated] (FLINK-6008) collection of BlobServer improvements

2017-06-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6008: --- Description: The following things should be improved around the BlobServer/BlobCache: * update config

[GitHub] flink issue #4233: [FLINK-7047] [travis] Reorganize build profiles

2017-06-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4233 @zentol could you start a mailing list discussion and describe your preference for splitting the tests in this manner or splitting the repo? Despite heroic efforts by you and Robert keeping the tes

[jira] [Commented] (FLINK-7047) Reorganize build profiles

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070104#comment-16070104 ] ASF GitHub Bot commented on FLINK-7047: --- Github user greghogan commented on the issu

[jira] [Commented] (FLINK-7044) Add methods to the client API that take the stateDescriptor.

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070096#comment-16070096 ] ASF GitHub Bot commented on FLINK-7044: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #4225: [FLINK-7044] [queryable-st] Allow to specify names...

2017-06-30 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4225#discussion_r125039522 --- Diff: flink-tests/src/test/java/org/apache/flink/test/query/AbstractQueryableStateITCase.java --- @@ -534,33 +537,66 @@ public Integer getKey(Tuple2 va

[jira] [Commented] (FLINK-7044) Add methods to the client API that take the stateDescriptor.

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070094#comment-16070094 ] ASF GitHub Bot commented on FLINK-7044: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #4225: [FLINK-7044] [queryable-st] Allow to specify names...

2017-06-30 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4225#discussion_r125039482 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java --- @@ -0,0 +1,102 @@ +/* + * Licensed to the Apach

[jira] [Updated] (FLINK-7003) "select * from" in Flink SQL should not flatten all fields in the table by default

2017-06-30 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7003: Issue Type: Sub-task (was: Bug) Parent: FLINK-7051 > "select * from" in Flink SQL should no

[jira] [Commented] (FLINK-5031) Consecutive DataStream.split() ignored

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070089#comment-16070089 ] ASF GitHub Bot commented on FLINK-5031: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-5031) Consecutive DataStream.split() ignored

2017-06-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070088#comment-16070088 ] Aljoscha Krettek commented on FLINK-5031: - Actually, the current behaviour seems a

[GitHub] flink issue #2847: [FLINK-5031]Consecutive DataStream.split() ignored

2017-06-30 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2847 I wrote a somewhat longer comment on the issue explaining some stuff: https://issues.apache.org/jira/browse/FLINK-5031?focusedCommentId=16070088&page=com.atlassian.jira.plugin.system.issuetabpanels:c

[jira] [Created] (FLINK-7051) Bump up Calcite version to 1.14

2017-06-30 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7051: --- Summary: Bump up Calcite version to 1.14 Key: FLINK-7051 URL: https://issues.apache.org/jira/browse/FLINK-7051 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-7003) "select * from" in Flink SQL should not flatten all fields in the table by default

2017-06-30 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7003: Description: Currently, CompositeRelDataType is extended from RelRecordType(StructKind.PEEK_FIELDS,

[jira] [Commented] (FLINK-7048) Define javadoc skipping in travis watchdog script

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070084#comment-16070084 ] ASF GitHub Bot commented on FLINK-7048: --- Github user greghogan commented on the issu

[GitHub] flink issue #4227: [FLINK-7048] [travis] Define javadoc skipping in travis w...

2017-06-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4227 +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 wishes so, or if the featur

[jira] [Commented] (FLINK-7046) Hide logging about downloaded artifacts on travis

2017-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16070082#comment-16070082 ] ASF GitHub Bot commented on FLINK-7046: --- Github user greghogan commented on the issu

[GitHub] flink issue #4226: [FLINK-7046] [travis] Hide download logging messages

2017-06-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4226 +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 wishes so, or if the featu

  1   2   3   >