[jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

[ https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4627: --- Description: Right now value extraction from config properties in the Kinesis

[jira] [Created] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

Tzu-Li (Gordon) Tai created FLINK-4627: -- Summary: Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties Key: FLINK-4627 URL:

[jira] [Commented] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15495068#comment-15495068 ] ASF GitHub Bot commented on FLINK-4561: --- Github user shijinkui commented on the issue:

[GitHub] flink issue #2459: [FLINK-4561] replace all the scala version as a `scala.bi...

Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2459 @StephanEwen Thank for your reply, understand it. --- 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] [Created] (FLINK-4626) Missing break in MetricStore#add()

Ted Yu created FLINK-4626: - Summary: Missing break in MetricStore#add() Key: FLINK-4626 URL: https://issues.apache.org/jira/browse/FLINK-4626 Project: Flink Issue Type: Bug Reporter: Ted

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79040795 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[jira] [Updated] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version

[ https://issues.apache.org/jira/browse/FLINK-4515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4515: - Component/s: JobManager > org.apache.flink.runtime.jobmanager.JobInfo class is not backwards

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494273#comment-15494273 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in the pull request:

[jira] [Updated] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version

[ https://issues.apache.org/jira/browse/FLINK-4515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4515: - Affects Version/s: 1.2.0 > org.apache.flink.runtime.jobmanager.JobInfo class is not backwards

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494252#comment-15494252 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in the pull request:

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79038567 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[jira] [Commented] (FLINK-4625) Guard Flink processes against blocking shutdown hooks

[ https://issues.apache.org/jira/browse/FLINK-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494110#comment-15494110 ] ASF GitHub Bot commented on FLINK-4625: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request #2503: [FLINK-4625] [core] Add a safety net to forcibly t...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2503 [FLINK-4625] [core] Add a safety net to forcibly terminate JVM if clean shutdown freezed. Resource managers like YARN send the JVM the `SIGTERM` signal to kill the process. With

[GitHub] flink issue #2498: [FLINK-4619] - JobManager does not answer to client when ...

Github user mproch commented on the issue: https://github.com/apache/flink/pull/2498 Yes, it's a bit more tricky then I expected... These tests probably also need to be changed, because they relied on previous behaviour... What's more with the change some checks on FlinkMiniCluster

[jira] [Commented] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

[ https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494099#comment-15494099 ] ASF GitHub Bot commented on FLINK-4619: --- Github user mproch commented on the issue:

[jira] [Commented] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

[ https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494086#comment-15494086 ] ASF GitHub Bot commented on FLINK-4619: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2498: [FLINK-4619] - JobManager does not answer to client when ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2498 Good idea. Unfortunately, the changed broke some tests: - `SavepointITCase.testSubmitWithUnknownSavepointPath` -

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494054#comment-15494054 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79021152 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494047#comment-15494047 ] ASF GitHub Bot commented on FLINK-4485: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2499: [FLINK-4485] close and remove user class loader after job...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2499 Looks food to me. +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

[GitHub] flink issue #2501: [FLINK-4622] CLI help message should include 'savepoint' ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2501 Thanks for the correction. +1 to merge 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 not

[jira] [Commented] (FLINK-4622) CLI help message should include 'savepoint' action

[ https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494044#comment-15494044 ] ASF GitHub Bot commented on FLINK-4622: --- Github user StephanEwen commented on the issue:

[jira] [Created] (FLINK-4625) Guard Flink processes against blocking shutdown hooks

Stephan Ewen created FLINK-4625: --- Summary: Guard Flink processes against blocking shutdown hooks Key: FLINK-4625 URL: https://issues.apache.org/jira/browse/FLINK-4625 Project: Flink Issue

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494022#comment-15494022 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79017956 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[jira] [Closed] (FLINK-4389) Expose metrics to Webfrontend

[ https://issues.apache.org/jira/browse/FLINK-4389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4389. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[jira] [Commented] (FLINK-4389) Expose metrics to Webfrontend

[ https://issues.apache.org/jira/browse/FLINK-4389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15494002#comment-15494002 ] ASF GitHub Bot commented on FLINK-4389: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2363: [FLINK-4389] Expose metrics to WebFrontend

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2363 --- 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-4589) Fix Merging of Covering Window in MergingWindowSet

[ https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493989#comment-15493989 ] ASF GitHub Bot commented on FLINK-4589: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2476: [FLINK-4589] Fix Merging of Covering Window in MergingWin...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2476 Looks good to me, 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 not have this feature

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493956#comment-15493956 ] Matthew Barlocker commented on FLINK-4618: -- Nice find [~melmoth] and [~tzulitai] - I don't know

[jira] [Comment Edited] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493927#comment-15493927 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4618 at 9/15/16 5:04 PM: -

[jira] [Commented] (FLINK-4617) Kafka & Flink duplicate messages on restart

[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493950#comment-15493950 ] Tzu-Li (Gordon) Tai commented on FLINK-4617: Revisited and reconfirmed that this is actually a

[jira] [Created] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

Till Rohrmann created FLINK-4624: Summary: Gelly's summarization algorithm cannot deal with null vertex group values Key: FLINK-4624 URL: https://issues.apache.org/jira/browse/FLINK-4624 Project:

[jira] [Updated] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4618: --- Fix Version/s: 1.1.3 1.2.0 > FlinkKafkaConsumer09 should start

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493927#comment-15493927 ] Tzu-Li (Gordon) Tai commented on FLINK-4618: I've confirmed that the problem only exists in

[jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record on startup from Kafka offsets

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4618: --- Summary: Kafka Consumer 0.9 should start from the next record on startup from Kafka

[jira] [Updated] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4618: --- Summary: FlinkKafkaConsumer09 should start from the next record on startup from

[jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4618: --- Summary: Kafka Consumer 0.9 should start from the next record on startup from offsets

[jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record when startup from Kafka offsets

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4618: --- Description: **Original reported ticket title: Last kafka message gets consumed twice

[jira] [Updated] (FLINK-4618) Kafka Consumer 0.9 should start from the next record when startup from Kafka offsets

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4618: --- Summary: Kafka Consumer 0.9 should start from the next record when startup from Kafka

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493897#comment-15493897 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in the pull request:

[jira] [Reopened] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-4618: > Last kafka message gets consumed twice when restarting job >

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79010283 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493858#comment-15493858 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2495 @ggevay and @StephanEwen - any feedback/reviews here. --- 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] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493859#comment-15493859 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79007600 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[jira] [Commented] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493845#comment-15493845 ] Tzu-Li (Gordon) Tai commented on FLINK-4618: Hi [~melmoth], I've revisited this issue, and I

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493841#comment-15493841 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79006658 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationIntermediateTask.java --- @@ -82,43 +82,46 @@ protected void

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493835#comment-15493835 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in the pull request:

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79005879 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java --- @@ -87,4 +87,6 @@ * @throws Exception Exceptions may be

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2496#discussion_r79003843 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationIntermediateTask.java --- @@ -82,43 +82,46 @@ protected void

[jira] [Assigned] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

[ https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4590: --- Assignee: Timo Walther > Some Table API tests are failing when debug lvl is set to DEBUG >

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493806#comment-15493806 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in the pull request:

[GitHub] flink issue #2454: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2454 It seems that Calcite is planning to add additional clauses to the SQL statement. Like `SELECT STREAM x FROM y EMIT xyz`. If we really remove the keyword we have to make sure that Calcite's parser

[jira] [Commented] (FLINK-4546) Remove STREAM keyword in Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493770#comment-15493770 ] ASF GitHub Bot commented on FLINK-4546: --- Github user twalthr commented on the issue:

[jira] [Updated] (FLINK-4623) Create Physical Execution Plan of a DataStream

[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4623: Labels: starter (was: ) > Create Physical Execution Plan of a DataStream >

[jira] [Created] (FLINK-4623) Create Physical Execution Plan of a DataStream

Timo Walther created FLINK-4623: --- Summary: Create Physical Execution Plan of a DataStream Key: FLINK-4623 URL: https://issues.apache.org/jira/browse/FLINK-4623 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4599. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 545b72bee9b2297c9d1d2f5d59d6d839378fde92.

[GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2485 --- 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-3322) MemoryManager creates too much GC pressure with iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493730#comment-15493730 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2495 The build shows failure but not sure what is the failure. It does not show any specific test case. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink issue #2496: FLINK-4615 Reusing the memory allocated for the drivers a...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2496 Builds seems to pass with this latest commit. Any feedback here @ggevay and @StephanEwen . --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493720#comment-15493720 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2485: [Flink 4599] - Add 'explain()' also to StreamTableEnviron...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2485 Thanks @chobeat. I fixed minor formatting issues and extended the documentation a little bit. Will merge... --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-4617) Kafka & Flink duplicate messages on restart

[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493667#comment-15493667 ] Matthew Barlocker commented on FLINK-4617: -- Sounds good. Thanks! > Kafka & Flink duplicate

[GitHub] flink pull request #2502: [FLINK-4550] [table] Clearly define SQL operator t...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2502 [FLINK-4550] [table] Clearly define SQL operator table Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Commented] (FLINK-4550) Clearly define SQL operator table

[ https://issues.apache.org/jira/browse/FLINK-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493575#comment-15493575 ] ASF GitHub Bot commented on FLINK-4550: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-4622) CLI help message should include 'savepoint' action

[ https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493533#comment-15493533 ] ASF GitHub Bot commented on FLINK-4622: --- GitHub user skidder opened a pull request:

[GitHub] flink pull request #2501: [FLINK-4622] CLI help message should include 'save...

GitHub user skidder opened a pull request: https://github.com/apache/flink/pull/2501 [FLINK-4622] CLI help message should include 'savepoint' action The Flink CLI help message should include the 'savepoint' action in the list of available actions. It currently looks like:

[jira] [Created] (FLINK-4622) CLI help message should include 'savepoint' action

Scott Kidder created FLINK-4622: --- Summary: CLI help message should include 'savepoint' action Key: FLINK-4622 URL: https://issues.apache.org/jira/browse/FLINK-4622 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493517#comment-15493517 ] ASF GitHub Bot commented on FLINK-3702: --- Github user ggevay commented on the issue:

[GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp...

Github user ggevay commented on the issue: https://github.com/apache/flink/pull/2094 > As for this pull request I suggest to update the false Javadoc from the streaming API and document in the concepts that the aggregation field accessors and the keyselectors are slightly different

[jira] [Commented] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493507#comment-15493507 ] ASF GitHub Bot commented on FLINK-4561: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2459: [FLINK-4561] replace all the scala version as a `scala.bi...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2459 @shijinkui I understand your motivation, it is a good idea in general. Please do not feel discouraged to suggest improvements. There are some things that look like they could be done

[jira] [Commented] (FLINK-3442) Expose savepoint button on web ui

[ https://issues.apache.org/jira/browse/FLINK-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493485#comment-15493485 ] Scott Kidder commented on FLINK-3442: - This is duplicated by FLINK-4336 > Expose savepoint button on

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493427#comment-15493427 ] Vasia Kalavri commented on FLINK-2254: -- It sounds good to me [~ivan.mushketyk]. Please go ahead and

[jira] [Commented] (FLINK-4620) Automatically creating savepoints

[ https://issues.apache.org/jira/browse/FLINK-4620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493397#comment-15493397 ] Stephan Ewen commented on FLINK-4620: - Adding [~uce] to this thread. There is a FLIP to unify

[jira] [Assigned] (FLINK-4550) Clearly define SQL operator table

[ https://issues.apache.org/jira/browse/FLINK-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4550: --- Assignee: Timo Walther > Clearly define SQL operator table >

[jira] [Commented] (FLINK-4549) Test and document implicitly supported SQL functions

[ https://issues.apache.org/jira/browse/FLINK-4549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493229#comment-15493229 ] ASF GitHub Bot commented on FLINK-4549: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #2500: [FLINK-4549] [table] Test and document implicitly ...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2500 [FLINK-4549] [table] Test and document implicitly supported SQL functions Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request #2499: [FLINK-4485] close and remove user class loader af...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2499 [FLINK-4485] close and remove user class loader after job completion Keeping the user class loader around after job completion may lead to excessive temp space usage because all user jars are kept

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15493019#comment-15493019 ] ASF GitHub Bot commented on FLINK-4485: --- GitHub user mxm opened a pull request:

[jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts

[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492928#comment-15492928 ] ASF GitHub Bot commented on FLINK-3030: --- Github user mushketyk commented on the issue:

[GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2448 @StephanEwen Should I change anything else in 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

[jira] [Created] (FLINK-4621) Improve decimal literals of SQL API

Timo Walther created FLINK-4621: --- Summary: Improve decimal literals of SQL API Key: FLINK-4621 URL: https://issues.apache.org/jira/browse/FLINK-4621 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink"

[ https://issues.apache.org/jira/browse/FLINK-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-1135. --- Resolution: Won't Fix > Blog post with topic "Accessing Data Stored in Hive with Flink" >

[jira] [Commented] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink"

[ https://issues.apache.org/jira/browse/FLINK-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492738#comment-15492738 ] Timo Walther commented on FLINK-1135: - No this won't happen. I will close the issue. > Blog post with

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492595#comment-15492595 ] Maximilian Michels commented on FLINK-4485: --- Yes, I was able to reproduce the problem with your

[jira] [Assigned] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4485: - Assignee: Maximilian Michels > Finished jobs in yarn session fill /tmp

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492554#comment-15492554 ] ASF GitHub Bot commented on FLINK-3857: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1962 Thanks @HungUnicorn, thats useful info. I wonder though if this config should be set by the user, instead of letting the connector internally set this. --- If your project is set up for it, you

[jira] [Closed] (FLINK-4617) Kafka & Flink duplicate messages on restart

[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-4617. -- > Kafka & Flink duplicate messages on restart > ---

[jira] [Resolved] (FLINK-4617) Kafka & Flink duplicate messages on restart

[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4617. Resolution: Not A Bug > Kafka & Flink duplicate messages on restart >

[jira] [Commented] (FLINK-4617) Kafka & Flink duplicate messages on restart

[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492513#comment-15492513 ] Tzu-Li (Gordon) Tai commented on FLINK-4617: Hi [~mbarlocker], now that this is sorted out (on

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

[ https://issues.apache.org/jira/browse/FLINK-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15492504#comment-15492504 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2496: FLINK-4615 Reusing the memory allocated for the drivers a...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2496 Updated PR. Handles reset()in a much better way. PageRankITCase exposed some cases. Also does the clean up of the driver now. Still wondering there should be a reason why the driver was

  1   2   >