[jira] [Commented] (FLINK-6629) ClusterClient cannot submit jobs to HA cluster if address not set in configuration

2017-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019178#comment-16019178 ] ASF GitHub Bot commented on FLINK-6629: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #3949: [FLINK-6629] Use HAServices to find connecting address fo...

2017-05-21 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3949 Thanks for the review @rmetzger. Merging 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 project does not have th

[jira] [Updated] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-21 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6653: --- Description: Currently, the Kinesis consumer's checkpoints directly serialize AWS's {

[jira] [Created] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-21 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6653: -- Summary: Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints Key: FLINK-6653 URL: https://issues.apache.org/jira/browse/FLINK-6653

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-21 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019140#comment-16019140 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: Let me think a bit about how to p

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-21 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019139#comment-16019139 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: [~skidder] thanks a lot for testi

[jira] [Commented] (FLINK-6482) Add nested serializers into configuration snapshots of composite serializers

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

[GitHub] flink issue #3937: [FLINK-6482] [core] Add nested serializers to config snap...

2017-05-21 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3937 @rmetzger it is currently under review by @StefanRRichter. The conflicts are pretty trivial and can be resolved very quickly; I'm just leaving it as is because the review started already last week.

[jira] [Commented] (FLINK-6495) Migrate Akka configuration options

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

[GitHub] flink issue #3935: [FLINK-6495] Migrate Akka configuration options

2017-05-21 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/3935 @zentol Thank you for your suggestions, and I have fixed the problems you mentioned :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

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

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

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

2017-05-21 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r117651897 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala --- @@ -0,0 +1,323 @@ +/* + * Lice

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

2017-05-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019045#comment-16019045 ] sunjincheng commented on FLINK-6649: Yes,[~fhueske] I like it called `Update Rate`, `U

[jira] [Updated] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

2017-05-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6650: --- Description: When I test Non-windowed group-aggregate with {{stream.toTable(tEnv, 'a, 'b, 'c).select(

[jira] [Updated] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

2017-05-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6650: --- Description: When I test Non-windowed group-aggregate with {{stream.toTable(tEnv, 'a, 'b, 'c).select(

[jira] [Updated] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

2017-05-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6650: --- Description: When I test Non-windowed group-aggregate with {{stream.toTable(tEnv, 'a, 'b, 'c).select(

[jira] [Updated] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

2017-05-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6650: --- Description: When I test Non-windowed group-aggregate with {{stream.toTable(tEnv, 'a, 'b, 'c).select(

[GitHub] flink issue #3947: [FLINK-6610][web] Allow uploadDir to be null in WebFronte...

2017-05-21 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3947 +1 to merge (tested the change locally) --- 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 ena

[jira] [Commented] (FLINK-6610) WebServer could not be created,when set the "jobmanager.web.submit.enable" to false

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

[jira] [Updated] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-05-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6643: -- Description: While testing Flink 1.3 RC1, I found that the JobManager is trying to recover a jo

[jira] [Updated] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-05-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6643: -- Description: While testing Flink 1.3 RC1, I found that the JobManager is trying to recover a jo

[GitHub] flink issue #3949: [FLINK-6629] Use HAServices to find connecting address fo...

2017-05-21 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3949 +1 to merge this 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 feature enabled and wishes

[jira] [Commented] (FLINK-6629) ClusterClient cannot submit jobs to HA cluster if address not set in configuration

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

[jira] [Commented] (FLINK-6482) Add nested serializers into configuration snapshots of composite serializers

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

[GitHub] flink issue #3937: [FLINK-6482] [core] Add nested serializers to config snap...

2017-05-21 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3937 Hey, what's the status of this PR? I see the JIRA is marked as a blocker. When do you think is this PR ready to be merged? --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

2017-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018878#comment-16018878 ] Stephan Ewen commented on FLINK-3952: - True, only Hadoop's netty is shaded. We should

[jira] [Commented] (FLINK-6603) Enable checkstyle on test sources

2017-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018825#comment-16018825 ] ASF GitHub Bot commented on FLINK-6603: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3941: [FLINK-6603] [streaming] Enable checkstyle on test source...

2017-05-21 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3941 @greghogan Awesome, looks good! Thanks a lot for taking this into account! --- 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-6446) Various improvements to the Web Frontend

2017-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018822#comment-16018822 ] ASF GitHub Bot commented on FLINK-6446: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #3946: [FLINK-6446] Fix some small issues in the web UI

2017-05-21 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3946#discussion_r117632701 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.jade --- @@ -28,10 +28,10 @@ split a(ui-sref=".subtasks({nodeid: no

[jira] [Closed] (FLINK-5341) Add a metric exposing how many times a job has been restarted

2017-05-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5341. --- Resolution: Fixed The "fullRestarts" metric was added in 8ed85fe49b7595546a8f968e0faa1fa7d4da4

[jira] [Closed] (FLINK-4909) JDBC Input format cast exception management

2017-05-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4909. --- Resolution: Won't Fix The JDBC InputFormat no longer does any casts or type checks. > JDBC In

[jira] [Closed] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

2017-05-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4061. --- Resolution: Cannot Reproduce > about flink jdbc connect oracle db exists a crital bug > -

[jira] [Commented] (FLINK-6620) Add KeyGroupCheckpointedOperator interface that works for checkpointing key-groups

2017-05-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16018778#comment-16018778 ] Aljoscha Krettek commented on FLINK-6620: - [~lzljs3620320] Unfortunately I'm very

[jira] [Closed] (FLINK-6640) Ensure registration of shared state happens before externalizing a checkpoint

2017-05-21 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6640. - Resolution: Fixed fixed in 040356391f > Ensure registration of shared state happens before extern

[jira] [Created] (FLINK-6652) Problem with DelimitedInputFormat

2017-05-21 Thread Moritz Schubotz (JIRA)
Moritz Schubotz created FLINK-6652: -- Summary: Problem with DelimitedInputFormat Key: FLINK-6652 URL: https://issues.apache.org/jira/browse/FLINK-6652 Project: Flink Issue Type: Bug