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

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

[jira] [Commented] (FLINK-7175) Add simple benchmark suite for Flink

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

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

2017-07-13 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4321 Good catch with with this spinning, I missed that. Checking per each iteration for assigned partitions is unfortunately costly, because there is no cheap `isEmpty()` method. The one that I

[GitHub] flink issue #4309: [FLINK-7166][avro] cleanup generated test classes in the ...

2017-07-13 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4309 I ran into this too. Thanks for the PR! Shall we also create a ticket to move generated files out of `src`? --- If your project is set up for it, you can reply to this email and have your

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

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086108#comment-16086108 ] Chesnay Schepler commented on FLINK-7176: - This is mostly an issue for 1.3, where the compilation

[GitHub] flink issue #4266: [FLINK-6232][Table] support proctime inner windowed s...

2017-07-13 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4266 Hi @hongyuhong and @wuchong, I opened a new PR which extends this PR. Please have a look and give feedback. @hongyuhong can you close the PRs #3715 and this one? Thank you,

[GitHub] flink issue #4323: [FLINK-7175] Add first simplest Flink benchmark

2017-07-13 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4323 JMH's GPLv2 license is not compatible with the ASL (see 2063fa12)? This would need to be a separate repo distinct from the Apache Flink project and licensed under the GPL. --- If your project is

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

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

[GitHub] flink pull request #4324: [FLINK-6232] [table] Add processing time window in...

2017-07-13 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4324 [FLINK-6232] [table] Add processing time window inner join to SQL. This is continuation and extension of PR #3715 and #4266 by @hongyuhong. You can merge this pull request into a Git repository by

[jira] [Commented] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

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

[jira] [Commented] (FLINK-7175) Add simple benchmark suite for Flink

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

[GitHub] flink issue #4323: [FLINK-7175] Add first simplest Flink benchmark

2017-07-13 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4323 Thanks for pointing this out. Indeed we will probably have to move it to separate project in that case. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request #3943: [FLINK-6617][table] Improve JAVA and SCALA logical...

2017-07-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3943 --- 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-6617) Improve JAVA and SCALA logical plans consistent test

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

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

2017-07-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4321 I think this pull request will make the Kafka consumer go into a hot busy waiting loop when it has no partitions assigned. I would suggest to do a blocking `take()` or so on the

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

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7176: Affects Version/s: (was: 1.3.2) 1.3.0 > Failed builds (due to

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

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

[GitHub] flink issue #4323: [FLINK-7175] Add first simplest Flink benchmark

2017-07-13 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4323 Another idea: a separate repo but never released since this looks to be for observation by developers rather than the community at large (results could be summarized in the documentation). ---

[jira] [Commented] (FLINK-7175) Add simple benchmark suite for Flink

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

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

2017-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085926#comment-16085926 ] Stephan Ewen commented on FLINK-7153: - I am happy to look at your suggested fix... > Eager Scheduling

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

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7176: Affects Version/s: 1.3.2 > Failed builds (due to compilation) don't upload logs >

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

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7176: Fix Version/s: 1.3.2 > Failed builds (due to compilation) don't upload logs >

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

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7176: Fix Version/s: (was: 1.3.2) 1.3.0 > Failed builds (due to

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

2017-07-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086104#comment-16086104 ] 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-13 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4321 Hmm, will blocking operation be appropriate here? This would prevent `shutdown()` from actually breaking the loop. I think we would need some timeout here? --- If your project is set up for it,

[jira] [Commented] (FLINK-6975) Add CONCAT/CONCAT_WS supported in TableAPI

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

[jira] [Closed] (FLINK-7173) Fix the illustration of tumbling window.

2017-07-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7173. --- Resolution: Fixed Fix Version/s: 1.4.0 Fixed in

[jira] [Commented] (FLINK-7173) Fix the illustration of tumbling window.

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

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

2017-07-13 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085706#comment-16085706 ] Sihua Zhou commented on FLINK-7153: --- [~StephanEwen] Thanks for you reply, can i contribute to this

[GitHub] flink issue #4274: [FLINK-6975][table]Add CONCAT/CONCAT_WS supported in Tabl...

2017-07-13 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4274 @wuchong Thanks for your reviewing. I have update the PR according your comments. Thanks, Jincheng --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink issue #4322: [FLINK-7173][doc]Change the illustration of tumbling wind...

2017-07-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4322 @sunjincheng121 Thanks a lot! I merged, could you please close this 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

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

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

[jira] [Commented] (FLINK-7173) Fix the illustration of tumbling window.

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

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

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

[jira] [Created] (FLINK-7175) Add simple benchmark suite for Flink

2017-07-13 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-7175: - Summary: Add simple benchmark suite for Flink Key: FLINK-7175 URL: https://issues.apache.org/jira/browse/FLINK-7175 Project: Flink Issue Type: Improvement

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

2017-07-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7176: --- Summary: Failed builds (due to compilation) don't upload logs Key: FLINK-7176 URL: https://issues.apache.org/jira/browse/FLINK-7176 Project: Flink

[GitHub] flink issue #4322: [FLINK-7173][doc]Change the illustration of tumbling wind...

2017-07-13 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4322 Yes @aljoscha I agree with you. I have updated the PR. -:) Thanks, Jincheng --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

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

2017-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7153: Priority: Blocker (was: Major) > Eager Scheduling can't allocate source for ExecutionGraph

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

2017-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7153: Fix Version/s: 1.3.2 > Eager Scheduling can't allocate source for ExecutionGraph correctly >

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

2017-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-7153: --- Assignee: Stephan Ewen > Eager Scheduling can't allocate source for ExecutionGraph correctly

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

2017-07-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085699#comment-16085699 ] Stephan Ewen commented on FLINK-7153: - Confirmed this bug. Will look into it and see that we provide a

[GitHub] flink issue #4192: [FLINK-6964] [checkpoint] Fix externalized incremental ch...

2017-07-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4192 This looks super nice now! I tried it and disabled each of the two fixes (registering shared state after restore and backend UUIDs) and reverting either made the new integration test fail.

[jira] [Commented] (FLINK-7175) Add simple benchmark suite for Flink

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

[GitHub] flink pull request #4323: [FLINK-7175] Add first simplest Flink benchmark

2017-07-13 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4323 [FLINK-7175] Add first simplest Flink benchmark Example output: ``` Benchmark (objectReuse) (parallelism) (stateBackend) Mode Cnt Score Error

[jira] [Updated] (FLINK-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation

2017-07-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7177: - Component/s: Table API & SQL > [table] Using Table API to perform aggregation on another Table API / SQL

[jira] [Created] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7178: - Summary: Datadog Metric Reporter Jar is Lacking Dependencies Key: FLINK-7178 URL: https://issues.apache.org/jira/browse/FLINK-7178 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation

2017-07-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7177: - Description: For example:

[jira] [Updated] (FLINK-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation

2017-07-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7177: - Affects Version/s: 1.3.1 > [table] Using Table API to perform aggregation on another Table API / SQL >

[jira] [Updated] (FLINK-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation

2017-07-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7177: - Description: For example:

[jira] [Created] (FLINK-7179) Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

2017-07-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7179: Summary: Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor Key: FLINK-7179 URL:

[jira] [Updated] (FLINK-7179) ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

2017-07-13 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-7179: - Summary: ProjectableTableSource interface doesn't compatible with

[jira] [Commented] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086330#comment-16086330 ] Chesnay Schepler commented on FLINK-7178: - The maven-shade plugin was not configured correctly and

[jira] [Commented] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

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

[GitHub] flink pull request #4326: [FLINK-7178] [metrics] Do not create separate shad...

2017-07-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4326 [FLINK-7178] [metrics] Do not create separate shaded jars You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 7178 Alternatively you

[jira] [Commented] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086321#comment-16086321 ] Chesnay Schepler commented on FLINK-7178: - [~aljoscha] We got a another blocker here. > Datadog

[jira] [Updated] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7178: Affects Version/s: 1.4.0 > Datadog Metric Reporter Jar is Lacking Dependencies >

[jira] [Updated] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7178: Fix Version/s: 1.3.2 1.4.0 > Datadog Metric Reporter Jar is Lacking

[jira] [Updated] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7178: Priority: Blocker (was: Major) > Datadog Metric Reporter Jar is Lacking Dependencies >

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

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

[jira] [Created] (FLINK-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation

2017-07-13 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7177: Summary: [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation Key: FLINK-7177 URL:

[GitHub] flink issue #4150: [FLINK-6951] Incompatible versions of httpcomponents jars...

2017-07-13 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4150 During testing, I saw the following exception: ```java java.lang.IllegalStateException: Socket not created by this factory at

[jira] [Assigned] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7178: --- Assignee: Chesnay Schepler > Datadog Metric Reporter Jar is Lacking Dependencies >

[GitHub] flink pull request #4327: [FLINK-7178] [metrics] Do not create separate shad...

2017-07-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4327 [FLINK-7178] [metrics] Do not create separate shaded jars Backport of #4326 for 1.3. You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink

[jira] [Commented] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

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

[jira] [Closed] (FLINK-7154) Missing call to build CsvTableSource example

2017-07-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7154. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for 1.3.2 with

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

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

[jira] [Commented] (FLINK-7154) Missing call to build CsvTableSource example

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

[GitHub] flink pull request #4303: fix doc typo in DataStreamRel

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

[GitHub] flink pull request #4313: [FLINK-7154] [docs] Missing call to build CsvTable...

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

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-07-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4078 --- 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-6693) Support DATE_FORMAT function in the Table / SQL API

2017-07-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6693. Resolution: Implemented Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[GitHub] flink pull request #4325: [hotfix] [hadoopCompat] Fix tests to verify result...

2017-07-13 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4325 [hotfix] [hadoopCompat] Fix tests to verify results new Hadoop input API. The tests of the reworked Hadoop input API (reworked to remove the Hadoop dependency on `flink-java`) did not validate

[GitHub] flink issue #4315: [FLINK-5541] Missing null check for localJar in FlinkSubm...

2017-07-13 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4315 lgtm --- 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] [Commented] (FLINK-7166) generated avro sources not cleaned up or re-created after changes

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

[jira] [Commented] (FLINK-6975) Add CONCAT/CONCAT_WS supported in TableAPI

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

[GitHub] flink pull request #4274: [FLINK-6975][table]Add CONCAT/CONCAT_WS supported ...

2017-07-13 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4274#discussion_r127382075 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/stringExpressions.scala --- @@ -277,3 +278,47 @@ case class

[jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

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

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

2017-07-13 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4328 [FLINK-6493] Fix ineffective null check in RegisteredOperatorBackendS… This PR is simlar to https://github.com/apache/flink/pull/1871/files. @tedyu What do you think of this Change ? You

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

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

[GitHub] flink pull request #4322: [FLINK-7173][doc]Change the illustration of tumbli...

2017-07-13 Thread sunjincheng121
Github user sunjincheng121 closed the pull request at: https://github.com/apache/flink/pull/4322 --- 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-7173) Fix the illustration of tumbling window.

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

[jira] [Commented] (FLINK-7173) Fix the illustration of tumbling window.

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

[GitHub] flink issue #4322: [FLINK-7173][doc]Change the illustration of tumbling wind...

2017-07-13 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4322 Sure! :) --- 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

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

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

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

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

[GitHub] flink pull request #4266: [FLINK-6232][Table] support proctime inner win...

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

[GitHub] flink pull request #3715: [FLINK-6232][Table]Support proctime inner equi...

2017-07-13 Thread hongyuhong
Github user hongyuhong closed the pull request at: https://github.com/apache/flink/pull/3715 --- 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 #4187: [FLINK-6998][Kafka Connector] Add kafka offset commit met...

2017-07-13 Thread zhenzhongxu
Github user zhenzhongxu commented on the issue: https://github.com/apache/flink/pull/4187 @tzulitai seems the last CI pipeline failed because of stability issues, how can I trigger another build without making a commit? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-07-13 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085290#comment-16085290 ] Jark Wu commented on FLINK-7169: Thanks for your contribution. I moved this issue under FLINK-6935. >

[jira] [Updated] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

2017-07-13 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-7169: --- Issue Type: Sub-task (was: Task) Parent: FLINK-6935 > Support AFTER MATCH SKIP function in CEP

[jira] [Updated] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-07-13 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6951: Fix Version/s: 1.3.2 > Incompatible versions of httpcomponents jars for Flink kinesis connector >

[jira] [Comment Edited] (FLINK-7165) Flink can't deploy on hadoop 2.6.0-cdh5.5.1 yarn

2017-07-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16084246#comment-16084246 ] 刘喆 edited comment on FLINK-7165 at 7/13/17 7:41 AM: I have tried the following

[jira] [Comment Edited] (FLINK-7165) Flink can't deploy on hadoop 2.6.0-cdh5.5.1 yarn

2017-07-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16084246#comment-16084246 ] 刘喆 edited comment on FLINK-7165 at 7/13/17 7:41 AM: I have tried the following

[GitHub] flink issue #3943: [FLINK-6617][table] Improve JAVA and SCALA logical plans ...

2017-07-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3943 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-6617) Improve JAVA and SCALA logical plans consistent test

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

[jira] [Assigned] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

2017-07-13 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-5541: --- Assignee: mingleizhang > Missing null check for localJar in FlinkSubmitter#submitTopology()

[jira] [Closed] (FLINK-7126) Support Distinct for Stream SQL and Table API

2017-07-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-7126. -- Resolution: Fixed Fixed in c8ca31aba083304117ed527c5c80cb9ede2b81bd > Support Distinct for Stream SQL

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

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

[GitHub] flink pull request #4150: [FLINK-6951] Incompatible versions of httpcomponen...

2017-07-13 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4150#discussion_r127138994 --- Diff: flink-connectors/flink-connector-kinesis/pom.xml --- @@ -56,6 +58,18 @@ under the License. +

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

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

  1   2   3   >