[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546411#comment-16546411 ] ASF GitHub Bot commented on FLINK-9852: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202980228 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableUtil.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546407#comment-16546407 ] ASF GitHub Bot commented on FLINK-9852: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202978881 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -18,33 +18,299 @@ package

[GitHub] flink issue #6347: [hotfix] consistency: vertexes -> vertices

2018-07-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6347 yes ---

[GitHub] flink issue #6347: [hotfix] consistency: vertexes -> vertices

2018-07-17 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6347 > Additionally this PR makes a lot of whitespace changes that should be reverted in any case. did you mean the whitespace in comment `* ` is significant? ---

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546399#comment-16546399 ] ASF GitHub Bot commented on FLINK-9852: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202977464 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -18,33 +18,299 @@ package

[jira] [Commented] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546392#comment-16546392 ] Chesnay Schepler commented on FLINK-8163: - This test has some funky retrying logic that ignores

[jira] [Closed] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8163. --- Resolution: Cannot Reproduce This test has some funky retrying logic that ignores >

[jira] [Reopened] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8163: - > NonHAQueryableStateFsBackendITCase test getting stuck on Travis >

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546369#comment-16546369 ] ASF GitHub Bot commented on FLINK-9792: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546368#comment-16546368 ] ASF GitHub Bot commented on FLINK-9792: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r202970121 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r202969620 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-9873) Log actual state when aborting checkpoint due to task not running

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9873: Affects Version/s: (was: 1.5.1) 1.5.0 > Log actual state when

[jira] [Updated] (FLINK-9792) Cannot add html tags in options description

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9792: Affects Version/s: (was: 1.5.1) 1.5.0 > Cannot add html tags in

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546325#comment-16546325 ] ASF GitHub Bot commented on FLINK-9013: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6294#discussion_r202968456 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/TextElement.java --- @@ -53,6 +55,16 @@ public static TextElement text(String

[jira] [Commented] (FLINK-9792) Cannot add html tags in options description

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546321#comment-16546321 ] ASF GitHub Bot commented on FLINK-9792: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #6312: [FLINK-9792] Added custom Description class for Co...

2018-07-17 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6312#discussion_r202967561 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlFormatter.java --- @@ -0,0 +1,67 @@ +/* + * Licensed to the

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202966706 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/BatchTableDescriptor.scala --- @@ -0,0 +1,126 @@ +/* + *

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546310#comment-16546310 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546311#comment-16546311 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546318#comment-16546318 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546316#comment-16546316 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546315#comment-16546315 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202963074 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableUtil.scala --- @@ -0,0 +1,148 @@ +/* + *

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546314#comment-16546314 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546307#comment-16546307 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202964290 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableUtil.scala --- @@ -0,0 +1,148 @@ +/* + *

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546313#comment-16546313 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546309#comment-16546309 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546317#comment-16546317 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202923853 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -18,33 +18,299 @@

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202915534 --- Diff: flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/EnvironmentTest.java --- @@ -40,10 +41,18 @@

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546312#comment-16546312 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202964715 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchematicDescriptor.scala --- @@ -19,14 +19,17 @@ package

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202966786 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/CsvAppendTableSinkFactory.scala --- @@ -0,0 +1,52 @@ +/* + *

[jira] [Commented] (FLINK-9852) Expose descriptor-based sink creation in table environments

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546308#comment-16546308 ] ASF GitHub Bot commented on FLINK-9852: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202965391 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/StreamTableDescriptor.scala --- @@ -0,0 +1,182 @@ +/* + *

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202964952 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/StreamTableDescriptor.scala --- @@ -0,0 +1,182 @@ +/* + *

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202965060 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/BatchTableDescriptor.scala --- @@ -0,0 +1,126 @@ +/* + *

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202963234 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableUtil.scala --- @@ -0,0 +1,148 @@ +/* + *

[GitHub] flink pull request #6343: [FLINK-9852] [table] Expose descriptor-based sink ...

2018-07-17 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6343#discussion_r202961529 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -18,33 +18,299 @@

[jira] [Updated] (FLINK-9862) Update end-to-end test to use RocksDB backed timers

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9862: -- Labels: pull-request-available (was: ) > Update end-to-end test to use RocksDB backed timers

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546302#comment-16546302 ] ASF GitHub Bot commented on FLINK-9013: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #6294: [FLINK-9013][docs] Document yarn.containers.vcores only b...

2018-07-17 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6294 I've rebased it on top of rich formatting feature for documentation, therefore only the last commit applies to the issue. I will also check the `DominantResourceCalculator` once again.

[jira] [Commented] (FLINK-9862) Update end-to-end test to use RocksDB backed timers

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546301#comment-16546301 ] ASF GitHub Bot commented on FLINK-9862: --- GitHub user tzulitai opened a pull request:

[jira] [Reopened] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8163: - Assignee: Chesnay Schepler (was: Kostas Kloudas) just got a timeout locally >

[GitHub] flink pull request #6351: [FLINK-9862] [test] Extend general puropose DataSt...

2018-07-17 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/6351 [FLINK-9862] [test] Extend general puropose DataStream test to have a tumbling window ## What is the purpose of the change This allows our end-to-end tests to have coverage for

[jira] [Closed] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8163. --- Resolution: Cannot Reproduce No occurrence was reported since the linked PR was merged. >

[jira] [Updated] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8163: Fix Version/s: (was: 1.5.2) (was: 1.6.0) >

[GitHub] flink pull request #6350: [FLINK-9873][runtime] Log task state when aborting...

2018-07-17 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6350#discussion_r202962522 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -457,13 +457,20 @@ public

[jira] [Updated] (FLINK-9872) SavepointITCase#testSavepointForJobWithIteration does not properly cancel jobs

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9872: Summary: SavepointITCase#testSavepointForJobWithIteration does not properly cancel jobs

[jira] [Commented] (FLINK-9873) Log actual state when aborting checkpoint due to task not running

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546290#comment-16546290 ] ASF GitHub Bot commented on FLINK-9873: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9873) Log actual state when aborting checkpoint due to task not running

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546287#comment-16546287 ] ASF GitHub Bot commented on FLINK-9873: --- GitHub user zentol opened a pull request:

[jira] [Updated] (FLINK-9873) Log actual state when aborting checkpoint due to task not running

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9873: -- Labels: pull-request-available (was: ) > Log actual state when aborting checkpoint due to

[GitHub] flink pull request #6350: [FLINK-9873][runtime] Log task state when aborting...

2018-07-17 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6350 [FLINK-9873][runtime] Log task state when aborting checkpoint ## What is the purpose of the change This PR adjusts the logging message for when a checkpoint is declined due to tasks not

[jira] [Created] (FLINK-9873) Log actual state when aborting checkpoint due to task not running

2018-07-17 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9873: --- Summary: Log actual state when aborting checkpoint due to task not running Key: FLINK-9873 URL: https://issues.apache.org/jira/browse/FLINK-9873 Project: Flink

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546283#comment-16546283 ] ASF GitHub Bot commented on FLINK-6997: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #6349: [FLINK-6997][tests] Properly cancel test job

2018-07-17 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6349 [FLINK-6997][tests] Properly cancel test job ## What is the purpose of the change With this PR the jobs started in `SavepointITCase#testSavepointForJobWithIteration` are properly canceled.

[jira] [Created] (FLINK-9872) SavepointITCase#testSavepointForJobWithIteration does not properly cancell jobs

2018-07-17 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9872: --- Summary: SavepointITCase#testSavepointForJobWithIteration does not properly cancell jobs Key: FLINK-9872 URL: https://issues.apache.org/jira/browse/FLINK-9872

[jira] [Updated] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6997: Fix Version/s: (was: 1.5.2) (was: 1.6.0) > SavepointITCase

[jira] [Closed] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6997. --- Resolution: Cannot Reproduce > SavepointITCase fails in master branch sometimes >

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546270#comment-16546270 ] Chesnay Schepler commented on FLINK-8101: - [~sharju] no, this Jira will not be fixed for 1.6. >

[jira] [Updated] (FLINK-8101) Elasticsearch 6.x support

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8101: Fix Version/s: (was: 1.6.0) 1.7.0 > Elasticsearch 6.x support >

[GitHub] flink issue #6347: [hotfix] consistency: vertexes -> vertices

2018-07-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6347 `vertices` is the correct plural, but this is another one of those cases where fixing it might cause more harm than good since it could cause merge conflicts, yet provides no functional benefit.

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546262#comment-16546262 ] Chesnay Schepler commented on FLINK-6997: - Either we're dealing with 2 separate issues here or

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

2018-07-17 Thread Sami Harju (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546246#comment-16546246 ] Sami Harju commented on FLINK-8101: --- Hi, any updates to this? Are we getting ES 6 support in 1.6? >

[jira] [Created] (FLINK-9871) Use Description class for ConfigOptions with rich formatting

2018-07-17 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9871: --- Summary: Use Description class for ConfigOptions with rich formatting Key: FLINK-9871 URL: https://issues.apache.org/jira/browse/FLINK-9871 Project: Flink

[jira] [Reopened] (FLINK-9669) Introduce task manager assignment store

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-9669: - Reopen to remove fixVersion > Introduce task manager assignment store >

[jira] [Closed] (FLINK-9669) Introduce task manager assignment store

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9669. --- Resolution: Invalid Fix Version/s: (was: 1.5.1) > Introduce task manager

[jira] [Closed] (FLINK-9670) Introduce slot manager factory

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9670. --- Resolution: Invalid Fix Version/s: (was: 1.5.1) > Introduce slot manager factory

[jira] [Reopened] (FLINK-9671) Add configuration to enable task manager isolation.

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-9671: - reopen to change fixVersion > Add configuration to enable task manager isolation. >

[jira] [Reopened] (FLINK-9670) Introduce slot manager factory

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-9670: - Reopen to remove fixVersion > Introduce slot manager factory >

[jira] [Closed] (FLINK-9671) Add configuration to enable task manager isolation.

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9671. --- Resolution: Won't Fix Fix Version/s: (was: 1.5.1) > Add configuration to enable

[jira] [Commented] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546195#comment-16546195 ] ASF GitHub Bot commented on FLINK-9598: --- Github user Myasuka commented on the issue:

[GitHub] flink issue #6346: [FLINK-9598] Refine java-doc about the min pause between ...

2018-07-17 Thread Myasuka
Github user Myasuka commented on the issue: https://github.com/apache/flink/pull/6346 @zentol Sorry, it's really my fault to affect the public APIs by mistake, I'm reverting API-changes back to original ones and only refine the docs. ---

[jira] [Updated] (FLINK-9860) Netty resource leak on receiver side

2018-07-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9860: Fix Version/s: 1.5.2 > Netty resource leak on receiver side >

[GitHub] flink issue #6347: [hotfix] consistency: vertexes -> vertices

2018-07-17 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6347 +1 from myside, it depends on @zentol or @tillrohrmann 's opinion. ---

[GitHub] flink issue #6347: [hotfix] consistency: vertexes -> vertices

2018-07-17 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6347 it seems Flink also uses "vertices", I agree your opinion. ---

[jira] [Updated] (FLINK-9870) Support field mapping and time attributes for table sinks

2018-07-17 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9870: Affects Version/s: 1.6.0 > Support field mapping and time attributes for table sinks >

[jira] [Closed] (FLINK-7064) test instability in WordCountMapreduceITCase

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7064. --- Resolution: Invalid Fix Version/s: (was: 1.5.2) (was:

[jira] [Created] (FLINK-9870) Support field mapping and time attributes for table sinks

2018-07-17 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9870: --- Summary: Support field mapping and time attributes for table sinks Key: FLINK-9870 URL: https://issues.apache.org/jira/browse/FLINK-9870 Project: Flink Issue

[jira] [Commented] (FLINK-9857) Processing-time timers fire too early

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546184#comment-16546184 ] ASF GitHub Bot commented on FLINK-9857: --- GitHub user aljoscha opened a pull request:

[jira] [Updated] (FLINK-9857) Processing-time timers fire too early

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9857: -- Labels: pull-request-available (was: ) > Processing-time timers fire too early >

[GitHub] flink issue #6347: [hotfix] typo: vertexes -> vertices

2018-07-17 Thread tison1
Github user tison1 commented on the issue: https://github.com/apache/flink/pull/6347 look up dictionary and it says "vertexes" is also vertex pluralities :P but the most of our code use "vertices", so could this PR thought as keeping consistency? ---

[GitHub] flink pull request #6348: [FLINK-9857] Delay firing of processing-time timer...

2018-07-17 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/6348 [FLINK-9857] Delay firing of processing-time timers by 1 ms Description from Jira issue: ``` The firing of processing-time timers is off by one. This leads to problems in edge cases,

[GitHub] flink issue #6347: [hotfix] typo: vertexes -> vertices

2018-07-17 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6347 my English is poor, but it seems "vertexes" is one of the vertex pluralities? cc @zentol @tison1 ---

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546171#comment-16546171 ] Kostas Kloudas commented on FLINK-9868: --- Thanks [~yanghua] for the quick reply. You are right!

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546159#comment-16546159 ] Chesnay Schepler commented on FLINK-9860: - we should double-check whether this also applies to

[GitHub] flink pull request #6347: [hotfix] typo: vertexes -> vertices

2018-07-17 Thread tison1
GitHub user tison1 opened a pull request: https://github.com/apache/flink/pull/6347 [hotfix] typo: vertexes -> vertices cc @zentol @yanghua You can merge this pull request into a Git repository by running: $ git pull https://github.com/tison1/flink master Alternatively you

[jira] [Closed] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator

2018-07-17 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt closed FLINK-8481. -- > Implement Scala API to expose join functionality of > TimeBoundedStreamJoinOperator >

[jira] [Resolved] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator

2018-07-17 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt resolved FLINK-8481. Resolution: Implemented Assignee: Florian Schmidt Fix Version/s: 1.6.0

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545495#comment-16545495 ] Chesnay Schepler edited comment on FLINK-9860 at 7/17/18 7:47 AM: -- oh,

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2018-07-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546141#comment-16546141 ] Chesnay Schepler commented on FLINK-6997: - looks like the error messages returned to the

[jira] [Commented] (FLINK-9868) Expose channel id to ProcessFunction

2018-07-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546120#comment-16546120 ] vinoyang commented on FLINK-9868: - [~kkl0u] the discussion is not posted by me, I just assign this issue

[GitHub] flink pull request #6346: [FLINK-9598] Refine java-doc about the min pause b...

2018-07-17 Thread Myasuka
GitHub user Myasuka opened a pull request: https://github.com/apache/flink/pull/6346 [FLINK-9598] Refine java-doc about the min pause between checkpoints ## What is the purpose of the change This pull request makes docs about config `minPauseBetweenCheckpoints` more clear,

[jira] [Commented] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-07-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546112#comment-16546112 ] ASF GitHub Bot commented on FLINK-9598: --- GitHub user Myasuka opened a pull request:

<    1   2   3   4   >