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

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

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

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

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

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

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

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

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

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

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

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4256#discussion_r125539485 --- Diff: docs/dev/table/streaming.md --- @@ -351,13 +351,109 @@ val windowedTable = tEnv Query Configuration ---

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

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4256#discussion_r125540625 --- Diff: docs/dev/table/streaming.md --- @@ -351,13 +351,109 @@ val windowedTable = tEnv Query Configuration ---

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

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4256#discussion_r125553376 --- Diff: docs/dev/table/streaming.md --- @@ -351,13 +351,109 @@ val windowedTable = tEnv Query Configuration ---

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

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4256#discussion_r125538537 --- Diff: docs/dev/table/streaming.md --- @@ -351,13 +351,109 @@ val windowedTable = tEnv Query Configuration ---

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

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4256#discussion_r125539538 --- Diff: docs/dev/table/streaming.md --- @@ -351,13 +351,109 @@ val windowedTable = tEnv Query Configuration ---

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

2017-07-04 Thread Luke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074221#comment-16074221 ] Luke edited comment on FLINK-6988 at 7/5/17 4:31 AM: - Is there plan for flink producer

[jira] [Commented] (FLINK-6499) Migrate state configuration options

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

[GitHub] flink issue #4173: [FLINK-6499] Migrate state configuration options

2017-07-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4173 Thanks for the contribution @zjureel. LGTM, merging this .. --- 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-6988) Add Apache Kafka 0.11 connector

2017-07-04 Thread Luke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074221#comment-16074221 ] Luke commented on FLINK-6988: - Is there plan for flink producer connector to support multiple topics in one

[jira] [Updated] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7104: Description: Actually, the dir of {{junit2471804890898765737}} had already not existed anymore.

[jira] [Updated] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7104: Description: Actually, the dir of {{junit7630178798271244089}} had already not existed anymore.

[jira] [Updated] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7104: Component/s: Build System > AccessDeniedException get when

[jira] [Updated] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7104: Description: java.nio.file.AccessDeniedException:

[jira] [Created] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call

2017-07-04 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7104: --- Summary: AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call Key: FLINK-7104 URL: https://issues.apache.org/jira/browse/FLINK-7104

[jira] [Commented] (FLINK-6969) Add support for deferred computation for group window aggregates

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

[GitHub] flink issue #4183: [FLINK-6969][table]Add support for deferred computation f...

2017-07-04 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4183 The proposal makes sense to me. BTW, the concepts of `earlyResultTimeOffset` and `updateRate` also works on window group aggregates, right? --- If your project is set up for it, you can

[jira] [Commented] (FLINK-6958) Async I/O timeout not work

2017-07-04 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16074164#comment-16074164 ] Jark Wu commented on FLINK-6958: I agree with you. In case of regular shutdown, we should wait all

[jira] [Updated] (FLINK-6407) Upgrade AVRO dependency version to 1.8.x

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6407: Fix Version/s: 1.4.0 > Upgrade AVRO dependency version to 1.8.x >

[jira] [Updated] (FLINK-6934) Consider moving LRUCache class

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6934: Fix Version/s: 1.3.2 > Consider moving LRUCache class > -- > >

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

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

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

2017-07-04 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4256 [FLINK-6747] [docs] Add documentation for QueryConfig. Needs to be merge to `master` and `release-1.3`. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822346#comment-15822346 ] Ted Yu edited comment on FLINK-5486 at 7/4/17 9:03 PM: --- Lock on State.bucketStates

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

2017-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for

[jira] [Updated] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2017-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6105: -- Description: When catching InterruptedException, we should throw InterruptedIOException instead of

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

2017-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5541: -- Description: {code} if (localJar == null) { try { for (final URL url :

[jira] [Comment Edited] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer

2017-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991975#comment-15991975 ] Ted Yu edited comment on FLINK-6359 at 7/4/17 9:01 PM: --- Interesting observations,

[jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch

2017-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6838: -- Description: {code} Tests in error: RescalingITCase.testSavepointRescalingInKeyedState[1] ยป JobExecution Job

[jira] [Closed] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

2017-07-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4286. --- Resolution: Won't Fix > Have Kafka examples that use the Kafka 0.9 connector >

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

[GitHub] flink issue #4221: [FLINK-7037] Remove scala suffic from flink-examples modu...

2017-07-04 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4221 Thanks! That makes sense. --- 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-7047) Reorganize build profiles

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

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 `mvn verify` now works as it should, execution tests and stuff. --- 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] [Comment Edited] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

2017-07-04 Thread Dmitrii Kniazev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073961#comment-16073961 ] Dmitrii Kniazev edited comment on FLINK-4286 at 7/4/17 8:04 PM: Cool. I

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 @rmetzger I can fix the issue with verify by reverting the profile logic. Instead of activating the surefire plugin in each module, the plugin is enabled by default in the root pom but disabled in

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

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

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

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

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 @rmetzger Now i understand why the tests aren't run. I thought that I was activating the profiles with the properties in the root pom.xml, but this isn't the case. I was just setting the system

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

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

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 WIth the existing surefire configuration we also cannot do this in 2 steps, one for compilation and one for tests. It is not possible to only run tests with any maven invocation that includes a

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

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

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 another more sane option would be to add a new module for each group that has a dependency for each module we want tested. THEN we could use the `-am` option. --- If your project is set up for it,

[jira] [Commented] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

2017-07-04 Thread Dmitrii Kniazev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073961#comment-16073961 ] Dmitrii Kniazev commented on FLINK-4286: Cool. In this case we can close this issue with 'won't

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

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

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 corrected my previous comment regarding the problems of `-am` and `-amd`. --- 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-4286) Have Kafka examples that use the Kafka 0.9 connector

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

[GitHub] flink issue #4250: [FLINK-4286] Have Kafka examples that use the Kafka 0.9 c...

2017-07-04 Thread mylog00
Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/4250 wouldn't to fix --- 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-4286) Have Kafka examples that use the Kafka 0.9 connector

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

[GitHub] flink pull request #4250: [FLINK-4286] Have Kafka examples that use the Kafk...

2017-07-04 Thread mylog00
Github user mylog00 closed the pull request at: https://github.com/apache/flink/pull/4250 --- 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-7047) Reorganize build profiles

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

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

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4233 `mvn verify` _should_ run all tests since the default for all added properties is true. But yes, it currently doesn't. I don't quite understand this as the default for all groups is true (i.e. all

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

[GitHub] flink issue #4221: [FLINK-7037] Remove scala suffic from flink-examples modu...

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4221 @aljoscha Because it is the only parent module that has a scala suffix. All other modules with a scala suffix don't have children. --- If your project is set up for it, you can reply to this email

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

2017-07-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6008. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 28c3354e735e98657d8d90912234cf8e896e78d6

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

2017-07-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6043. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 0f91083b2b497485b4375935ed7397583a03ca7c

[jira] [Closed] (FLINK-7037) Remove scala suffix from flink-examples module

2017-07-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7037. --- Resolution: Fixed 1.4: bd858845a4ade89f78c06f72444563adfa5a974b > Remove scala suffix from

[jira] [Closed] (FLINK-6823) Activate checkstyle for runtime/broadcast

2017-07-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6823. --- Resolution: Fixed 1.4: 4d18afed80774c57766752f8a3cc45133a4a457a > Activate checkstyle for

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

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

[jira] [Commented] (FLINK-6823) Activate checkstyle for runtime/broadcast

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

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

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

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

[GitHub] flink pull request #4146: [FLINK-6008][blob] collection of BlobServer improv...

2017-07-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4146 --- 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 #4068: [FLINK-6823] Activate checkstyle for runtime/broad...

2017-07-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4068 --- 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 #4221: [FLINK-7037] Remove scala suffic from flink-exampl...

2017-07-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4221 --- 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 #3583: [FLINK-6043] [web] Display exception timestamp

2017-07-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3583 --- 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-6925) Add CONCAT/CONCAT_WS supported in SQL

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

[GitHub] flink issue #4138: [FLINK-6925][table]Add CONCAT/CONCAT_WS supported in SQL

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4138 Thanks @wuchong ! From my point of view +1 to merge. @twalthr do you have any other comments? :) --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125504798 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[jira] [Updated] (FLINK-7103) Implement skeletal structure of dispatcher component

2017-07-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7103: - Summary: Implement skeletal structure of dispatcher component (was: Implement dispatcher

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125504087 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[jira] [Created] (FLINK-7103) Implement dispatcher component

2017-07-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7103: Summary: Implement dispatcher component Key: FLINK-7103 URL: https://issues.apache.org/jira/browse/FLINK-7103 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #4252: [FLINK-7074] [tm] Add entry point for the TaskMana...

2017-07-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4252#discussion_r125503520 --- Diff: flink-runtime/pom.xml --- @@ -117,6 +117,16 @@ under the License. + org.slf4j

[jira] [Commented] (FLINK-7074) Add entry point for TaskManagerRunner

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

[jira] [Commented] (FLINK-7102) improve ClassLoaderITCase

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

[GitHub] flink pull request #4255: [FLINK-7102] improve ClassLoaderITCase

2017-07-04 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4255 [FLINK-7102] improve ClassLoaderITCase * ClassLoaderITCase unnecessarily runs multiple tests in a single test case * ClassLoaderITCase#testDisposeSavepointWithCustomKvState() does not cancel its

[jira] [Commented] (FLINK-7097) Start TaskExecutor via start-up script

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

[GitHub] flink pull request #4253: [FLINK-7097] [scripts] Enable Flip-6 TaskExecutor ...

2017-07-04 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4253#discussion_r125502076 --- Diff: flink-dist/src/main/flink-bin/bin/taskmanager.sh --- @@ -73,11 +78,11 @@ if [[ $STARTSTOP == "start" ]] || [[ $STARTSTOP ==

[jira] [Commented] (FLINK-7037) Remove scala suffix from flink-examples module

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125501792 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink issue #4221: [FLINK-7037] Remove scala suffic from flink-examples modu...

2017-07-04 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4221 @zentol why was this only a problem for the example module? --- 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] [Created] (FLINK-7102) improve ClassLoaderITCase

2017-07-04 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7102: -- Summary: improve ClassLoaderITCase Key: FLINK-7102 URL: https://issues.apache.org/jira/browse/FLINK-7102 Project: Flink Issue Type: Bug Components:

[jira] [Assigned] (FLINK-7082) Flip-6: Generic entry point for Flink sessions

2017-07-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7082: Assignee: Till Rohrmann > Flip-6: Generic entry point for Flink sessions >

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

2017-07-04 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4233 @aljoscha this may be caused by publishing pom's with unresolved `${scala.binary.version}`. I am planning to file a ticket after #4221 is merged. The StackOverflow link looks promising. --- If

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

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

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125500774 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig

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

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

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

2017-07-04 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4233 There's also this interesting approach which limits changes to the root POM: https://stackoverflow.com/a/39562385/4770039 --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125498157 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

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

2017-07-04 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4233 I think we should be able to do this as a two-step process without changing the poms: ``` mvn install -pl flink-tests,flink-foo-bar -am -DskipTests -Dmaven.javadoc.skip=true mvn

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

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

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125495801 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

  1   2   3   4   >