[jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542617#comment-16542617 ] ASF GitHub Bot commented on FLINK-7095: --- Github user zhangminglei closed the pull r

[jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542615#comment-16542615 ] ASF GitHub Bot commented on FLINK-7095: --- Github user zhangminglei commented on the

[GitHub] flink pull request #5375: [FLINK-7095] [TaskManager] Add Command line parsin...

2018-07-12 Thread zhangminglei
Github user zhangminglei closed the pull request at: https://github.com/apache/flink/pull/5375 ---

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

2018-07-12 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/6323 [FLINK-8558] [FLINK-8866] [table] Finalize unified table source/sink/format interfaces ## What is the purpose of the change This PR finalizes the efforts done in #6264 and #6201 for having

[GitHub] flink issue #5375: [FLINK-7095] [TaskManager] Add Command line parsing tool ...

2018-07-12 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5375 Hi, @tillrohrmann . You are welcome ~ I still have a lot of other flink jira will be addressed by me in the future. ---

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Resolved] (FLINK-4807) ResourceManager clean up JobManager's registration

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4807. -- Resolution: Duplicate Fix Version/s: 1.5.0 > ResourceManager clean up JobManager's regis

[jira] [Resolved] (FLINK-7472) Release task managers gracefully

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7472. -- Resolution: Done > Release task managers gracefully > > >

[jira] [Commented] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session

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

[GitHub] flink issue #6240: [FLINK-9004][tests] Implement Jepsen tests to test job av...

2018-07-12 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/6240 I extended the regular `README.md`. ---

[jira] [Assigned] (FLINK-7075) Implement Flip-6 standalone mode

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7075: Assignee: Till Rohrmann > Implement Flip-6 standalone mode > -

[jira] [Closed] (FLINK-7075) Implement Flip-6 standalone mode

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7075. Resolution: Fixed Fix Version/s: 1.5.0 Added to Flink 1.5.0 > Implement Flip-6 standalone m

[jira] [Resolved] (FLINK-4897) Implement Dispatcher to support Flink sessions

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4897. -- Resolution: Fixed Fix Version/s: 1.5.0 Added to Flink 1.5.0: 748eba1b5363aeb9e64d379b9b2

[jira] [Resolved] (FLINK-4834) Implement unified High Availability Services Abstraction

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4834. -- Resolution: Fixed Fix Version/s: 1.5.0 All subtasks have been completed in Flink 1.5.0.

[jira] [Assigned] (FLINK-4343) Implement new TaskManager

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4343: Assignee: Till Rohrmann > Implement new TaskManager > - > >

[jira] [Resolved] (FLINK-4343) Implement new TaskManager

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4343. -- Resolution: Fixed Fix Version/s: 1.5.0 The {{TaskExecutor}} has been added to Flink 1.5.

[jira] [Resolved] (FLINK-7469) Handle slot requests occuring before RM registration completes

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7469. -- Resolution: Duplicate Fix Version/s: 1.5.0 This issue should have been fixed with FLINK-

[jira] [Closed] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7095. Resolution: Duplicate Fix Version/s: 1.6.0 > Add proper command line parsing tool to TaskMan

[jira] [Updated] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7095: -- Labels: flip-6 pull-request-available (was: flip-6) > Add proper command line parsing tool to

[jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542601#comment-16542601 ] ASF GitHub Bot commented on FLINK-7095: --- Github user tillrohrmann commented on the

[GitHub] flink issue #5375: [FLINK-7095] [TaskManager] Add Command line parsing tool ...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5375 Sorry for not getting back to you earlier @zhangminglei. I accidentally addressed this issue with #6318. I think we can therefore close this PR. Sorry for the bad PR management. This won

[jira] [Commented] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542600#comment-16542600 ] ASF GitHub Bot commented on FLINK-9822: --- Github user tillrohrmann commented on a di

[GitHub] flink pull request #6319: [FLINK-9822] Add Dockerfile for StandaloneJobClust...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6319#discussion_r202254368 --- Diff: flink-container/docker/README.md --- @@ -0,0 +1,44 @@ +# Apache Flink cluster deployment on docker using docker-compose --- End diff --

[GitHub] flink pull request #6319: [FLINK-9822] Add Dockerfile for StandaloneJobClust...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6319#discussion_r202254410 --- Diff: flink-container/docker/README.md --- @@ -0,0 +1,44 @@ +# Apache Flink cluster deployment on docker using docker-compose + +## Insta

[jira] [Commented] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542599#comment-16542599 ] ASF GitHub Bot commented on FLINK-9822: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542596#comment-16542596 ] Till Rohrmann commented on FLINK-4319: -- [~yazdanjs] thanks for your interest. The co

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

2018-07-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542594#comment-16542594 ] Chesnay Schepler commented on FLINK-5860: - [~maheshsenni] the cassandra example s

[jira] [Commented] (FLINK-9771) "Show Plan" option under Submit New Job in WebUI not working

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

[jira] [Commented] (FLINK-9563) Migrate integration tests for CEP

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

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

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

[jira] [Commented] (FLINK-9801) flink-dist is missing dependency on flink-examples

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

[jira] [Commented] (FLINK-9810) JarListHandler does not close opened jars

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

[GitHub] flink pull request #6170: [FLINK-9563]: Using a custom sink function for tes...

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6170 ---

[GitHub] flink pull request #6304: [FLINK-9801][build] Add missing example dependenci...

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6304 ---

[GitHub] flink pull request #6102: [FLINK-9091][build] Dependency convergence run aga...

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6102 ---

[GitHub] flink pull request #6274: [FLINK-9771][rest] Fix plan JSON response

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6274 ---

[GitHub] flink pull request #6310: [FLINK-9810][rest] Close jar file in JarListHandle...

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6310 ---

[jira] [Closed] (FLINK-9563) Migrate integration tests for CEP

2018-07-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9563. --- Resolution: Fixed Fix Version/s: 1.6.0 master: 40f9131e9136f4f956c59e4c0c837afba8b9bb4

[jira] [Commented] (FLINK-9276) Improve error message when TaskManager fails

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

[GitHub] flink pull request #5954: [FLINK-9276] Improve error message when TaskManage...

2018-07-12 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/5954 ---

[jira] [Commented] (FLINK-9276) Improve error message when TaskManager fails

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

[GitHub] flink issue #5954: [FLINK-9276] Improve error message when TaskManager fails

2018-07-12 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5954 OK, closing this PR... ---

[GitHub] flink pull request #6305: [FLINK-9807][tests] Optimize EventTimeWindowCheckp...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6305#discussion_r202249510 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java --- @@ -99,11 +110,21 @@

[jira] [Commented] (FLINK-9807) Improve EventTimeWindowCheckpointITCase&LocalRecoveryITCase with parameterized

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542572#comment-16542572 ] ASF GitHub Bot commented on FLINK-9807: --- Github user tillrohrmann commented on a di

[jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9764: - Priority: Critical (was: Major) > Failure in LocalRecoveryRocksDBFullITCase > --

[jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9764: - Fix Version/s: 1.6.0 > Failure in LocalRecoveryRocksDBFullITCase > --

[jira] [Assigned] (FLINK-9807) Improve EventTimeWindowCheckpointITCase&LocalRecoveryITCase with parameterized

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9807: Assignee: Congxian Qiu > Improve EventTimeWindowCheckpointITCase&LocalRecoveryITCase with

[jira] [Commented] (FLINK-9276) Improve error message when TaskManager fails

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542549#comment-16542549 ] ASF GitHub Bot commented on FLINK-9276: --- Github user tillrohrmann commented on the

[GitHub] flink issue #5954: [FLINK-9276] Improve error message when TaskManager fails

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5954 I think this is not super critical and since we only pass in `Exceptions` at the moment I would say let's close this PR. ---

[jira] [Commented] (FLINK-9575) Potential race condition when removing JobGraph in HA

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542547#comment-16542547 ] ASF GitHub Bot commented on FLINK-9575: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-9575) Potential race condition when removing JobGraph in HA

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542546#comment-16542546 ] ASF GitHub Bot commented on FLINK-9575: --- Github user tillrohrmann commented on a di

[jira] [Commented] (FLINK-9575) Potential race condition when removing JobGraph in HA

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542548#comment-16542548 ] ASF GitHub Bot commented on FLINK-9575: --- Github user tillrohrmann commented on a di

[GitHub] flink pull request #6322: [FLINK-9575]: Remove job-related BLOBS only if the...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6322#discussion_r202248523 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1759,11 +1759,22 @@ class JobManager( ca

[GitHub] flink pull request #6322: [FLINK-9575]: Remove job-related BLOBS only if the...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6322#discussion_r202248449 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1759,11 +1759,22 @@ class JobManager( ca

[GitHub] flink pull request #6322: [FLINK-9575]: Remove job-related BLOBS only if the...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6322#discussion_r202248365 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1759,11 +1759,22 @@ class JobManager( ca

[jira] [Commented] (FLINK-9832) Allow commas in job submission query params

2018-07-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542526#comment-16542526 ] Chesnay Schepler commented on FLINK-9832: - HA, it's not a parsing error but the _

[jira] [Commented] (FLINK-9832) Allow commas in job submission query params

2018-07-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542522#comment-16542522 ] Chesnay Schepler commented on FLINK-9832: - hold on, that doesn't quite work since

[jira] [Commented] (FLINK-9832) Allow commas in job submission query params

2018-07-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542520#comment-16542520 ] Chesnay Schepler commented on FLINK-9832: - I have an idea to fix this in a better

[jira] [Assigned] (FLINK-9832) Allow commas in job submission query params

2018-07-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9832: --- Assignee: Chesnay Schepler > Allow commas in job submission query params > -

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

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

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

2018-07-12 Thread RalphSu
Github user RalphSu commented on the issue: https://github.com/apache/flink/pull/6103 @tillrohrmann already did that, it looks alleviate though not fix. I'm upgrade from 1.2.0 to 1.4.2. Major thing i can see is TM now connection to HDFS instead of only talk to JobManager, could this

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542428#comment-16542428 ] ASF GitHub Bot commented on FLINK-9692: --- Github user glaksh100 commented on the iss

[GitHub] flink issue #6300: [FLINK-9692][Kinesis Connector] Adaptive reads from Kines...

2018-07-12 Thread glaksh100
Github user glaksh100 commented on the issue: https://github.com/apache/flink/pull/6300 The idea here is that `maxNumberOfRecordsPerFetch` should never be a value that gets records that exceeds the read limit (2 Mb/sec) from the math here. ``` 2 Mb/sec / (averageRecordSizeByte

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

2018-07-12 Thread glaksh100
Github user glaksh100 commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r202227845 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -330,4

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

2018-07-12 Thread glaksh100
Github user glaksh100 commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r202227834 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java --- @@

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542423#comment-16542423 ] ASF GitHub Bot commented on FLINK-9692: --- Github user glaksh100 commented on a diff

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542424#comment-16542424 ] ASF GitHub Bot commented on FLINK-9692: --- Github user glaksh100 commented on a diff

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542293#comment-16542293 ] ASF GitHub Bot commented on FLINK-9692: --- Github user bowenli86 commented on a diff

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542292#comment-16542292 ] ASF GitHub Bot commented on FLINK-9692: --- Github user bowenli86 commented on a diff

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

2018-07-12 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r202199865 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java --- @@

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

2018-07-12 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r202201507 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -330,4

[jira] [Commented] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542273#comment-16542273 ] ASF GitHub Bot commented on FLINK-9822: --- Github user bowenli86 commented on a diff

[jira] [Commented] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542272#comment-16542272 ] ASF GitHub Bot commented on FLINK-9822: --- Github user bowenli86 commented on a diff

[GitHub] flink pull request #6319: [FLINK-9822] Add Dockerfile for StandaloneJobClust...

2018-07-12 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6319#discussion_r202198679 --- Diff: flink-container/docker/README.md --- @@ -0,0 +1,44 @@ +# Apache Flink cluster deployment on docker using docker-compose --- End diff --

[GitHub] flink pull request #6319: [FLINK-9822] Add Dockerfile for StandaloneJobClust...

2018-07-12 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6319#discussion_r202197686 --- Diff: flink-container/docker/README.md --- @@ -0,0 +1,44 @@ +# Apache Flink cluster deployment on docker using docker-compose + +## Installa

[jira] [Assigned] (FLINK-9703) Mesos does not expose TM Prometheus port

2018-07-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9703: Assignee: Rune Skou Larsen > Mesos does not expose TM Prometheus port > --

[jira] [Commented] (FLINK-9703) Mesos does not expose TM Prometheus port

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542188#comment-16542188 ] ASF GitHub Bot commented on FLINK-9703: --- Github user tillrohrmann commented on a di

[GitHub] flink pull request #6288: [FLINK-9703] [flink-mesos] Expose Prometheus port ...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6288#discussion_r202171601 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -332,6 +334,22 @@ public String t

[jira] [Commented] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542132#comment-16542132 ] ASF GitHub Bot commented on FLINK-9692: --- Github user glaksh100 commented on a diff

[GitHub] flink pull request #6300: [FLINK-9692][Kinesis Connector] Adaptive reads fro...

2018-07-12 Thread glaksh100
Github user glaksh100 commented on a diff in the pull request: https://github.com/apache/flink/pull/6300#discussion_r202156901 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -330,4

[jira] [Closed] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-07-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8480. - Resolution: Fixed Merged on master with 42ada8ad9ca28f94d0a0355658330198bbc2b577. > Implement Ja

[jira] [Updated] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8480: -- Labels: pull-request-available (was: ) > Implement Java API to expose join functionality of >

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

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

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for Interval...

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5482 ---

[jira] [Closed] (FLINK-9701) Activate TTL in state descriptors

2018-07-12 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9701. - Resolution: Implemented Merged in: master: f45b7f7ff2 > Activate TTL in state descriptors >

[jira] [Commented] (FLINK-9701) Activate TTL in state descriptors

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

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

2018-07-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6313 ---

[jira] [Commented] (FLINK-9701) Activate TTL in state descriptors

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542040#comment-16542040 ] ASF GitHub Bot commented on FLINK-9701: --- Github user StefanRRichter commented on th

[GitHub] flink issue #6313: [FLINK-9701] Add TTL in state descriptors

2018-07-12 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/6313 LGTM, nice work! 👍 Besides one comment about closing the backends after tests, the PR is ready. This is no big thing so I will just fix it myself before merging now. ---

[jira] [Commented] (FLINK-9701) Activate TTL in state descriptors

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542039#comment-16542039 ] ASF GitHub Bot commented on FLINK-9701: --- Github user StefanRRichter commented on a

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

2018-07-12 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202130806 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/StateBackendTestContext.java --- @@ -0,0 +1,120 @@ +/* + * Licensed

[jira] [Commented] (FLINK-9829) The wrapper classes be compared by symbol of '==' directly in BigDecSerializer.java

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542013#comment-16542013 ] ASF GitHub Bot commented on FLINK-9829: --- Github user lamber-ken commented on the is

[GitHub] flink issue #6321: [FLINK-9829] fix the wrapper classes be compared by symbo...

2018-07-12 Thread lamber-ken
Github user lamber-ken commented on the issue: https://github.com/apache/flink/pull/6321 @zentol, hi, there are two ways to contribute to flink project. one is create a `jira FLINK-` , another is `[hotfix] XXX`. for example, fix some checkstyle or code refactor, how to

[jira] [Commented] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541946#comment-16541946 ] ASF GitHub Bot commented on FLINK-8544: --- Github user BillLeecn commented on the iss

[GitHub] flink issue #5516: [FLINK-8544] [Kafka Connector] Handle null message key in...

2018-07-12 Thread BillLeecn
Github user BillLeecn commented on the issue: https://github.com/apache/flink/pull/5516 @dawidwys Of course not. The patch has been updated. ---

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541926#comment-16541926 ] ASF GitHub Bot commented on FLINK-9143: --- Github user tillrohrmann commented on a di

[GitHub] flink pull request #6283: [FLINK-9143] Use cluster strategy if none was set ...

2018-07-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6283#discussion_r202103545 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CoordinatorShutdownTest.java --- @@ -83,6 +86,10 @@ public void testCoordinat

[jira] [Commented] (FLINK-9701) Activate TTL in state descriptors

2018-07-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541921#comment-16541921 ] ASF GitHub Bot commented on FLINK-9701: --- Github user StefanRRichter commented on a

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

2018-07-12 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202103083 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -240,7 +243,7 @@ private boolean hasRegis

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

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

  1   2   3   4   >