[GitHub] flink issue #5614: [FLINK-8827] When FLINK_CONF_DIR contains spaces, execute...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5614 +1 ---

[jira] [Commented] (FLINK-8827) When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed

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

[GitHub] flink issue #5643: can integrate and support on apache kudu ?

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5643 Pull Requests are not meant to ask question, please head to the [mailing lists](http://flink.apache.org/community.html#mailing-lists) or open a [JIRA](https://issues.apache.org/jira/projects/FLINK).

[jira] [Commented] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387372#comment-16387372 ] mingleizhang commented on FLINK-8687: - [~yuzhih...@gmail.com] Shouldn't we lock {{write}} situation ?

[GitHub] flink pull request #5643: can integrate and support on apache kudu ?

GitHub user qi20088 opened a pull request: https://github.com/apache/flink/pull/5643 can integrate and support on apache kudu ? *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your

[jira] [Assigned] (FLINK-5621) Flink should provide a mechanism to prevent scheduling tasks on TaskManagers with operational issues

[ https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-5621: --- Assignee: vinoyang > Flink should provide a mechanism to prevent scheduling tasks on TaskManagers >

[jira] [Updated] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8687: Priority: Major (was: Minor) > MaterializedCollectStreamResult#retrievePage should take resultLock

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16387335#comment-16387335 ] Sihua Zhou commented on FLINK-8871: --- [~srichter] Have you already work on this or decide to work on

[jira] [Commented] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

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

[GitHub] flink issue #5440: [FLINK-6160] [flip-6] Retry JobManager/ResourceManager co...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5440 @tillrohrmann Could you please take a look on this when available ? Thanks ---

[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5481 @kl0u @aljoscha I added the scala example, and I believe the only build failure in Travis is irrelevant ---

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

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 3/6/18 4:48 AM: --- error-prone has JDK 8

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

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

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

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

[GitHub] flink pull request #5327: [FLINK-8428] [table] Implement stream-stream non-w...

Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5327#discussion_r172408177 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/NonWindowJoin.scala --- @@ -0,0 +1,271 @@ +/* + *

[GitHub] flink pull request #5327: [FLINK-8428] [table] Implement stream-stream non-w...

Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5327#discussion_r172408402 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/NonWindowLeftJoinWithNonEquiPredicates.scala --- @@ -0,0 +1,228

[jira] [Assigned] (FLINK-8861) Add support for batch queries in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8861: -- Assignee: Xingcan Cui > Add support for batch queries in SQL Client >

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

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

[GitHub] flink issue #5555: [FLINK-8689][table]Add runtime support of distinct filter...

Github user walterddr commented on the issue: https://github.com/apache/flink/pull/ @hequn8128 @fhueske Thanks for the feedback. I have updated the diff to directly use DistinctAccumulator for filtering and modified the `generateAggregation` API. Please kindly take another look

[jira] [Created] (FLINK-8874) rewrite Flink docs/dev/stream/operators/process_function.md to recommend using KeyedProcessFunction

Bowen Li created FLINK-8874: --- Summary: rewrite Flink docs/dev/stream/operators/process_function.md to recommend using KeyedProcessFunction Key: FLINK-8874 URL: https://issues.apache.org/jira/browse/FLINK-8874

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

[GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-...

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5634 I think the ideal would be that idleness would occur only for tail reads, i.e. due to a timeout from `kafkaConsumer.poll(pollTimeout)`.In other words, an intermittent connection issue would

[jira] [Created] (FLINK-8873) move unit tests of KeyedStream.scala from DataStreamTest.scala to KeyedStreamTest.scala

Bowen Li created FLINK-8873: --- Summary: move unit tests of KeyedStream.scala from DataStreamTest.scala to KeyedStreamTest.scala Key: FLINK-8873 URL: https://issues.apache.org/jira/browse/FLINK-8873 Project:

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

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

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

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

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

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

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

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

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

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

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r172306197 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java --- @@ -0,0 +1,480 @@ +/*

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r172303424 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -137,6 +158,151 @@ public EqualTo

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r172302147 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -137,6 +158,151 @@ public EqualTo

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r172302583 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -137,6 +158,151 @@ public EqualTo

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r172303671 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java --- @@ -0,0 +1,480 @@ +/*

[jira] [Updated] (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:all-tabpanel ] Aleksandr Filichkin updated FLINK-8829: --- Description: Hi, We have running Flink 1.3.2 app in Amazon EMR with YARN. Every week

[GitHub] flink pull request #5642: [FLINK-8091] [flink-dist] Support running historys...

GitHub user fnk opened a pull request: https://github.com/apache/flink/pull/5642 [FLINK-8091] [flink-dist] Support running historyserver in foreground ## Brief change log *Allow historyserver to run in foreground* - The scripts "flink-console.sh" and

[jira] [Commented] (FLINK-8091) Support running historyserver in foreground

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

[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=16386404#comment-16386404 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zentol closed the pull request at:

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

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

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

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

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5601 The main issue was actually described in FLINK-8801: According to https://docs.aws.amazon.com/AmazonS3/latest/dev/Introduction.html#ConsistencyModel: > Amazon S3 provides

[jira] [Closed] (FLINK-8757) Add MiniClusterResource.getClusterClient()

[ https://issues.apache.org/jira/browse/FLINK-8757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8757. --- Resolution: Duplicate Fix Version/s: (was: 1.5.0) > Add

[jira] [Created] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

Stefan Richter created FLINK-8871: - Summary: Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Key: FLINK-8871 URL: https://issues.apache.org/jira/browse/FLINK-8871

[jira] [Created] (FLINK-8872) Yarn detached mode via -yd does not detach

Nico Kruber created FLINK-8872: -- Summary: Yarn detached mode via -yd does not detach Key: FLINK-8872 URL: https://issues.apache.org/jira/browse/FLINK-8872 Project: Flink Issue Type: Bug

[jira] [Closed] (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:all-tabpanel ] Chesnay Schepler closed FLINK-8849. --- Resolution: Fixed Assignee: Ken Krugler Fix Version/s: 1.4.2

[jira] [Commented] (FLINK-8601) Introduce PartitionedBloomFilter for Approximate calculation and other situations of performance optimization

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

[GitHub] flink issue #5641: [FLINK-8601][WIP] Introduce PartitionedBloomFilter for Ap...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5641 For the sake of easy to discussion later.. ---

[jira] [Closed] (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 closed FLINK-8857. --- Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 master:

[GitHub] flink pull request #5641: [FLINK-8601][WIP] Introduce PartitionedBloomFilter...

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5641 [FLINK-8601][WIP] Introduce PartitionedBloomFilter for Approximate calculation and other situations of performance optimization This PR introduce PartitionedBloomFilter which support rescaling

[jira] [Commented] (FLINK-8601) Introduce PartitionedBloomFilter for Approximate calculation and other situations of performance optimization

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

[jira] [Resolved] (FLINK-8337) GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable

[ https://issues.apache.org/jira/browse/FLINK-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-8337. Resolution: Fixed Assignee: Nico Kruber Fix Version/s: (was: 1.4.3) Should be

[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=16386350#comment-16386350 ] ASF GitHub Bot commented on FLINK-8849: --- 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=16386351#comment-16386351 ] ASF GitHub Bot commented on FLINK-8857: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7226) REST responses contain invalid content-encoding header

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

[GitHub] flink pull request #5590: [hotfix][REST] Fix CONTENT_TYPE header

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

[GitHub] flink pull request #5592: [hotfix] fix javadoc link of ClusterClient#trigger...

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

[GitHub] flink pull request #5607: [hotfix][docs] Drop the incorrect parallel remark ...

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

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

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

[GitHub] flink pull request #5630: [FLINK-8849][Documentation] Fix link to chaining d...

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

[GitHub] flink pull request #5627: [doc] Remove missed CheckpointedRestoring

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

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

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

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5601 S3 is actually strongly consistent when reading newly created objects, just not in listing or renaming objects (files). The test seems to actually use reads of full paths, so wondering

[jira] [Closed] (FLINK-8870) End-to-end tests wrongly pass if md5sum is not installed

[ https://issues.apache.org/jira/browse/FLINK-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt closed FLINK-8870. -- Resolution: Invalid Behaves as expected, I just misinterpreted the output > End-to-end tests

[jira] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386260#comment-16386260 ] Aljoscha Krettek commented on FLINK-8807: - Fixed on release-1.4 in

[jira] [Created] (FLINK-8870) End-to-end tests wrongly pass if md5sum is not installed

Florian Schmidt created FLINK-8870: -- Summary: End-to-end tests wrongly pass if md5sum is not installed Key: FLINK-8870 URL: https://issues.apache.org/jira/browse/FLINK-8870 Project: Flink

[jira] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

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

[jira] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

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

[GitHub] flink issue #5623: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5623 Thanks for the comments! I'll incorporate them and merge. ---

[GitHub] flink pull request #5623: [FLINK-8807] Fix ZookeeperCompleted checkpoint sto...

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

[jira] [Created] (FLINK-8869) Kafka restore from checkpoint without react to the new add partition to kafka server

aitozi created FLINK-8869: - Summary: Kafka restore from checkpoint without react to the new add partition to kafka server Key: FLINK-8869 URL: https://issues.apache.org/jira/browse/FLINK-8869 Project: Flink

[jira] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16386197#comment-16386197 ] Aljoscha Krettek commented on FLINK-8807: - Fixed on release-1.5 in

[jira] [Created] (FLINK-8868) Support Table Function as Table

Ruidong Li created FLINK-8868: - Summary: Support Table Function as Table Key: FLINK-8868 URL: https://issues.apache.org/jira/browse/FLINK-8868 Project: Flink Issue Type: Improvement

[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 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] [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] [Created] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks

Timo Walther created FLINK-8866: --- Summary: Create unified interfaces to configure and instatiate TableSinks Key: FLINK-8866 URL: https://issues.apache.org/jira/browse/FLINK-8866 Project: Flink

[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] [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: 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 >

[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-8864) Add CLI query history in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8864: Summary: Add CLI query history in SQL Client (was: Add CLI query history) > Add CLI query history

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

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

[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-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:

[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] [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] [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:

[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-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-8861) Add support for batch queries in SQL Client

Timo Walther created FLINK-8861: --- Summary: Add support for batch queries in SQL Client Key: FLINK-8861 URL: https://issues.apache.org/jira/browse/FLINK-8861 Project: Flink Issue Type: Sub-task

[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

[jira] [Updated] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

[ https://issues.apache.org/jira/browse/FLINK-8852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8852: Issue Type: Sub-task (was: Bug) Parent: FLINK-7594 > SQL Client does not work with new

[jira] [Updated] (FLINK-8850) SQL Client does not support Event-time

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

[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] [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 issue #5613: [FLINK-8274] [table] Split generated methods for preventi...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5613 @Xpray and @hequn8128 are you fine with merging this PR for now and then open follow-up issues for more splitting (unboxing, expression, class)? ---

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

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

[GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP...

GitHub user buptljy opened a pull request: https://github.com/apache/flink/pull/5638 [FLINK-6924][table]ADD LOG(X) supported in TableAPI ## What is the purpose of the change * Add LOG(X) function in TableAPI. ## Brief change log * Add LOG(X) function in TableAPI.

  1   2   >