[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-07-21 Thread Steven Zhen Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16097121#comment-16097121 ] Steven Zhen Wu commented on FLINK-6301: --- [~vidhu5269] is this bug only related to gzip compression?

[jira] [Created] (FLINK-7242) Drop Java 7 Support

2017-07-21 Thread Eron Wright (JIRA)
Eron Wright created FLINK-7242: --- Summary: Drop Java 7 Support Key: FLINK-7242 URL: https://issues.apache.org/jira/browse/FLINK-7242 Project: Flink Issue Type: Task Reporter: Eron

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-07-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096992#comment-16096992 ] Fabian Hueske commented on FLINK-6747: -- Fixed for 1.3 with 6856875e7691c55b0ce14bf90dfa687eb15cb539

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

2017-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096958#comment-16096958 ] ASF GitHub Bot commented on FLINK-7194: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4379: [FLINK-7194] [table] Add methods for type hints to UDAGG ...

2017-07-21 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4379 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

[GitHub] flink pull request #4383: [hotfix] [optimizer] Normalize job plan operator f...

2017-07-21 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4383 [hotfix] [optimizer] Normalize job plan operator formatting When printing the job plan the operator description is typically formatted as the operator name followed by the user given or generated

[jira] [Commented] (FLINK-7211) Exclude Gelly javadoc jar from release

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

[GitHub] flink issue #4352: [FLINK-7211] [build] Exclude Gelly javadoc jar from relea...

2017-07-21 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4352 +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 feature

[jira] [Updated] (FLINK-5539) CLI: run/info/list/stop/cancel

2017-07-21 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-5539: Summary: CLI: run/info/list/stop/cancel (was: CLI: info/list/stop/cancel) > CLI:

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r128798162 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/dataview/ListView.scala --- @@ -0,0 +1,99 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7234) Fix CombineHint documentation

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

[GitHub] flink issue #4372: [FLINK-7234] [docs] Fix CombineHint documentation

2017-07-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4372 I think you are right @greghogan. It's not about the ratio of #distinct keys to size of the dataset. But it's also not only the ratio of #distinct keys to size of the memory. The skew of

[jira] [Commented] (FLINK-7241) Fix YARN high availability documentation

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

[GitHub] flink pull request #4382: [FLINK-7241] Fix YARN high availability documentat...

2017-07-21 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4382 [FLINK-7241] Fix YARN high availability documentation R: @rmetzger (or anyone really) You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (FLINK-7241) Fix YARN high availability documentation

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7241: Fix Version/s: 1.3.2 > Fix YARN high availability documentation >

[jira] [Updated] (FLINK-7241) Fix YARN high availability documentation

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7241: Affects Version/s: 1.3.0 1.3.1 > Fix YARN high availability

[jira] [Created] (FLINK-7241) Fix YARN high availability documentation

2017-07-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7241: --- Summary: Fix YARN high availability documentation Key: FLINK-7241 URL: https://issues.apache.org/jira/browse/FLINK-7241 Project: Flink Issue Type: Bug

[GitHub] flink issue #4379: [FLINK-7194] [table] Add methods for type hints to UDAGG ...

2017-07-21 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4379 Loos good to me. +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

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

2017-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096385#comment-16096385 ] ASF GitHub Bot commented on FLINK-7194: --- Github user wuchong commented on the issue:

[GitHub] flink issue #4372: [FLINK-7234] [docs] Fix CombineHint documentation

2017-07-21 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4372 @StephanEwen I like the new template. I much prefer free form over checkboxes. @fhueske I'm questioning my understanding of the the heuristic for using a hash-combine. For a fixed number

[jira] [Commented] (FLINK-7234) Fix CombineHint documentation

2017-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096381#comment-16096381 ] ASF GitHub Bot commented on FLINK-7234: --- Github user greghogan commented on the issue:

[jira] [Closed] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-07-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6747. -- Resolution: Fixed Fixed in c472309c776db5f25e6a43f22598e31058d0f82d > Table API / SQL Docs: Streaming

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

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

[GitHub] flink pull request #4365: [FLINK-6747] [docs] Add documentation for dynamic ...

2017-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4365 --- 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 #4380: Time sort with offset/fetch without retraction

2017-07-21 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/4380 @fhueske ,@wuchong I updated the PR. Please have a look --- 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] [Assigned] (FLINK-6973) Add L/RPAD supported in TableAPI

2017-07-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6973: -- Assignee: sunjincheng > Add L/RPAD supported in TableAPI > >

[jira] [Assigned] (FLINK-6846) Add TIMESTAMPADD supported in TableAPI

2017-07-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6846: -- Assignee: sunjincheng > Add TIMESTAMPADD supported in TableAPI >

[GitHub] flink issue #4149: [FLINK-6923] [Kafka Connector] Expose in-processing/in-fl...

2017-07-21 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4149 @zhenzhongxu Have you looked into `KeyedDeserializationSchema`? In there you have access to the partition and the offset at which the record originated. --- If your project is set up for it, you

[jira] [Commented] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

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

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

2017-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096322#comment-16096322 ] ASF GitHub Bot commented on FLINK-7194: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4379: [FLINK-7194] [table] Add methods for type hints to UDAGG ...

2017-07-21 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4379 Hi @fhueske Thanks for the update. The PR. looks good to me. -:) + to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-7105) Make ActorSystem creation per default non-daemonic

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

[GitHub] flink issue #4259: [FLINK-7105] Make ActorSystems non daemonic

2017-07-21 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4259 Looks good, +1 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

[GitHub] flink issue #4365: [FLINK-6747] [docs] Add documentation for dynamic tables.

2017-07-21 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4365 Hi @fhueske No problem, that's my duty. :) 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

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096305#comment-16096305 ] ASF GitHub Bot commented on FLINK-6747: --- Github user sunjincheng121 commented on the issue:

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

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

[GitHub] flink pull request #4379: [FLINK-7194] [table] Add methods for type hints to...

2017-07-21 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4379#discussion_r128773463 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -314,7 +314,28 @@

[jira] [Commented] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one

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

[GitHub] flink issue #4321: [FLINK-7174] Bump Kafka 0.10 dependency to 0.10.2.1

2017-07-21 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4321 Fair enough +1 then --- 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] [Comment Edited] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-07-21 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096273#comment-16096273 ] Xingcan Cui edited comment on FLINK-6233 at 7/21/17 1:50 PM: - [~fhueske],

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-07-21 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096273#comment-16096273 ] Xingcan Cui commented on FLINK-6233: [~fhueske], according to your comment, we actually not change the

[jira] [Commented] (FLINK-7196) add a TTL to transient BLOB files

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

[GitHub] flink pull request #4381: [FLINK-7196][blob] add a TTL to all transient BLOB...

2017-07-21 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4381 [FLINK-7196][blob] add a TTL to all transient BLOBs ## What is the purpose of the change Transient BLOB files are currently only deleted manually and may thus linger around if not cleaned

[jira] [Commented] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

2017-07-21 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096249#comment-16096249 ] Sihua Zhou commented on FLINK-7153: --- [~aljoscha] I issues contains two subproblems, for the first one

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[GitHub] flink pull request #4357: (release-1.3) [FLINK-7143, FLINK-7195] Collection ...

2017-07-21 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4357#discussion_r128755399 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -517,16

[jira] [Commented] (FLINK-7143) Partition assignment for Kafka consumer is not stable

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

[GitHub] flink pull request #4357: (release-1.3) [FLINK-7143, FLINK-7195] Collection ...

2017-07-21 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4357#discussion_r128754182 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -517,16

[jira] [Commented] (FLINK-6046) Add support for oversized messages during deployment

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

[GitHub] flink pull request #3742: [FLINK-6046] Add support for oversized messages du...

2017-07-21 Thread NicoK
Github user NicoK closed the pull request at: https://github.com/apache/flink/pull/3742 --- 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 #4379: [FLINK-7194] [table] Add methods for type hints to UDAGG ...

2017-07-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4379 Thanks for the review @sunjincheng121. 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

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

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

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

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

[GitHub] flink issue #4380: Time sort with offset/fetch without retraction

2017-07-21 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/4380 @fhueske Also - i do not understand why you would need to keep the counters for offset/fetch as states? Assuming we have in the buffer state with events for proctime T values (1, 2, 3,

[GitHub] flink pull request #4379: [FLINK-7194] [table] Add methods for type hints to...

2017-07-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4379#discussion_r128745444 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -314,7 +314,28 @@ object

[GitHub] flink issue #4380: Time sort with offset/fetch without retraction

2017-07-21 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/4380 @fhueske I did not understood initially that this is your suggestion. What you propose has the advantage that it is easy to maintain (as we consolidate the whole functionality) and a slight

[jira] [Commented] (FLINK-3992) Remove Key interface

2017-07-21 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096123#comment-16096123 ] mingleizhang commented on FLINK-3992: - Could you please add more message here ? [~Zentol] Thanks. :)

[jira] [Commented] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

2017-07-21 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096120#comment-16096120 ] mingleizhang commented on FLINK-4048: - I would like work on it when 2.0.0 should comes. Now, I wont.

[jira] [Commented] (FLINK-5130) Remove Deprecated Methods from WindowedStream

2017-07-21 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096110#comment-16096110 ] mingleizhang commented on FLINK-5130: - If agree, I wont do it until 2.0.0 begin. > Remove Deprecated

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

2017-07-21 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096109#comment-16096109 ] Ufuk Celebi commented on FLINK-7067: I agree with Stephan's opinion. That's why I also have the test

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-21 Thread kaibozhou
Github user kaibozhou commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r128730577 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -357,6 +423,9 @@ class

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-07-21 Thread kaibozhou
Github user kaibozhou commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r128730510 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/dataview/ListView.scala --- @@ -0,0 +1,99 @@ +/* + * Licensed to

[GitHub] flink pull request #4379: [FLINK-7194] [table] Add methods for type hints to...

2017-07-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4379#discussion_r128728039 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/AggregateFunction.scala --- @@ -17,6 +17,8 @@ */ package

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

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

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

2017-07-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3829 Hi @lincoln-lil, that's very good input! What do you think about the following? We keep the current `TableSink` interface, but when registering a `TableSink` in a `TableEnvironment` we

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one

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

[GitHub] flink issue #4321: [FLINK-7174] Bump Kafka 0.10 dependency to 0.10.2.1

2017-07-21 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4321 Dropping this field would make it more error prone in the future if anyone would call `reassingPartitions()` from somewhere else. For me `hasAssignedPartitions` is tightly related to the state of

[jira] [Commented] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095999#comment-16095999 ] Aljoscha Krettek commented on FLINK-7153: - [~StephanEwen] & [~sihuazhou] Do you think this is

[jira] [Updated] (FLINK-7231) SlotSharingGroups are not always released in time for new restarts

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7231: Priority: Blocker (was: Major) > SlotSharingGroups are not always released in time for new

[GitHub] flink pull request #4366: [FLINK-7228] [history] Use free port in HistorySer...

2017-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4366 --- 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] [Commented] (FLINK-7228) Harden HistoryServerStaticFileHandlerTest

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

[jira] [Commented] (FLINK-4187) Support for outer joins on DataStream

2017-07-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095991#comment-16095991 ] Fabian Hueske commented on FLINK-4187: -- There are many different way in which streams can be joined.

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095990#comment-16095990 ] Aljoscha Krettek commented on FLINK-7067: - [~StephanEwen] & [~uce] Since this seems like a good

[jira] [Closed] (FLINK-7203) Remove useless "flink-avro" module

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7203. --- Resolution: Not A Problem > Remove useless "flink-avro" module >

[jira] [Reopened] (FLINK-7203) Remove useless "flink-avro" module

2017-07-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7203: - > Remove useless "flink-avro" module > -- > >

[jira] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

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

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-07-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095964#comment-16095964 ] Fabian Hueske commented on FLINK-6233: -- Just talked to [~aljoscha] about this idea. He said this

[GitHub] flink issue #4365: [FLINK-6747] [docs] Add documentation for dynamic tables.

2017-07-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4365 Great, thanks @sunjincheng121 --- 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] [Commented] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-07-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095936#comment-16095936 ] ASF GitHub Bot commented on FLINK-6747: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4365: [FLINK-6747] [docs] Add documentation for dynamic tables.

2017-07-21 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4365 I'll merge this weekend... --- 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] [Closed] (FLINK-7203) Remove useless "flink-avro" module

2017-07-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7203. --- Resolution: Fixed > Remove useless "flink-avro" module > -- > >

[GitHub] flink pull request #4371: [FLINK-7232] [docs] Update checkstyle docs regardi...

2017-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4371 --- 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] [Commented] (FLINK-7232) Update checkstyle docs regarding test inclusion

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

[jira] [Closed] (FLINK-7232) Update checkstyle docs regarding test inclusion

2017-07-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7232. --- Resolution: Fixed 1.4: e4e2327e9501b28336478874d698346c09588326 > Update checkstyle docs

[jira] [Closed] (FLINK-7176) Failed builds (due to compilation) don't upload logs

2017-07-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7176. --- Resolution: Fixed 1.3: 20ddb46b7944162c9cb1cfbd7d1658a6a88246fe > Failed builds (due to

[jira] [Commented] (FLINK-7176) Failed builds (due to compilation) don't upload logs

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

[GitHub] flink pull request #4329: [FLINK-7176] [travis] Improve error handling

2017-07-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4329 --- 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] [Commented] (FLINK-7198) Metric Reporters report incorrect host for JobManager

2017-07-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095837#comment-16095837 ] Bowen Li commented on FLINK-7198: - Sounds good to me. We can change title of this ticket to match what we