[jira] [Assigned] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

[ https://issues.apache.org/jira/browse/FLINK-7804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7804: --- Assignee: Gary Yao > YarnResourceManager does not execute AMRMClientAsync callbacks in main thread >

[jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385772#comment-16385772 ] Bowen Li commented on FLINK-8837: - +1 on adding a new {{experimental}} annotation. I can take this ticket

[jira] [Created] (FLINK-8857) HBase connector read example throws exception at the end.

Xu Zhang created FLINK-8857: --- Summary: HBase connector read example throws exception at the end. Key: FLINK-8857 URL: https://issues.apache.org/jira/browse/FLINK-8857 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8845) Introduce `parallel recovery` mode for full checkpoint (savepoint)

[ https://issues.apache.org/jira/browse/FLINK-8845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-8845: -- Summary: Introduce `parallel recovery` mode for full checkpoint (savepoint) (was: Introduce

[jira] [Updated] (FLINK-8839) Table source factory discovery is broken in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8839: Priority: Blocker (was: Major) > Table source factory discovery is broken in SQL Client >

[jira] [Updated] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

[ https://issues.apache.org/jira/browse/FLINK-7804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7804: Priority: Blocker (was: Major) > YarnResourceManager does not execute AMRMClientAsync callbacks in main

[jira] [Comment Edited] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385857#comment-16385857 ] mingleizhang edited comment on FLINK-8835 at 3/5/18 9:40 AM: - Hi,

[GitHub] flink pull request #5634: [FLINK-5479] [kafka] Idleness detection for period...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5634 [FLINK-5479] [kafka] Idleness detection for periodic per-partition watermarks in FlinkKafkaConsumer ## What is the purpose of the change This commit adds the capability to detect idle

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385857#comment-16385857 ] mingleizhang commented on FLINK-8835: - Hi, [~StephanEwen] I would like to confirm one stuff with you.

[jira] [Commented] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

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

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

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

[jira] [Commented] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385879#comment-16385879 ] Daniel Harper commented on FLINK-8834: -- Interesting insight, thanks [~StephanEwen]! Will follow

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r172136142 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -242,4 +242,17 @@ class CountWithTimeoutFunction extends ProcessFunction[(String, String),

[GitHub] flink issue #5601: [FLINK-8818][yarn/s3][tests] harden YarnFileStageTest upl...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5601 LGTM 👍 ---

[jira] [Commented] (FLINK-8769) Quickstart job execution in IDE logs contain several exceptions

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

[GitHub] flink pull request #5635: [FLINK-8859][state backend] RocksDB backend should...

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5635 [FLINK-8859][state backend] RocksDB backend should pass WriteOption to Rocks.put() when restoring ## What is the purpose of the change This PR fixes

[jira] [Commented] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining

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

[jira] [Commented] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write

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

[jira] [Commented] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write

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

[GitHub] flink pull request #5601: [FLINK-8818][yarn/s3][tests] harden YarnFileStageT...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5601#discussion_r172152959 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java --- @@ -200,13 +201,23 @@ static void testCopyFromLocalRecursive(

[GitHub] flink pull request #5601: [FLINK-8818][yarn/s3][tests] harden YarnFileStageT...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5601#discussion_r172152995 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTest.java --- @@ -200,13 +201,23 @@ static void testCopyFromLocalRecursive(

[jira] [Created] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

Sihua Zhou created FLINK-8859: - Summary: RocksDB backend should pass WriteOption to Rocks.put() when restoring Key: FLINK-8859 URL: https://issues.apache.org/jira/browse/FLINK-8859 Project: Flink

[GitHub] flink pull request #5633: [FLINK-8857] [Hbase] Avoid HBase connector read ex...

GitHub user neoremind opened a pull request: https://github.com/apache/flink/pull/5633 [FLINK-8857] [Hbase] Avoid HBase connector read example throwing exception at the end ## What is the purpose of the change *This pull request fixes problem of HBase read example throwing

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

[ https://issues.apache.org/jira/browse/FLINK-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385825#comment-16385825 ] Chesnay Schepler commented on FLINK-8857: - This happens because the program calls

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8715: Fix Version/s: 1.5.0 > RocksDB does not propagate reconfiguration of serializer to the

[jira] [Updated] (FLINK-8269) Set netRuntime in JobExecutionResult

[ https://issues.apache.org/jira/browse/FLINK-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8269: Fix Version/s: 1.5.0 > Set netRuntime in JobExecutionResult >

[jira] [Updated] (FLINK-8857) HBase connector read example throws exception at the end.

[ https://issues.apache.org/jira/browse/FLINK-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8857: Labels: easy-fix starter (was: ) > HBase connector read example throws exception at the

[jira] [Created] (FLINK-8858) SQL Client to submit long running query in file

Renjie Liu created FLINK-8858: - Summary: SQL Client to submit long running query in file Key: FLINK-8858 URL: https://issues.apache.org/jira/browse/FLINK-8858 Project: Flink Issue Type: New

[GitHub] flink issue #5630: [FLINK-8849][Documentation] Fix link to chaining docs

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5630 merging. ---

[jira] [Commented] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining

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

[jira] [Commented] (FLINK-8458) Add the switch for keeping both the old mode and the new credit-based mode

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

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

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

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r172133573 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -242,4 +242,17 @@ class CountWithTimeoutFunction extends ProcessFunction[(String, String),

[jira] [Commented] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write

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

[GitHub] flink pull request #5601: [FLINK-8818][yarn/s3][tests] harden YarnFileStageT...

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

[jira] [Commented] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

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

[jira] [Updated] (FLINK-8839) Table source factory discovery is broken in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8839: Fix Version/s: 1.5.0 > Table source factory discovery is broken in SQL Client >

[jira] [Updated] (FLINK-8857) HBase connector read example throws exception at the end.

[ https://issues.apache.org/jira/browse/FLINK-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8857: Affects Version/s: 1.5.0 1.3.2 1.4.1 > HBase

[GitHub] flink pull request #5633: [FLINK-8857] [Hbase] Avoid HBase connector read ex...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5633#discussion_r172122162 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseReadExample.java --- @@ -86,8 +86,8 @@ public boolean

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

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

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385836#comment-16385836 ] Aljoscha Krettek commented on FLINK-7756: - [~trazdan] & [~shashank734] You think we can also close

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385834#comment-16385834 ] Aljoscha Krettek commented on FLINK-7756: - Great that it works now! Regarding 1) This is probably

[GitHub] flink pull request #5633: [FLINK-8857] [Hbase] Avoid HBase connector read ex...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5633#discussion_r172124498 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseReadExample.java --- @@ -86,8 +86,8 @@ public boolean

[jira] [Commented] (FLINK-8818) Harden YarnFileStageTest upload test for eventual consistent read-after-write

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

[GitHub] flink issue #5635: [FLINK-8859][state backend] RocksDB backend should pass W...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5635 @StefanRRichter Could you please have a look at this? This is a trivial work, but can improve performance a lot (It looks like we forgot it when restoring). ---

[jira] [Assigned] (FLINK-8857) HBase connector read example throws exception at the end.

[ https://issues.apache.org/jira/browse/FLINK-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8857: --- Assignee: Xu Zhang > HBase connector read example throws exception at the end. >

[jira] [Updated] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

[ https://issues.apache.org/jira/browse/FLINK-7804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7804: Fix Version/s: 1.5.0 > YarnResourceManager does not execute AMRMClientAsync callbacks in

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

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

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

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

[GitHub] flink pull request #5633: [FLINK-8857] [Hbase] Avoid HBase connector read ex...

Github user neoremind commented on a diff in the pull request: https://github.com/apache/flink/pull/5633#discussion_r172122738 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseReadExample.java --- @@ -86,8 +86,8 @@ public boolean

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

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

[jira] [Commented] (FLINK-8829) Flink in EMR(YARN) is down due to Akka communication issue

[ https://issues.apache.org/jira/browse/FLINK-8829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385831#comment-16385831 ] Aleksandr Filichkin commented on FLINK-8829: [~phoenixjiangnan] Have you faced it before? What

[GitHub] flink pull request #5633: [FLINK-8857] [Hbase] Avoid HBase connector read ex...

Github user neoremind commented on a diff in the pull request: https://github.com/apache/flink/pull/5633#discussion_r172125701 --- Diff: flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseReadExample.java --- @@ -86,8 +86,8 @@ public boolean

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

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

[jira] [Commented] (FLINK-8857) HBase connector read example throws exception at the end.

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

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r172135390 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -242,4 +242,17 @@ class CountWithTimeoutFunction extends ProcessFunction[(String, String),

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r172135104 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java --- @@ -70,21 +69,15 @@ public void open()

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

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

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

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

[jira] [Commented] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

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

[GitHub] flink issue #5630: [FLINK-8849][Documentation] Fix link to chaining docs

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5630 We don't _require_ JIRAs for small doc fixes, whether you open one is up to you. ---

[GitHub] flink issue #5627: [doc] Remove missed CheckpointedRestoring

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5627 merging. ---

[GitHub] flink issue #5633: [FLINK-8857] [Hbase] Avoid HBase connector read example t...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5633 merging. ---

[GitHub] flink pull request #5611: [FLINK-8769][flip6] do not print error causing exc...

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

[GitHub] flink pull request #5317: [FLINK-8458] Add the switch for keeping both the o...

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

[GitHub] flink pull request #5636: [FLINK-8703][tests] Port CancelingTestBase to Mini...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5636 [FLINK-8703][tests] Port CancelingTestBase to MiniClusterResource ## What is the purpose of the change The `CancelingTestBase` now uses the `MiniClusterResource` and can be run against

[jira] [Closed] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

[ https://issues.apache.org/jira/browse/FLINK-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8859. - Resolution: Fixed Release Note: Merged in 131daa28bf. > RocksDB backend should pass

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Created] (FLINK-8862) Support HBase snapshot read

Xu Zhang created FLINK-8862: --- Summary: Support HBase snapshot read Key: FLINK-8862 URL: https://issues.apache.org/jira/browse/FLINK-8862 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8863) Add user-defined function support in SQL Client

Timo Walther created FLINK-8863: --- Summary: Add user-defined function support in SQL Client Key: FLINK-8863 URL: https://issues.apache.org/jira/browse/FLINK-8863 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386138#comment-16386138 ] Aljoscha Krettek commented on FLINK-7756: - [~shashank734] Yes, because that should also fail with

[jira] [Updated] (FLINK-8858) Add support for INSERT INTO in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8858: Issue Type: Sub-task (was: New Feature) Parent: FLINK-7594 > Add support for INSERT INTO

[jira] [Updated] (FLINK-8858) Add support for INSERT INTO in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8858: Summary: Add support for INSERT INTO in SQL Client (was: SQL Client to submit long running query

[jira] [Updated] (FLINK-8860) SlotManager spamming log files

[ https://issues.apache.org/jira/browse/FLINK-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8860: Priority: Blocker (was: Critical) > SlotManager spamming log files >

[GitHub] flink pull request #5640: [FLINK-8839] [sql-client] Fix table source factory...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5640 [FLINK-8839] [sql-client] Fix table source factory discovery ## What is the purpose of the change This PR fixes the table source factory discovery by adding dependencies to the

[jira] [Commented] (FLINK-8839) Table source factory discovery is broken in SQL Client

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

[GitHub] flink issue #5635: [FLINK-8859][state backend] RocksDB backend should pass W...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5635 LGTM 👍 ---

[jira] [Commented] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

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

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386040#comment-16386040 ] Shashank Agarwal commented on FLINK-7756: - [~aljoscha] We found one thing, In our past setup, we

[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=16386109#comment-16386109 ] ASF GitHub Bot commented on FLINK-8274: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #5635: [FLINK-8859][state backend] RocksDB backend should...

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

[jira] [Commented] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring

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

[jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-4387: --- Priority: Major (was: Blocker) > Instability in KvStateClientTest.testClientServerIntegration() >

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386061#comment-16386061 ] Nico Kruber commented on FLINK-4387: Upgrading Netty should solve this bug as well. > Instability in

[GitHub] flink pull request #5621: [FLINK-8517] fix missing synchronization in TaskEv...

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

[jira] [Updated] (FLINK-8862) Support HBase snapshot read

[ https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Zhang updated FLINK-8862: Attachment: FLINK-8862-DesignDoc.pdf > Support HBase snapshot read > --- > >

[jira] [Created] (FLINK-8864) Add CLI query history

Timo Walther created FLINK-8864: --- Summary: Add CLI query history Key: FLINK-8864 URL: https://issues.apache.org/jira/browse/FLINK-8864 Project: Flink Issue Type: Sub-task Components:

[GitHub] flink pull request #5639: [FLINK-8862] [HBase] Support HBase snapshot read

GitHub user neoremind opened a pull request: https://github.com/apache/flink/pull/5639 [FLINK-8862] [HBase] Support HBase snapshot read ## What is the purpose of the change *Flink-hbase connector only supports reading/scanning HBase over region server scanner, there is

[jira] [Created] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

Shashank Agarwal created FLINK-8867: --- Summary: Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config Key: FLINK-8867 URL: https://issues.apache.org/jira/browse/FLINK-8867 Project:

[jira] [Updated] (FLINK-8860) SlotManager spamming log files

[ https://issues.apache.org/jira/browse/FLINK-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8860: --- Labels: flip-6 (was: flip-6 flip6) > SlotManager spamming log files > --

[jira] [Comment Edited] (FLINK-8858) SQL Client to submit long running query in file

[ https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386047#comment-16386047 ] Timo Walther edited comment on FLINK-8858 at 3/5/18 1:08 PM: - Thanks for

[jira] [Closed] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal closed FLINK-6321. --- Resolution: Fixed Fix Version/s: 1.4.1 same as :

[jira] [Commented] (FLINK-8517) StaticlyNestedIterationsITCase.testJobWithoutObjectReuse unstable on Travis

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

[jira] [Updated] (FLINK-8862) Support HBase snapshot read

[ https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Zhang updated FLINK-8862: Attachment: FLINK-8862-Design-Class-Diagram.png > Support HBase snapshot read > ---

[jira] [Created] (FLINK-8865) Add CLI query code completion in SQL Client

Timo Walther created FLINK-8865: --- Summary: Add CLI query code completion in SQL Client Key: FLINK-8865 URL: https://issues.apache.org/jira/browse/FLINK-8865 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-8812) Possible resource leak in Flip6

[ https://issues.apache.org/jira/browse/FLINK-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8812: --- Labels: flip-6 (was: flip6) > Possible resource leak in Flip6 > --- > >

[jira] [Created] (FLINK-8860) SlotManager spamming log files

Nico Kruber created FLINK-8860: -- Summary: SlotManager spamming log files Key: FLINK-8860 URL: https://issues.apache.org/jira/browse/FLINK-8860 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7594 > Improve basic embedded SQL

[jira] [Updated] (FLINK-8853) SQL Client cannot emit query results that contain a rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-8853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8853: Issue Type: Sub-task (was: Bug) Parent: FLINK-7594 > SQL Client cannot emit query results

[GitHub] flink pull request #5637: [FLINK-8860][flip6] stop SlotManager spamming logs...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5637 [FLINK-8860][flip6] stop SlotManager spamming logs for every TM heartbeat at log level 'info' ## What is the purpose of the change For every `TaskManager` heartbeat message, `SlotManager`

  1   2   >