[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 connecto

[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: https://issues.apache.org/jira/browse/FLI

[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&focusedCommentId=15495068#comment-15495068 ] ASF GitHub Bot commented on FLINK-4561: --- Github user shijinkui commented on the issu

[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 forwa

[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 compa

[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&focusedCommentId=15494273#comment-15494273 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in t

[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 comp

[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&focusedCommentId=15494252#comment-15494252 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in t

[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 forwa

[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&focusedCommentId=15494110#comment-15494110 ] ASF GitHub Bot commented on FLINK-4625: --- GitHub user StephanEwen opened a pull reque

[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 `SIGTE

[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 st

[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&focusedCommentId=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&focusedCommentId=15494086#comment-15494086 ] ASF GitHub Bot commented on FLINK-4619: --- Github user StephanEwen commented on the is

[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` - `RescalingITCase.testSavepointRescalingFailureWithNonPartitionedSta

[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&focusedCommentId=15494054#comment-15494054 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff

[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 f

[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&focusedCommentId=15494047#comment-15494047 ] ASF GitHub Bot commented on FLINK-4485: --- Github user StephanEwen commented on the is

[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 e

[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 have

[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&focusedCommentId=15494044#comment-15494044 ] ASF GitHub Bot commented on FLINK-4622: --- Github user StephanEwen commented on the is

[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 Type:

[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&focusedCommentId=15494022#comment-15494022 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff

[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 f

[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 70704de0c82cbb7b143dd696221e11999

[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&focusedCommentId=15494002#comment-15494002 ] ASF GitHub Bot commented on FLINK-4389: --- Github user asfgit closed the pull request

[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 enab

[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&focusedCommentId=15493989#comment-15493989 ] ASF GitHub Bot commented on FLINK-4589: --- Github user StephanEwen commented on the is

[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 enable

[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&focusedCommentId=15493956#comment-15493956 ] Matthew Barlocker commented on FLINK-4618: -- Nice find [~melmoth] and [~tzulitai]

[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&focusedCommentId=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&focusedCommentId=15493950#comment-15493950 ] Tzu-Li (Gordon) Tai commented on FLINK-4617: Revisited and reconfirmed that th

[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: Flin

[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 from

[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&focusedCommentId=15493927#comment-15493927 ] Tzu-Li (Gordon) Tai commented on FLINK-4618: I've confirmed that the problem o

[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 of

[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 offset

[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&focusedCommentId=15493897#comment-15493897 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in t

[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 forwa

[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&focusedCommentId=15493858#comment-15493858 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff

[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 have

[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&focusedCommentId=15493859#comment-15493859 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the iss

[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 f

[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&focusedCommentId=15493845#comment-15493845 ] Tzu-Li (Gordon) Tai commented on FLINK-4618: Hi [~melmoth], I've revisited thi

[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&focusedCommentId=15493841#comment-15493841 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on a diff

[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 initia

[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&focusedCommentId=15493835#comment-15493835 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in t

[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 forwa

[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 initialize

[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&focusedCommentId=15493806#comment-15493806 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ggevay commented on a diff in t

[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 wi

[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&focusedCommentId=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: Improv

[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. I

[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 enab

[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&focusedCommentId=15493730#comment-15493730 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the iss

[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 GitH

[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&focusedCommentId=15493720#comment-15493720 ] ASF GitHub Bot commented on FLINK-4615: --- Github user ramkrish86 commented on the iss

[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 appe

[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&focusedCommentId=15493667#comment-15493667 ] Matthew Barlocker commented on FLINK-4617: -- Sounds good. Thanks! > Kafka & Flink

[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 you

[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&focusedCommentId=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&focusedCommentId=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: Bu

[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&focusedCommentId=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 du

[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&focusedCommentId=15493507#comment-15493507 ] ASF GitHub Bot commented on FLINK-4561: --- Github user StephanEwen commented on the is

[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 bett

[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&focusedCommentId=15493485#comment-15493485 ] Scott Kidder commented on FLINK-3442: - This is duplicated by FLINK-4336 > Expose save

[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&focusedCommentId=15493427#comment-15493427 ] Vasia Kalavri commented on FLINK-2254: -- It sounds good to me [~ivan.mushketyk]. Pleas

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

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

[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&focusedCommentId=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 consid

[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 un

[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&focusedCommentId=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&focusedCommentId=15492928#comment-15492928 ] ASF GitHub Bot commented on FLINK-3030: --- Github user mushketyk commented on the issu

[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&focusedCommentId=15492738#comment-15492738 ] Timo Walther commented on FLINK-1135: - No this won't happen. I will close the issue.

[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&focusedCommentId=15492595#comment-15492595 ] Maximilian Michels commented on FLINK-4485: --- Yes, I was able to reproduce the pr