[jira] [Assigned] (FLINK-6615) tmp directory not cleaned up on shutdown

[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6615: --- Assignee: (was: Bowen Li) > tmp directory not cleaned up on shutdown >

[jira] [Resolved] (FLINK-6615) tmp directory not cleaned up on shutdown

[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-6615. - Resolution: Won't Fix > tmp directory not cleaned up on shutdown >

[jira] [Assigned] (FLINK-7947) Let ParameterTool return a dedicated GlobalJobParameters object

[ https://issues.apache.org/jira/browse/FLINK-7947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7947: --- Assignee: (was: Bowen Li) > Let ParameterTool return a dedicated GlobalJobParameters object >

[GitHub] flink pull request #:

Github user jimmec commented on the pull request: https://github.com/apache/flink/commit/3062e29a8bbb667d098c43a0b225d5602049#commitcomment-27642949 In

[jira] [Closed] (FLINK-8548) Add Streaming State Machine Example

[ https://issues.apache.org/jira/browse/FLINK-8548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8548. --- > Add Streaming State Machine Example > --- > > Key:

[jira] [Resolved] (FLINK-8548) Add Streaming State Machine Example

[ https://issues.apache.org/jira/browse/FLINK-8548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8548. - Resolution: Done Done in 80883feeeba5232ecd41fe6759c69bf2ff1a6483 > Add Streaming State Machine

[jira] [Closed] (FLINK-8680) Name printing sinks by default.

[ https://issues.apache.org/jira/browse/FLINK-8680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8680. --- > Name printing sinks by default. > --- > > Key: FLINK-8680 >

[jira] [Resolved] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions

[ https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8549. - Resolution: Fixed Fixed via 85bfc073680667e9daa16439d33fa86c1c0be133 > Move TimerServiceOptions

[jira] [Resolved] (FLINK-8680) Name printing sinks by default.

[ https://issues.apache.org/jira/browse/FLINK-8680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8680. - Resolution: Fixed Fixed via 21491b2717e3a60e63dcf4fb0aa839b9885be67a > Name printing sinks by

[jira] [Closed] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions

[ https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8549. --- > Move TimerServiceOptions to TaskManagerOptions > -- > >

[jira] [Commented] (FLINK-8548) Add Streaming State Machine Example

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

[jira] [Closed] (FLINK-8682) Make start/stop cluster scripts work without SSH for local HA setups

[ https://issues.apache.org/jira/browse/FLINK-8682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8682. --- > Make start/stop cluster scripts work without SSH for local HA setups >

[jira] [Resolved] (FLINK-8682) Make start/stop cluster scripts work without SSH for local HA setups

[ https://issues.apache.org/jira/browse/FLINK-8682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8682. - Resolution: Fixed Fixed via 39711fb6f1d801e067e121803ea82b1c2742c956 > Make start/stop cluster

[GitHub] flink pull request #5402: [FLINK-8549] [config] Move TimerServiceOptions int...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5402 ---

[jira] [Commented] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions

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

[jira] [Closed] (FLINK-8681) Remove planVisualizer.html move notice

[ https://issues.apache.org/jira/browse/FLINK-8681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8681. --- > Remove planVisualizer.html move notice > -- > >

[jira] [Resolved] (FLINK-8681) Remove planVisualizer.html move notice

[ https://issues.apache.org/jira/browse/FLINK-8681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8681. - Resolution: Fixed Fixed via 096bf80d93d4f27b2e57aaff8754ebbe54151ecb > Remove

[GitHub] flink pull request #5401: [FLINK-8548] [examples] Add state machine example

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5401 ---

[jira] [Commented] (FLINK-8599) Improve the failure behavior of the FileInputFormat for bad files

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

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368677#comment-16368677 ] Ken Krugler commented on FLINK-7477: It works (at least when running with YARN via EMR). I believe

[GitHub] flink pull request #5521: [FLINK-8599] Improve the failure behavior of the F...

GitHub user ChengzhiZhao opened a pull request: https://github.com/apache/flink/pull/5521 [FLINK-8599] Improve the failure behavior of the FileInputFormat for … ## What is the purpose of the change This pull request is intent to improve the failure behavior of the

[jira] [Closed] (FLINK-8692) Mistake in MyMapFunction code snippet

[ https://issues.apache.org/jira/browse/FLINK-8692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8692. --- Resolution: Fixed master: 0644f4f77dde4532714fb60bf8c646365fca5fc0 1.4:

[jira] [Updated] (FLINK-8692) Mistake in MyMapFunction code snippet

[ https://issues.apache.org/jira/browse/FLINK-8692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8692: Labels: (was: documentation) > Mistake in MyMapFunction code snippet >

[jira] [Updated] (FLINK-8692) Mistake in MyMapFunction code snippet

[ https://issues.apache.org/jira/browse/FLINK-8692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8692: Affects Version/s: 1.5.0 > Mistake in MyMapFunction code snippet >

[jira] [Assigned] (FLINK-8692) Mistake in MyMapFunction code snippet

[ https://issues.apache.org/jira/browse/FLINK-8692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8692: --- Assignee: Chesnay Schepler > Mistake in MyMapFunction code snippet >

[jira] [Updated] (FLINK-8692) Mistake in MyMapFunction code snippet

[ https://issues.apache.org/jira/browse/FLINK-8692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8692: Fix Version/s: 1.4.2 1.5.0 > Mistake in MyMapFunction code snippet >

[jira] [Closed] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

[ https://issues.apache.org/jira/browse/FLINK-8693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8693. --- Resolution: Fixed master: 8cea2f6576da713e5625e00ef2dbe34a410a1df1 > initPythonInterpreter

[jira] [Updated] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

[ https://issues.apache.org/jira/browse/FLINK-8693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8693: Priority: Trivial (was: Minor) > initPythonInterpreter is called twice with same arguments

[jira] [Updated] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

[ https://issues.apache.org/jira/browse/FLINK-8693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8693: Fix Version/s: 1.5.0 > initPythonInterpreter is called twice with same arguments in >

[jira] [Updated] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

[ https://issues.apache.org/jira/browse/FLINK-8693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8693: Component/s: Python API > initPythonInterpreter is called twice with same arguments in >

[jira] [Updated] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

[ https://issues.apache.org/jira/browse/FLINK-8693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8693: Affects Version/s: 1.5.0 > initPythonInterpreter is called twice with same arguments in >

[jira] [Assigned] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

[ https://issues.apache.org/jira/browse/FLINK-8693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8693: --- Assignee: Chesnay Schepler > initPythonInterpreter is called twice with same

[jira] [Created] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

Ted Yu created FLINK-8693: - Summary: initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript Key: FLINK-8693 URL: https://issues.apache.org/jira/browse/FLINK-8693

[jira] [Created] (FLINK-8692) Mistake in MyMapFunction code snippet

Matt Hagen created FLINK-8692: - Summary: Mistake in MyMapFunction code snippet Key: FLINK-8692 URL: https://issues.apache.org/jira/browse/FLINK-8692 Project: Flink Issue Type: Bug

[GitHub] flink pull request #5520: [FLINK-8599] Improve the failure behavior of the F...

Github user ChengzhiZhao closed the pull request at: https://github.com/apache/flink/pull/5520 ---

[jira] [Commented] (FLINK-8599) Improve the failure behavior of the FileInputFormat for bad files

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

[jira] [Assigned] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS

[ https://issues.apache.org/jira/browse/FLINK-8684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8684: --- Assignee: Chesnay Schepler > Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS

[jira] [Assigned] (FLINK-8689) Add runtime support of distinct filter using MapView for GenerateAggregation

[ https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-8689: Assignee: Rong Rong > Add runtime support of distinct filter using MapView for GenerateAggregation

[jira] [Assigned] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-8690: Assignee: Rong Rong > Update logical rule set to generate FlinkLogicalAggregate explicitly allow

[jira] [Created] (FLINK-8691) Update table API to support distinct operator on data stream

Rong Rong created FLINK-8691: Summary: Update table API to support distinct operator on data stream Key: FLINK-8691 URL: https://issues.apache.org/jira/browse/FLINK-8691 Project: Flink Issue

[jira] [Created] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator

Rong Rong created FLINK-8690: Summary: Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator Key: FLINK-8690 URL: https://issues.apache.org/jira/browse/FLINK-8690

[jira] [Created] (FLINK-8689) Add runtime support of distinct filter using MapView for GenerateAggregation

Rong Rong created FLINK-8689: Summary: Add runtime support of distinct filter using MapView for GenerateAggregation Key: FLINK-8689 URL: https://issues.apache.org/jira/browse/FLINK-8689 Project: Flink

[jira] [Commented] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API

[ https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368585#comment-16368585 ] Rong Rong commented on FLINK-8688: -- Related distinct aggregate feature request JIRA > Enable distinct

[jira] [Updated] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API

[ https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8688: - Description: Distinct aggregation is not currently supported on data stream with Table/SQL API. This is

[jira] [Updated] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API

[ https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8688: - Description: Distinct aggregation is not currently supported on data stream with Table/SQL API. This is

[jira] [Created] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API

Rong Rong created FLINK-8688: Summary: Enable distinct aggregation for data stream on Table/SQL API Key: FLINK-8688 URL: https://issues.apache.org/jira/browse/FLINK-8688 Project: Flink Issue

[jira] [Commented] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS

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

[GitHub] flink pull request #5519: [FLINK-8684] [config] Rework MesosTaskManagerParam...

Github user zhangminglei closed the pull request at: https://github.com/apache/flink/pull/5519 ---

[jira] [Commented] (FLINK-8599) Improve the failure behavior of the FileInputFormat for bad files

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

[GitHub] flink pull request #5520: [FLINK-8599] Improve the failure behavior of the F...

GitHub user ChengzhiZhao opened a pull request: https://github.com/apache/flink/pull/5520 [FLINK-8599] Improve the failure behavior of the FileInputFormat for bad files ## What is the purpose of the change This pull request is intent to improve the failure behavior of the

[jira] [Updated] (FLINK-8599) Improve the failure behavior of the FileInputFormat for bad files

[ https://issues.apache.org/jira/browse/FLINK-8599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengzhi Zhao updated FLINK-8599: - Summary: Improve the failure behavior of the FileInputFormat for bad files (was: Improve the

[jira] [Commented] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6

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

[jira] [Commented] (FLINK-8614) Enable Flip-6 per default

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

[jira] [Commented] (FLINK-8673) Don't let JobManagerRunner shut down itself

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

[jira] [Commented] (FLINK-8653) Remove slot request timeout from SlotPool

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

[GitHub] flink pull request #5437: [FLINK-8614] [flip6] Activate Flip-6 mode per defa...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5437 ---

[GitHub] flink pull request #5483: [FLINK-8653] [flip6] Remove internal slot request ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5483 ---

[jira] [Closed] (FLINK-8673) Don't let JobManagerRunner shut down itself

[ https://issues.apache.org/jira/browse/FLINK-8673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8673. Resolution: Fixed Fixed via 075f5b6930b86e110a32e290229b9800be72a3a7 > Don't let JobManagerRunner

[jira] [Closed] (FLINK-8614) Enable Flip-6 per default

[ https://issues.apache.org/jira/browse/FLINK-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8614. Resolution: Fixed Fixed via ab8316f31a4de0648ab3ffa9f19fcd419aaa3bb9 > Enable Flip-6 per default >

[GitHub] flink pull request #5510: [FLINK-8673] [flip6] Use JobManagerRunner#resultFu...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5510 ---

[GitHub] flink pull request #5444: [FLINK-8546] [flip6] Respect savepoints and restor...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5444 ---

[jira] [Closed] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6

[ https://issues.apache.org/jira/browse/FLINK-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8546. Resolution: Fixed Fixed via 3a4e89643d7d7642dde9b5644491f261d4d545bd > Respect savepoint settings

[jira] [Closed] (FLINK-8653) Remove slot request timeout from SlotPool

[ https://issues.apache.org/jira/browse/FLINK-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8653. Resolution: Fixed Fixed via d8a8866973f7e0463047963e6b242cdc2cb82fec > Remove slot request timeout

[jira] [Commented] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS

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

[GitHub] flink issue #5519: [FLINK-8684] [config] Rework MesosTaskManagerParameters#M...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5519 Correct, I've included a fix for FLINK-8684 in the [PR](https://github.com/apache/flink/pull/5515) for FLINK-8683. ---

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

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

[GitHub] flink pull request #5174: [FLINK-8274][TableAPI & SQL] Fix Java 64K method c...

Github user jahandarm commented on a diff in the pull request: https://github.com/apache/flink/pull/5174#discussion_r168942867 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CalcWithSplitCodeGenITCase.scala --- @@ -0,0 +1,385 @@