[jira] [Commented] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

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

[GitHub] flink issue #4391: [FLINK-7258] [network] Fix watermark configuration order

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4391 +1. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

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

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[jira] [Commented] (FLINK-7255) ListStateDescriptor example uses wrong constructor

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

[GitHub] flink issue #4389: [FLINK-7255] [docs] Remove default value from ListStateDe...

2017-07-24 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4389 Nice catch! +1, 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

[jira] [Commented] (FLINK-7256) End-to-end tests should only be run after successful compilation

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

[GitHub] flink issue #4390: [FLINK-7256] [travis] Only run end-to-end tests if no pre...

2017-07-24 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4390 +1, 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 f

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

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

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

2017-07-24 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4150 From the looks of https://github.com/druid-io/druid/issues/4456, could it be that we need to update our AWS Java SDK version? --- If your project is set up for it, you can reply to this email and

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

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

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

2017-07-24 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4150 @bowenli86 but isn't the shading of httpcomponents in the Kinesis consumer supposed to avoid conflicts with whatever version you're using for S3AFileSystem? --- If your project is set up for it, y

[jira] [Commented] (FLINK-6940) Clarify the effect of configuring per-job state backend

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

[GitHub] flink issue #4136: [FLINK-6940][docs] Clarify the effect of configuring per-...

2017-07-24 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4136 @zentol @alpinegizmo Guys, please let me know your thoughts :) --- 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-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

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

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

2017-07-24 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4150 My Flink job checkpoints to S3, I'm configuring S3AFileSystem shown in https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/aws.html#flink-for-hadoop-27. I doubt if this error

[jira] [Commented] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

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

[GitHub] flink issue #4391: [FLINK-7258] [network] Fix watermark configuration order

2017-07-24 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4391 @uce , really good to see this fix. I remembered meeting this problem in our production before and changed the sequence then. --- If your project is set up for it, you can reply to this email and

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

2017-07-24 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-5486: Fix Version/s: 1.3.3 1.3.2 > Lack of synchronization in BucketingSink#handleResto

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

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

[GitHub] flink issue #4356: [FLINK-5486] Fix lacking of synchronization in BucketingS...

2017-07-24 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4356 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-7245) Enhance the operators to support holding back watermarks

2017-07-24 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099299#comment-16099299 ] Xingcan Cui commented on FLINK-7245: Sure. I'll draw up a design document for that, as

[jira] [Commented] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

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

[GitHub] flink pull request #4391: [FLINK-7258] [network] Fix watermark configuration...

2017-07-24 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/4391 [FLINK-7258] [network] Fix watermark configuration order ## Purpose This PR changes the order in which low and high watermarks are configured for Netty server child connections (high first). That wa

[GitHub] flink issue #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

2017-07-24 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/4368 @pnowojski looks great. You mentioned the Pravaga connector as a motivation, did you look at its implementation and do you anticipate any challenges in porting it o this new framework?

[jira] [Updated] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7258: --- Priority: Minor (was: Major) > IllegalArgumentException in Netty bootstrap with large memory state se

[jira] [Updated] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7258: --- Description: In NettyBootstrap we configure the low and high watermarks in the following order: {code

[jira] [Created] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7258: -- Summary: IllegalArgumentException in Netty bootstrap with large memory state segment size Key: FLINK-7258 URL: https://issues.apache.org/jira/browse/FLINK-7258 Project: F

[GitHub] flink issue #4384: [FLINK-7202] Split supressions for flink-core, flink-java...

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4384 Looks good to me, +1 once travis gives green light. --- 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 f

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[GitHub] flink issue #4383: [hotfix] [optimizer] Normalize job plan operator formatti...

2017-07-24 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4383 @zentol I'd estimate that to be a similar change. --- 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

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098464#comment-16098464 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129044374 --- Diff: tools/maven/suppressions-optimizer.xml --- @@ -56,4 +56,32 @@ under the License. + + + + + + +

[jira] [Created] (FLINK-7257) Extend flink-runtime checkstyle coverage to tests

2017-07-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7257: --- Summary: Extend flink-runtime checkstyle coverage to tests Key: FLINK-7257 URL: https://issues.apache.org/jira/browse/FLINK-7257 Project: Flink Issue T

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098452#comment-16098452 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129042176 --- Diff: tools/maven/suppressions-optimizer.xml --- @@ -56,4 +56,32 @@ under the License. + + + + + + +

[jira] [Commented] (FLINK-7249) Bump Java version in build plugin

2017-07-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098425#comment-16098425 ] Stephan Ewen commented on FLINK-7249: - I think so, yes. It should be referenced in a f

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129036125 --- Diff: tools/maven/suppressions-optimizer.xml --- @@ -56,4 +56,32 @@ under the License. + + + + + + +

[GitHub] flink issue #4383: [hotfix] [optimizer] Normalize job plan operator formatti...

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4383 Just to mention the idea, would removing the space introduce more changes? --- 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 proje

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098405#comment-16098405 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129034227 --- Diff: tools/maven/suppressions-optimizer.xml --- @@ -56,4 +56,32 @@ under the License. + + + + + + +

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

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

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

2017-07-24 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4352 @aljoscha done. Thanks for the merge and managing the release! --- 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 n

[jira] [Commented] (FLINK-7247) Replace travis java 7 profiles

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

[GitHub] flink issue #4388: [FLINK-7247] [travis] Replace java 7 build profiles

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4388 ah yeah, nice catch. I will move the modified profiles to openjdk8. --- 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 doe

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

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098398#comment-16098398 ] ASF GitHub Bot commented on FLINK-7211: --- Github user greghogan closed the pull reque

[GitHub] flink pull request #4352: [FLINK-7211] [build] Exclude Gelly javadoc jar fro...

2017-07-24 Thread greghogan
Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/4352 --- 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 e

[jira] [Commented] (FLINK-7247) Replace travis java 7 profiles

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

[GitHub] flink issue #4388: [FLINK-7247] [travis] Replace java 7 build profiles

2017-07-24 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4388 Since we're running `trusty` it looks like we also have `openjdk8` available instead of using `oraclejdk8` for all tests. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-7256) End-to-end tests should only be run after successful compilation

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

[GitHub] flink pull request #4390: [FLINK-7256] [travis] Only run end-to-end tests if...

2017-07-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4390 [FLINK-7256] [travis] Only run end-to-end tests if no previous error … With this PR the execution of the end-to-end tests is skipped. Compilation failures in particular always lead to these

[jira] [Created] (FLINK-7256) End-to-end tests should only be run after successful compilation

2017-07-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7256: --- Summary: End-to-end tests should only be run after successful compilation Key: FLINK-7256 URL: https://issues.apache.org/jira/browse/FLINK-7256 Project: Flink

[jira] [Commented] (FLINK-7255) ListStateDescriptor example uses wrong constructor

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

[GitHub] flink pull request #4389: [FLINK-7255] [docs] Remove default value from List...

2017-07-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4389 [FLINK-7255] [docs] Remove default value from ListStateDescriptor con… This PR corrects the docs regarding the ListStateDescriptor; it no longer passes a default value to the constructor.

[jira] [Created] (FLINK-7255) ListStateDescriptor example uses wrong constructor

2017-07-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7255: --- Summary: ListStateDescriptor example uses wrong constructor Key: FLINK-7255 URL: https://issues.apache.org/jira/browse/FLINK-7255 Project: Flink Issue

[GitHub] flink issue #4369: [Flink-7218] [JobManager] ExecutionVertex.getPreferredLoc...

2017-07-24 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4369 Hi @summerleafs! I think we cannot use this approach to fix this. The most important thing is that this introduces a blocking operation (`.get()` on the future) in the call, which will m

[jira] [Commented] (FLINK-7187) Activate checkstyle flink-java/sca

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

[jira] [Commented] (FLINK-7181) Activate checkstyle flink-java/operators/*

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

[GitHub] flink issue #4337: [FLINK-7187] Activate checkstyle flink-java/sca

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4337 +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #4342: [FLINK-7181] Activate checkstyle flink-java/operators/*

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4342 +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Resolved] (FLINK-7177) DataSetAggregateWithNullValuesRule fails creating null literal for non-nullable type

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

[jira] [Resolved] (FLINK-7137) Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable

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

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSysten

2017-07-24 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098292#comment-16098292 ] mingleizhang commented on FLINK-5789: - I would suggest we should have a more detailed

[jira] [Commented] (FLINK-7213) Introduce state management by OperatorID in TaskManager

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098285#comment-16098285 ] ASF GitHub Bot commented on FLINK-7213: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-7213) Introduce state management by OperatorID in TaskManager

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098286#comment-16098286 ] ASF GitHub Bot commented on FLINK-7213: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-7213) Introduce state management by OperatorID in TaskManager

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098284#comment-16098284 ] ASF GitHub Bot commented on FLINK-7213: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4353: [FLINK-7213] Introduce state management by Operato...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4353#discussion_r129019373 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBAsyncSnapshotTest.java --- @@ -164,8 +168,16

[GitHub] flink pull request #4353: [FLINK-7213] Introduce state management by Operato...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4353#discussion_r129020085 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java --- @@ -164,6 +269,7 @@ public long getStateSize() {

[GitHub] flink pull request #4353: [FLINK-7213] Introduce state management by Operato...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4353#discussion_r129020863 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java --- @@ -18,20 +18,40 @@ package org.apache.fli

[jira] [Closed] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

2017-07-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3704. --- Resolution: Not A Problem Seems to have been fixed as a byproduct of other fixes. > JobManage

[jira] [Updated] (FLINK-7246) Big latency shown on operator.latency

2017-07-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7246: Component/s: (was: Core) Metrics DataStream API > Big

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

2017-07-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098273#comment-16098273 ] Aljoscha Krettek commented on FLINK-7245: - This is an interesting new feature and

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[GitHub] flink issue #4384: [FLINK-7202] Split supressions for flink-core, flink-java...

2017-07-24 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4384 Yes, unfortunately in the poms for those modules, the checkstyle was disabled for test sources. That is why I forgot about tests. I enabled them and will prepared fixed version of suppression files.

[GitHub] flink issue #4384: [FLINK-7202] Split supressions for flink-core, flink-java...

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4384 hmm...but the build is still passing... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabl

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[jira] [Commented] (FLINK-7137) Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable

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

[GitHub] flink pull request #4314: [FLINK-7137] [table] Flink TableAPI supports neste...

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

[jira] [Created] (FLINK-7254) java8 module pom disables checkstyle

2017-07-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7254: --- Summary: java8 module pom disables checkstyle Key: FLINK-7254 URL: https://issues.apache.org/jira/browse/FLINK-7254 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098243#comment-16098243 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098245#comment-16098245 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

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

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098244#comment-16098244 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098246#comment-16098246 ] ASF GitHub Bot commented on FLINK-7202: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129015817 --- Diff: tools/maven/suppressions-java.xml --- @@ -24,6 +24,27 @@ under the License. + + + + + +

[GitHub] flink issue #4384: [FLINK-7202] Split supressions for flink-core, flink-java...

2017-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4384 It appears you're missing suppressions for a number of test packages. --- 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 do

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129016101 --- Diff: tools/maven/suppressions-optimizer.xml --- @@ -24,6 +24,36 @@ under the License. + + + + +

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129015090 --- Diff: tools/maven/suppressions-core.xml --- @@ -24,6 +24,63 @@ under the License. + + + + + +

[GitHub] flink pull request #4384: [FLINK-7202] Split supressions for flink-core, fli...

2017-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4384#discussion_r129015415 --- Diff: tools/maven/suppressions-core.xml --- @@ -24,6 +24,63 @@ under the License. + + + + + +

[jira] [Assigned] (FLINK-7253) Remove all 'assume Java 8' code in tests

2017-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7253: --- Assignee: Chesnay Schepler > Remove all 'assume Java 8' code in tests > -

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2017-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098225#comment-16098225 ] Chesnay Schepler commented on FLINK-7251: - The JIRA title doesn't seem accurate. T

[jira] [Commented] (FLINK-7249) Bump Java version in build plugin

2017-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098219#comment-16098219 ] Chesnay Schepler commented on FLINK-7249: - [~StephanEwen] Is this about the {{java

[jira] [Assigned] (FLINK-7250) Drop the jdk8 build profile

2017-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7250: --- Assignee: Chesnay Schepler > Drop the jdk8 build profile > --

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

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098200#comment-16098200 ] ASF GitHub Bot commented on FLINK-7174: --- Github user tzulitai closed the pull reques

[GitHub] flink pull request #4386: (backport-1.3) [FLINK-7174] [kafka] Bump Kafka 0.1...

2017-07-24 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/4386 --- 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 en

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

2017-07-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7174: --- Release Note: The default Kafka version for Flink Kafka Consumer 0.10 is bumped from 0

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

2017-07-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7174. Resolution: Fixed Release Note: The default Kafka version for Flink Kafka Consu

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

2017-07-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098197#comment-16098197 ] Tzu-Li (Gordon) Tai commented on FLINK-7174: Merged for {{release-1.3}} via 6a

[jira] [Updated] (FLINK-6365) Adapt default values of the Kinesis connector

2017-07-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6365: --- Affects Version/s: (was: 1.2.0) 1.4.0

  1   2   >