[jira] [Commented] (FLINK-11067) Port TableEnvironments to Java

2018-12-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721116#comment-16721116 ] sunjincheng commented on FLINK-11067: - It meant that we move `TableEnvironment ` fro

[jira] [Assigned] (FLINK-10615) Cancel with savepoint can fail the job

2018-12-14 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10615: --- Assignee: (was: boshu Zheng) > Cancel with savepoint can fail the job > ---

[GitHub] tillrohrmann commented on a change in pull request #7295: [FLINK-10748] Decouple RestServerEndpoint from Dispatcher

2018-12-14 Thread GitBox
tillrohrmann commented on a change in pull request #7295: [FLINK-10748] Decouple RestServerEndpoint from Dispatcher URL: https://github.com/apache/flink/pull/7295#discussion_r241691330 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/LeaderRetrieval

[GitHub] tillrohrmann commented on a change in pull request #7295: [FLINK-10748] Decouple RestServerEndpoint from Dispatcher

2018-12-14 Thread GitBox
tillrohrmann commented on a change in pull request #7295: [FLINK-10748] Decouple RestServerEndpoint from Dispatcher URL: https://github.com/apache/flink/pull/7295#discussion_r241691227 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/LeaderRetrievalHa

[GitHub] tillrohrmann commented on a change in pull request #7295: [FLINK-10748] Decouple RestServerEndpoint from Dispatcher

2018-12-14 Thread GitBox
tillrohrmann commented on a change in pull request #7295: [FLINK-10748] Decouple RestServerEndpoint from Dispatcher URL: https://github.com/apache/flink/pull/7295#discussion_r241690213 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/LeaderRetrieval

[jira] [Commented] (FLINK-9569) Confusing construction of AvroSerializers for generic records

2018-12-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721077#comment-16721077 ] Tzu-Li (Gordon) Tai commented on FLINK-9569: [~dawidwys] this can be closed.

[jira] [Commented] (FLINK-9569) Confusing construction of AvroSerializers for generic records

2018-12-14 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721064#comment-16721064 ] Dawid Wysakowicz commented on FLINK-9569: - [~tzulitai] is it still relevant or sh

[jira] [Updated] (FLINK-11166) Slot Placement Constraint

2018-12-14 Thread Tony Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tony Xintong Song updated FLINK-11166: -- Description: In many cases, users may want Flink to schedule their job tasks following

[jira] [Closed] (FLINK-9569) Confusing construction of AvroSerializers for generic records

2018-12-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9569. -- Resolution: Won't Fix > Confusing construction of AvroSerializers for generic records >

[jira] [Commented] (FLINK-11160) Confluent Avro Serialization Schema

2018-12-14 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721067#comment-16721067 ] Dawid Wysakowicz commented on FLINK-11160: -- Hi [~Zhen-hao], Welcome to the Flin

[jira] [Commented] (FLINK-11166) Slot Placement Constraint

2018-12-14 Thread Tony Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721074#comment-16721074 ] Tony Xintong Song commented on FLINK-11166: --- Hi [~till.rohrmann], I'd like to

[jira] [Created] (FLINK-11166) Slot Placement Constraint

2018-12-14 Thread Tony Xintong Song (JIRA)
Tony Xintong Song created FLINK-11166: - Summary: Slot Placement Constraint Key: FLINK-11166 URL: https://issues.apache.org/jira/browse/FLINK-11166 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-11160) Confluent Avro Serialization Schema

2018-12-14 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-11160. Resolution: Duplicate > Confluent Avro Serialization Schema > ---

[jira] [Commented] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

2018-12-14 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721051#comment-16721051 ] TisonKun commented on FLINK-6626: - It sounds reasonable. {{Dispacther}} has the write bi

[jira] [Updated] (FLINK-11164) Refreshing expired shard iterator fails if no records were retrieved from shard since ShardConsumer was started in FlinkKinesisConsumer

2018-12-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11164: Description: Originally reported by: [http://apache-flink-user-mailing-list-archi

[jira] [Updated] (FLINK-11164) Refreshing expired shard iterator fails if no records were retrieved from shard since ShardConsumer was started in FlinkKinesisConsumer

2018-12-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11164: Description: Originally reported by: [http://apache-flink-user-mailing-list-archi

[jira] [Created] (FLINK-11165) Refine the deploying log for easier finding of task locations

2018-12-14 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-11165: --- Summary: Refine the deploying log for easier finding of task locations Key: FLINK-11165 URL: https://issues.apache.org/jira/browse/FLINK-11165 Project: Flink Issue Ty

[jira] [Created] (FLINK-11164) Refreshing expired shard iterator fails if no records were retrieved from shard since ShardConsumer was started in FlinkKinesisConsumer

2018-12-14 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11164: --- Summary: Refreshing expired shard iterator fails if no records were retrieved from shard since ShardConsumer was started in FlinkKinesisConsumer Key: FLINK-11164 UR

<    1   2