[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-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

[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-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

[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 #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-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 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] [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

[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] [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:

[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] [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

[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] [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:

[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

[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] [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] [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] [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 >

[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] [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: - Component/s: Table API & SQL > [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] [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-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:

[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

[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-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:

[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-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

[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:

[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

[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-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 #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

[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 #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] [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] [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: 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: (was: 1.3.2) 1.3.0 > Failed builds (due to

[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

[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:

[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 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-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:

[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] [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:

[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] [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] [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

[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:

[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-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:

[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

[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] [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:

[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-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 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-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

[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] [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] [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] [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 #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] [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-7169) Support AFTER MATCH SKIP function in CEP library API

2017-07-13 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085643#comment-16085643 ] Dawid Wysakowicz commented on FLINK-7169: - I had not enough time to think of all cases ,but also

[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=16085642#comment-16085642 ] ASF GitHub Bot commented on FLINK-7173: --- Github user aljoscha commented on the issue:

[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 While on this, I think it would also make sense to fix the picture for sliding windows, what do you think? --- If your project is set up for it, you can reply to this email and have your reply

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

2017-07-13 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085637#comment-16085637 ] Dian Fu commented on FLINK-7169: Hi [~ychen], Thanks a lot working on this ticket. :) For the API change,

[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=16085623#comment-16085623 ] ASF GitHub Bot commented on FLINK-6964: --- Github user StefanRRichter commented on the issue:

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

2017-07-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4192 @aljoscha @StephanEwen I have added an IT case for this problem. It is testing a sequence externalized checkpoint recoveries, using full and incremental checkpoints on standalone and

[jira] [Resolved] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

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

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

2017-07-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085615#comment-16085615 ] Fabian Hueske commented on FLINK-7153: -- Hi [~sihuazhou], thanks for reporting this 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=16085609#comment-16085609 ] ASF GitHub Bot commented on FLINK-7173: --- GitHub user sunjincheng121 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 opened a pull request: https://github.com/apache/flink/pull/4322 [FLINK-7173][doc]Change the illustration of tumbling window. Change the illustration of tumbling window. - [ ] General - The pull request references the related JIRA issue

[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=16085608#comment-16085608 ] ASF GitHub Bot commented on FLINK-7174: --- GitHub user pnowojski opened a pull request:

[GitHub] flink pull request #4321: [FLINK-7174] Bump Kafka 0.10 dependency to 0.10.2....

2017-07-13 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4321 [FLINK-7174] Bump Kafka 0.10 dependency to 0.10.2.1 This patch fixes also an incompatibility with the latest Kafka 0.10.x and 0.11.x kafka-clients. You can merge this pull request into a Git

  1   2   3   >