[jira] [Updated] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

2019-01-31 Thread eugen yushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] eugen yushin updated FLINK-10167: - Affects Version/s: 1.7.1 > SessionWindows not compatible with typed DataStreams in scala > -

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

2019-01-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757113#comment-16757113 ] Dawid Wysakowicz commented on FLINK-11447: -- Hi [~hequn8128], We thought about t

[jira] [Created] (FLINK-11487) Support for writing data to Apache Flume

2019-01-31 Thread ambition (JIRA)
ambition created FLINK-11487: Summary: Support for writing data to Apache Flume Key: FLINK-11487 URL: https://issues.apache.org/jira/browse/FLINK-11487 Project: Flink Issue Type: New Feature

[GitHub] zentol commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#discussion_r252615174 ## File path: flink-libraries/flink-table/pom.xml ## @@ -267,6 +250,8 @@ under the License.

[jira] [Updated] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11389: -- Fix Version/s: 1.8.0 1.6.4 > Incorrectly use job information when call getS

[jira] [Updated] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11389: -- Priority: Major (was: Minor) > Incorrectly use job information when call getSerializedTaskInf

[jira] [Updated] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11389: -- Affects Version/s: 1.8.0 1.6.3 1.7.1 > Incorrect

[jira] [Closed] (FLINK-11219) Upgrade Jackson dependency to 2.9.6

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11219. Resolution: Won't Fix > Upgrade Jackson dependency to 2.9.6 >

[GitHub] tillrohrmann commented on issue #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
tillrohrmann commented on issue #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7606#issuecomment-459299615 Failing test case is unrelated. --

[GitHub] asfgit merged pull request #7614: [BP-1.7][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
asfgit merged pull request #7614: [BP-1.7][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7614 This is an automated message from the Apache

[GitHub] asfgit closed pull request #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
asfgit closed pull request #7606: [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7606 This is an automated message from the Apache Git Ser

[GitHub] asfgit merged pull request #7615: [BP-1.6][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase

2019-01-31 Thread GitBox
asfgit merged pull request #7615: [BP-1.6][FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase URL: https://github.com/apache/flink/pull/7615 This is an automated message from the Apache

[jira] [Resolved] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10774. --- Resolution: Fixed Fix Version/s: 1.8.0 1.7.2 1.6

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757126#comment-16757126 ] Timo Walther commented on FLINK-11447: -- Thanks for joining the discussion [~hequn81

[jira] [Assigned] (FLINK-3414) Add Scala DSL for CEP's pattern definition

2019-01-31 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-3414: --- Assignee: (was: Dawid Wysakowicz) > Add Scala DSL for CEP's pattern definition >

[GitHub] ambition119 opened a new pull request #7618: [FLINK-11487] Support for writing data to Apache Flume

2019-01-31 Thread GitBox
ambition119 opened a new pull request #7618: [FLINK-11487] Support for writing data to Apache Flume URL: https://github.com/apache/flink/pull/7618 ## What is the purpose of the change This pull request corresponds to a [FLINK-11487](https://issues.apache.org/jira/browse/FLINK-11487)

[GitHub] tillrohrmann merged pull request #7591: [FLINK-11412] [mesos] Remove legacy MesosFlinkResourceManager

2019-01-31 Thread GitBox
tillrohrmann merged pull request #7591: [FLINK-11412] [mesos] Remove legacy MesosFlinkResourceManager URL: https://github.com/apache/flink/pull/7591 This is an automated message from the Apache Git Service. To respond to the

[jira] [Resolved] (FLINK-11412) Remove legacy MesosFlinkResourceManager

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11412. --- Resolution: Fixed Fixed via https://github.com/apache/flink/commit/a43d3c85884de1f45d4884b2

[jira] [Assigned] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10774: - Assignee: Till Rohrmann (was: Steven Zhen Wu) > connection leak when partition discove

[jira] [Updated] (FLINK-11487) Support for writing data to Apache Flume

2019-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11487: --- Labels: pull-request-available (was: ) > Support for writing data to Apache Flume > ---

[GitHub] zentol merged pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests

2019-01-31 Thread GitBox
zentol merged pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler from valid tests URL: https://github.com/apache/flink/pull/7303 This is an automated message from the Apache Git Service. To respond to the message

[GitHub] aljoscha commented on issue #7601: [FLINK-11164] Check for sentinel values when creating new Kinesis ShardIterator

2019-01-31 Thread GitBox
aljoscha commented on issue #7601: [FLINK-11164] Check for sentinel values when creating new Kinesis ShardIterator URL: https://github.com/apache/flink/pull/7601#issuecomment-459305252 I refactored this some more. PTAL. 😄 Th

[jira] [Commented] (FLINK-10569) Clean up uses of Scheduler and Instance in valid tests

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757136#comment-16757136 ] Chesnay Schepler commented on FLINK-10569: -- First batch: master: 568d90cf0b718f

[jira] [Comment Edited] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757126#comment-16757126 ] Timo Walther edited comment on FLINK-11447 at 1/31/19 10:59 AM: --

[jira] [Assigned] (FLINK-11395) Support for Avro StreamingFileSink

2019-01-31 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11395: Assignee: vinoyang > Support for Avro StreamingFileSink > -- > >

[GitHub] mxm commented on issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTrigger

2019-01-31 Thread GitBox
mxm commented on issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTrigger URL: https://github.com/apache/flink/pull/2671#issuecomment-459312479 Thanks for writing down your findings! This is an automated mes

[GitHub] zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter URL: https://github.com/apache/flink/pull/7582#discussion_r252625470 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics

[GitHub] zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter URL: https://github.com/apache/flink/pull/7582#discussion_r252625671 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics

[GitHub] zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter URL: https://github.com/apache/flink/pull/7582#discussion_r252626021 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics

[GitHub] zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter URL: https://github.com/apache/flink/pull/7582#discussion_r252639049 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics

[GitHub] zentol merged pull request #7608: FLINK-11473 [documentation][ Clarify documenation on Latency Tracking

2019-01-31 Thread GitBox
zentol merged pull request #7608: FLINK-11473 [documentation][ Clarify documenation on Latency Tracking URL: https://github.com/apache/flink/pull/7608 This is an automated message from the Apache Git Service. To respond to t

[jira] [Updated] (FLINK-11473) Clarify Documenation on Latency Tracking

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11473: - Component/s: Metrics > Clarify Documenation on Latency Tracking > --

[jira] [Closed] (FLINK-11473) Clarify Documenation on Latency Tracking

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11473. Resolution: Fixed Fix Version/s: 1.8.0 1.7.2 master: 999a04d21c6

[GitHub] zentol commented on a change in pull request #7385: [hotfix]Fix some logging statements which can not correctly record the behaviors

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7385: [hotfix]Fix some logging statements which can not correctly record the behaviors URL: https://github.com/apache/flink/pull/7385#discussion_r252642344 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/Job

[GitHub] zentol commented on a change in pull request #7385: [hotfix]Fix some logging statements which can not correctly record the behaviors

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7385: [hotfix]Fix some logging statements which can not correctly record the behaviors URL: https://github.com/apache/flink/pull/7385#discussion_r252642377 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailabil

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

2019-01-31 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757178#comment-16757178 ] Hequn Cheng commented on FLINK-11445: - [~twalthr] Oops, forgot it. Thanks for the re

[jira] [Created] (FLINK-11488) Merge a basic Blink planner framework

2019-01-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11488: Summary: Merge a basic Blink planner framework Key: FLINK-11488 URL: https://issues.apache.org/jira/browse/FLINK-11488 Project: Flink Issue Type: Sub-task

[GitHub] StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make access to ExecutionGraph single threaded from JobMaster main thread

2019-01-31 Thread GitBox
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make access to ExecutionGraph single threaded from JobMaster main thread URL: https://github.com/apache/flink/pull/7568#discussion_r252648234 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime

[GitHub] libenchao opened a new pull request #7619: [hotfix] [javadocs] Fix typo in TaskSlot

2019-01-31 Thread GitBox
libenchao opened a new pull request #7619: [hotfix] [javadocs] Fix typo in TaskSlot URL: https://github.com/apache/flink/pull/7619 Fix typo in TaskSlot. This is an automated message from the Apache Git Service. To respond to

[GitHub] libenchao opened a new pull request #7620: [hotfix] [javadocs] Correct outdated doc for TaskSlotTable.start()

2019-01-31 Thread GitBox
libenchao opened a new pull request #7620: [hotfix] [javadocs] Correct outdated doc for TaskSlotTable.start() URL: https://github.com/apache/flink/pull/7620 Correct outdated doc for `TaskSlotTable.start()`. This is an automat

[GitHub] dawidwys merged pull request #7619: [hotfix] [javadocs] Fix typo in TaskSlot

2019-01-31 Thread GitBox
dawidwys merged pull request #7619: [hotfix] [javadocs] Fix typo in TaskSlot URL: https://github.com/apache/flink/pull/7619 This is an automated message from the Apache Git Service. To respond to the message, please log on Gi

[GitHub] zentol commented on issue #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

2019-01-31 Thread GitBox
zentol commented on issue #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#issuecomment-459331867 @knaufk That's a bug in 1.7.0-1.7.1, see [FLINK-11251](https://issues.apache.org/jira/browse/FLINK-11251). @1u0 The mocks

[jira] [Updated] (FLINK-11488) Merge a basic Blink planner framework

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11488: - Description: A more detailed description can be found in [FLIP-32|https://cwiki.apache.org/conf

[jira] [Closed] (FLINK-11384) Remove legacy MesosTaskManager

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11384. Resolution: Fixed master: 119128fb1d05ab5b9539a00fe1c381e8af4a7304 > Remove legacy MesosT

[jira] [Created] (FLINK-11490) Add an initial batch runtime

2019-01-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11490: Summary: Add an initial batch runtime Key: FLINK-11490 URL: https://issues.apache.org/jira/browse/FLINK-11490 Project: Flink Issue Type: Sub-task C

[jira] [Updated] (FLINK-11369) Remove ZooKeeperHAJobManagerTest

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11369: - Summary: Remove ZooKeeperHAJobManagerTest (was: Check and port ZooKeeperHAJobManagerTes

[jira] [Updated] (FLINK-11488) Add a basic Blink planner framework

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11488: - Summary: Add a basic Blink planner framework (was: Merge a basic Blink planner framework) > Ad

[jira] [Updated] (FLINK-11490) Add an initial Blink batch runtime

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11490: - Summary: Add an initial Blink batch runtime (was: Add an initial batch runtime) > Add an initi

[GitHub] zentol merged pull request #7592: [FLINK-11369] [tests] Remove invalid tests ZooKeeperHAJobManagerTest

2019-01-31 Thread GitBox
zentol merged pull request #7592: [FLINK-11369] [tests] Remove invalid tests ZooKeeperHAJobManagerTest URL: https://github.com/apache/flink/pull/7592 This is an automated message from the Apache Git Service. To respond to th

[jira] [Created] (FLINK-11489) Add an initial Blink streaming runtime

2019-01-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11489: Summary: Add an initial Blink streaming runtime Key: FLINK-11489 URL: https://issues.apache.org/jira/browse/FLINK-11489 Project: Flink Issue Type: Sub-task

[GitHub] zentol merged pull request #7531: [FLINK-11384] [mesos] Remove legacy MesosTaskManager

2019-01-31 Thread GitBox
zentol merged pull request #7531: [FLINK-11384] [mesos] Remove legacy MesosTaskManager URL: https://github.com/apache/flink/pull/7531 This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Closed] (FLINK-11369) Remove ZooKeeperHAJobManagerTest

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11369. Resolution: Fixed Fix Version/s: 1.8.0 master: 4facd91ccd0eaafde6c71641e4e1dd2b4d4b

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252657912 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252658478 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252660110 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252659991 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252660356 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252658296 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base

2019-01-31 Thread GitBox
zentol commented on a change in pull request #7600: [FLINK-11368][tests] Port TaskManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7600#discussion_r252659746 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunn

[GitHub] zentol merged pull request #7577: [FLINK-11365] Remove legacy TaskManagerFailureRecoveryITCase

2019-01-31 Thread GitBox
zentol merged pull request #7577: [FLINK-11365] Remove legacy TaskManagerFailureRecoveryITCase URL: https://github.com/apache/flink/pull/7577 This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Created] (FLINK-11492) Support the full Blink SQL runtime

2019-01-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11492: Summary: Support the full Blink SQL runtime Key: FLINK-11492 URL: https://issues.apache.org/jira/browse/FLINK-11492 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-11365) Check and port TaskManagerFailureRecoveryITCase to new code base if necessary

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11365. Resolution: Fixed Fix Version/s: 1.8.0 master: 7b6f2f487511d3766089ecd495597440f8a4

[jira] [Updated] (FLINK-11490) Add an initial Blink SQL batch runtime

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11490: - Summary: Add an initial Blink SQL batch runtime (was: Add an initial Blink batch runtime) > Ad

[jira] [Created] (FLINK-11491) Support all TPC-DS queries

2019-01-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11491: Summary: Support all TPC-DS queries Key: FLINK-11491 URL: https://issues.apache.org/jira/browse/FLINK-11491 Project: Flink Issue Type: Sub-task Com

[jira] [Updated] (FLINK-11491) Support all TPC-DS queries

2019-01-31 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-11491: --- Description: A more detailed description can be found in [FLIP-32|https://cwiki.apache.org/

[GitHub] kl0u commented on issue #7588: [FLINK-11419][filesystem] For recovery, wait until lease is revoked before truncate file

2019-01-31 Thread GitBox
kl0u commented on issue #7588: [FLINK-11419][filesystem] For recovery, wait until lease is revoked before truncate file URL: https://github.com/apache/flink/pull/7588#issuecomment-459341982 Thanks for the work @EAlexRojas . I will merge as soon as Travis gives green. --

[GitHub] zentol merged pull request #7530: [FLINK-11385] [mesos] Remove legacy MesosJobManager

2019-01-31 Thread GitBox
zentol merged pull request #7530: [FLINK-11385] [mesos] Remove legacy MesosJobManager URL: https://github.com/apache/flink/pull/7530 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-11489) Add an initial Blink SQL streaming runtime

2019-01-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11489: - Summary: Add an initial Blink SQL streaming runtime (was: Add an initial Blink streaming runtim

[jira] [Closed] (FLINK-11385) Remove legacy MesosJobManager

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11385. Resolution: Fixed master: 6e25b0c79138fd96e50afbd3ce4c5b2bf59e2245 > Remove legacy MesosJ

[GitHub] tillrohrmann merged pull request #7617: [FLINK-11380][tests] Finish mocking of resourceManagerClient before using it

2019-01-31 Thread GitBox
tillrohrmann merged pull request #7617: [FLINK-11380][tests] Finish mocking of resourceManagerClient before using it URL: https://github.com/apache/flink/pull/7617 This is an automated message from the Apache Git Service. To

[GitHub] tillrohrmann commented on issue #7617: [FLINK-11380][tests] Finish mocking of resourceManagerClient before using it

2019-01-31 Thread GitBox
tillrohrmann commented on issue #7617: [FLINK-11380][tests] Finish mocking of resourceManagerClient before using it URL: https://github.com/apache/flink/pull/7617#issuecomment-459343747 Thanks for the review @zentol. Test failure is unrelated. Merging. -

[jira] [Resolved] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11380. --- Resolution: Fixed Fixed via https://github.com/apache/flink/commit/c68bb9efb04bf518b776c70f

[GitHub] tillrohrmann merged pull request #7620: [hotfix] [javadocs] Correct outdated doc for TaskSlotTable.start()

2019-01-31 Thread GitBox
tillrohrmann merged pull request #7620: [hotfix] [javadocs] Correct outdated doc for TaskSlotTable.start() URL: https://github.com/apache/flink/pull/7620 This is an automated message from the Apache Git Service. To respond t

[jira] [Created] (FLINK-11493) Finalize the Blink SQL merging efforts

2019-01-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11493: Summary: Finalize the Blink SQL merging efforts Key: FLINK-11493 URL: https://issues.apache.org/jira/browse/FLINK-11493 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11380: -- Issue Type: Bug (was: Test) > YarnFlinkResourceManagerTest test case crashed > -

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2019-01-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757236#comment-16757236 ] Till Rohrmann commented on FLINK-9920: -- Another instance: https://api.travis-ci.org/

[GitHub] sjwiesman commented on issue #7618: [FLINK-11487] Support for writing data to Apache Flume

2019-01-31 Thread GitBox
sjwiesman commented on issue #7618: [FLINK-11487] Support for writing data to Apache Flume URL: https://github.com/apache/flink/pull/7618#issuecomment-459348021 Not sure if you are aware but there is already a flink connector for flume in Apache Bahir[1]. It might make more sense to consol

[jira] [Created] (FLINK-11494) Remove legacy WebRuntimeMonitor

2019-01-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11494: Summary: Remove legacy WebRuntimeMonitor Key: FLINK-11494 URL: https://issues.apache.org/jira/browse/FLINK-11494 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-11494) Remove legacy WebRuntimeMonitor

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11494: Assignee: Chesnay Schepler > Remove legacy WebRuntimeMonitor > --

[jira] [Assigned] (FLINK-11495) Remove legacy job archiving paths

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11495: Assignee: Chesnay Schepler > Remove legacy job archiving paths >

[GitHub] zentol commented on issue #7574: [hotfix] [docs] Fix wrong port in docs for Kubernetes Setup

2019-01-31 Thread GitBox
zentol commented on issue #7574: [hotfix] [docs] Fix wrong port in docs for Kubernetes Setup URL: https://github.com/apache/flink/pull/7574#issuecomment-459353101 I wouldn't call the port "wrong". The TaskManager does not have to use the same port as the JobManager. --

[jira] [Created] (FLINK-11495) Remove legacy job archiving paths

2019-01-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11495: Summary: Remove legacy job archiving paths Key: FLINK-11495 URL: https://issues.apache.org/jira/browse/FLINK-11495 Project: Flink Issue Type: Sub-tas

[jira] [Updated] (FLINK-11079) Skip deployment for flnk-storm-examples

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11079: - Issue Type: Improvement (was: Bug) > Skip deployment for flnk-storm-examples >

[jira] [Closed] (FLINK-11207) Update Apache commons-compress from 1.4.1 to 1.18

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11207. Resolution: Fixed > Update Apache commons-compress from 1.4.1 to 1.18 > --

[jira] [Reopened] (FLINK-11207) Update Apache commons-compress from 1.4.1 to 1.18

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11207: -- > Update Apache commons-compress from 1.4.1 to 1.18 >

[jira] [Updated] (FLINK-11207) Update Apache commons-compress from 1.4.1 to 1.18

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11207: - Issue Type: Improvement (was: Bug) > Update Apache commons-compress from 1.4.1 to 1.18

[jira] [Updated] (FLINK-11423) Keep exception message thrown from the main class

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11423: - Summary: Keep exception message thrown from the main class (was: Propagate the error m

[jira] [Reopened] (FLINK-11079) Skip deployment for flnk-storm-examples

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11079: -- > Skip deployment for flnk-storm-examples > --- > >

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

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11160: - Fix Version/s: (was: 1.7.2) (was: 1.8.0) > Confluent Avro Ser

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

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11160: -- > Confluent Avro Serialization Schema > > >

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

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11160. Resolution: Duplicate > Confluent Avro Serialization Schema > ---

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

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11160: -- > Confluent Avro Serialization Schema > > >

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

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11160: - Release Note: (was: Added Serialization Schema to work with the Confluent Avro format

[jira] [Closed] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11023. Resolution: Fixed > Update LICENSE and NOTICE files for flink-connectors > ---

[jira] [Updated] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11023: - Issue Type: Improvement (was: Bug) > Update LICENSE and NOTICE files for flink-connecto

[jira] [Updated] (FLINK-11145) Fix Hadoop version handling in binary release script

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11145: - Issue Type: Bug (was: Improvement) > Fix Hadoop version handling in binary release scri

[jira] [Reopened] (FLINK-11145) Fix Hadoop version handling in binary release script

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11145: -- > Fix Hadoop version handling in binary release script > -

[jira] [Closed] (FLINK-11079) Skip deployment for flnk-storm-examples

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11079. Resolution: Fixed > Skip deployment for flnk-storm-examples >

[jira] [Reopened] (FLINK-11423) Propagate the error message from Main method to JarRunHandler

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11423: -- > Propagate the error message from Main method to JarRunHandler >

[jira] [Closed] (FLINK-11423) Keep exception message thrown from the main class

2019-01-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11423. Resolution: Fixed > Keep exception message thrown from the main class > -

<    1   2   3   4   >