[jira] [Updated] (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:all-tabpanel ] Sihua Zhou updated FLINK-8601: -- Description: h3. Backgroud Bloom filter is useful in many situation, for example: * 1. Approximate

[jira] [Updated] (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:all-tabpanel ] Sihua Zhou updated FLINK-8601: -- Summary: Introduce PartitionedBloomFilter for Approximate calculation and other situations of

[jira] [Commented] (FLINK-8601) Introduce LinkedBloomFilter 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=16358051#comment-16358051 ] Sihua Zhou commented on FLINK-8601: --- [~fhueske] I have update the document, could you please have a loot

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

[ https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-8601: -- Component/s: (was: Core) State Backends, Checkpointing > Introduce

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

[ https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-8601: -- Description: h3. Backgroud Bloom filter is useful in many situation, for example: * 1. Approximate

[jira] [Closed] (FLINK-8616) Missing null check in OperatorChain.CopyingChainingOutput#pushToOperator masks ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8616. --- Resolution: Duplicate Duplicate of FLINK-8423. > Missing null check in

[jira] [Updated] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8423: Priority: Critical (was: Minor) > OperatorChain#pushToOperator catch block may fail with

[GitHub] flink issue #5393: [FLINK-8516] Allow for custom hash function for shard to ...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/5393 @tzulitai any update? ---

[jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

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

[jira] [Closed] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler closed FLINK-8615. -- Resolution: Not A Bug > Configuring Apache Flink Local Set up with Pseudo distributed Yarn >

[jira] [Commented] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357916#comment-16357916 ] Ken Krugler commented on FLINK-8615: https://flink.apache.org/community.html > Configuring Apache

[jira] [Commented] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357903#comment-16357903 ] Karrtik Iyer commented on FLINK-8615: - Hi [~kkrugler], Apologies, I was not aware of the Flink User

[jira] [Commented] (FLINK-8617) Fix code generation bug while accessing Map type

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

[GitHub] flink pull request #5438: [FLINK-8617][TableAPI & SQL] Fix code generation b...

GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/5438 [FLINK-8617][TableAPI & SQL] Fix code generation bug while accessing … ## What is the purpose of the change fix code generation error in MapGet ## Brief change log handle

[jira] [Created] (FLINK-8617) Fix code generation bug while accessing Map type

Ruidong Li created FLINK-8617: - Summary: Fix code generation bug while accessing Map type Key: FLINK-8617 URL: https://issues.apache.org/jira/browse/FLINK-8617 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8616) Missing null check in OperatorChain.CopyingChainingOutput#pushToOperator masks ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cliff Resnick updated FLINK-8616: - Summary: Missing null check in OperatorChain.CopyingChainingOutput#pushToOperator masks

[jira] [Updated] (FLINK-8616) Missing null check in OperatorChain.copyingChainOutput#pushToOperator masks ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cliff Resnick updated FLINK-8616: - Summary: Missing null check in OperatorChain.copyingChainOutput#pushToOperator masks

[jira] [Created] (FLINK-8616) Missing null check in OperatorChain#pushToOperator masks ClassCastException

Cliff Resnick created FLINK-8616: Summary: Missing null check in OperatorChain#pushToOperator masks ClassCastException Key: FLINK-8616 URL: https://issues.apache.org/jira/browse/FLINK-8616 Project:

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357640#comment-16357640 ] Thomas Weise commented on FLINK-5697: - Since shards are immutable wrt their hash key range and records

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

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

[GitHub] flink pull request #5424: FLINK-8571] [DataStream] Introduce utility functio...

Github user mdaxini commented on a diff in the pull request: https://github.com/apache/flink/pull/5424#discussion_r167064838 --- Diff: docs/dev/api_concepts.md --- @@ -896,3 +896,54 @@ result type ```R``` for the final result. E.g. for a histogram, ```V``` is a num {%

[jira] [Commented] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357418#comment-16357418 ] Ken Krugler commented on FLINK-8615: Hi Karrtik - for a support/configuration question like this,

[jira] [Updated] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set

[ https://issues.apache.org/jira/browse/FLINK-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8410: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Kafka consumer's

[jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

[ https://issues.apache.org/jira/browse/FLINK-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8416: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Kinesis consumer doc

[jira] [Commented] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos

[ https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357305#comment-16357305 ] Tzu-Li (Gordon) Tai commented on FLINK-8247: Moving this to 1.4.2, since on the mailing lists

[jira] [Updated] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos

[ https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8247: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Support Hadoop-free

[jira] [Updated] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8418: --- Fix Version/s: (was: 1.4.1) 1.4.2 >

[jira] [Commented] (FLINK-8451) CaseClassSerializer is not backwards compatible in 1.4

[ https://issues.apache.org/jira/browse/FLINK-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357300#comment-16357300 ] Timo Walther commented on FLINK-8451: - [~tzulitai] yes, 1.4.2 is fine for me. > CaseClassSerializer

[jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher

[ https://issues.apache.org/jira/browse/FLINK-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357299#comment-16357299 ] Tzu-Li (Gordon) Tai commented on FLINK-8308: [~uce] what is the status of this? Has this been

[jira] [Updated] (FLINK-8020) Deadlock found in Async I/O operator

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8020: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Deadlock found in Async

[jira] [Commented] (FLINK-8020) Deadlock found in Async I/O operator

[ https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357296#comment-16357296 ] Tzu-Li (Gordon) Tai commented on FLINK-8020: Moving this to 1.4.2, since on the mailing lists

[jira] [Updated] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8500: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Get the timestamp of the

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357295#comment-16357295 ] Tzu-Li (Gordon) Tai commented on FLINK-8500: Moving this to 1.4.2, since on the mailing lists

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357294#comment-16357294 ] Tzu-Li (Gordon) Tai commented on FLINK-8487: [~aljoscha] can you confirm? > State loss after

[jira] [Commented] (FLINK-8451) CaseClassSerializer is not backwards compatible in 1.4

[ https://issues.apache.org/jira/browse/FLINK-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357291#comment-16357291 ] Tzu-Li (Gordon) Tai commented on FLINK-8451: [~shashank734] the stack trace you posted seems

[jira] [Updated] (FLINK-8451) CaseClassSerializer is not backwards compatible in 1.4

[ https://issues.apache.org/jira/browse/FLINK-8451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8451: --- Fix Version/s: (was: 1.4.1) 1.4.2 > CaseClassSerializer is not

[jira] [Created] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

Karrtik Iyer created FLINK-8615: --- Summary: Configuring Apache Flink Local Set up with Pseudo distributed Yarn Key: FLINK-8615 URL: https://issues.apache.org/jira/browse/FLINK-8615 Project: Flink

[jira] [Updated] (FLINK-8439) Document using a custom AWS Credentials Provider with flink-3s-fs-hadoop

[ https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8439: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Document using a custom

[jira] [Resolved] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes

[ https://issues.apache.org/jira/browse/FLINK-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8270. Resolution: Fixed > TaskManagers do not use correct local path for shipped Keytab

[jira] [Commented] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes

[ https://issues.apache.org/jira/browse/FLINK-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357288#comment-16357288 ] Tzu-Li (Gordon) Tai commented on FLINK-8270: Fixed by FLINK-8275. Closing this issue now. >

[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=16357284#comment-16357284 ] Tzu-Li (Gordon) Tai commented on FLINK-7756: Marking this as resolved due to the fix in

[jira] [Resolved] (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:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7756. Resolution: Fixed Assignee: Aljoscha Krettek > RocksDB state backend

[jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5372: --- Fix Version/s: (was: 1.4.1) 1.4.2 > Fix

[jira] [Comment Edited] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357276#comment-16357276 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5372 at 2/8/18 5:40 PM:

[jira] [Comment Edited] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357276#comment-16357276 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5372 at 2/8/18 5:39 PM:

[jira] [Resolved] (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 ] Tzu-Li (Gordon) Tai resolved FLINK-6321. Resolution: Fixed > RocksDB state backend Checkpointing is not working with

[jira] [Commented] (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:comment-tabpanel=16357278#comment-16357278 ] Tzu-Li (Gordon) Tai commented on FLINK-6321: I am marking this as resolved now, due to the fix

[jira] [Commented] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357276#comment-16357276 ] Tzu-Li (Gordon) Tai commented on FLINK-5372: [~srichter] what is the status of this issue? Can

[jira] [Commented] (FLINK-8614) Enable Flip-6 per default

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

[GitHub] flink pull request #5437: [FLINK-8614] [flip6] Activate Flip-6 mode per defa...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5437 [FLINK-8614] [flip6] Activate Flip-6 mode per default ## What is the purpose of the change This commit enables the Flip-6 mode per default. Additionally, it disables some of the

[jira] [Created] (FLINK-8614) Enable Flip-6 per default

Till Rohrmann created FLINK-8614: Summary: Enable Flip-6 per default Key: FLINK-8614 URL: https://issues.apache.org/jira/browse/FLINK-8614 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-8613) Return excess container in YarnResourceManager

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

[GitHub] flink pull request #5436: [FLINK-8613] [flip6] [yarn] Return excess containe...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5436 [FLINK-8613] [flip6] [yarn] Return excess containers ## What is the purpose of the change Upon notification of newly allocated containers, the YarnResourceManager will only accept

[jira] [Created] (FLINK-8613) Return excess container in YarnResourceManager

Till Rohrmann created FLINK-8613: Summary: Return excess container in YarnResourceManager Key: FLINK-8613 URL: https://issues.apache.org/jira/browse/FLINK-8613 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8612) Add non-detached job mode

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

[GitHub] flink pull request #5435: [FLINK-8612] [flip6] Enable non-detached job mode

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5435 [FLINK-8612] [flip6] Enable non-detached job mode ## What is the purpose of the change The non-detached job mode waits until has served the JobResult of a completed job at least

[jira] [Created] (FLINK-8612) Add non-detached job mode

Till Rohrmann created FLINK-8612: Summary: Add non-detached job mode Key: FLINK-8612 URL: https://issues.apache.org/jira/browse/FLINK-8612 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8611) Add result future to JobManagerRunner

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

[GitHub] flink pull request #5434: [FLINK-8611] [flip6] Add result future to JobManag...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5434 [FLINK-8611] [flip6] Add result future to JobManagerRunner ## What is the purpose of the change This commit adds a CompletableFuture to the JobManagerRunner. This future will be

[jira] [Created] (FLINK-8611) Add result future to JobManagerRunner

Till Rohrmann created FLINK-8611: Summary: Add result future to JobManagerRunner Key: FLINK-8611 URL: https://issues.apache.org/jira/browse/FLINK-8611 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-8318) Conflict jackson library with ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8318. Resolution: Fixed Assignee: Nico Kruber > Conflict jackson library with

[jira] [Commented] (FLINK-8318) Conflict jackson library with ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357172#comment-16357172 ] Tzu-Li (Gordon) Tai commented on FLINK-8318: We have a fix now in `1.5.0` and `1.4.1` that

[jira] [Resolved] (FLINK-8362) Shade Elasticsearch dependencies away

[ https://issues.apache.org/jira/browse/FLINK-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8362. Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 > Shade

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

[ https://issues.apache.org/jira/browse/FLINK-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357164#comment-16357164 ] Tzu-Li (Gordon) Tai commented on FLINK-8362: Merged. 1.4 - 

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

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

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

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

[GitHub] flink pull request #5426: [FLINK-8362] [elasticsearch] Shade all ES connecto...

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

[GitHub] flink pull request #5243: [FLINK-8362][elasticsearch] shade all dependencies

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

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

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

[GitHub] flink issue #5426: [FLINK-8362] [elasticsearch] Shade all ES connector depen...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5426 Build passing locally, merging ... ---

[GitHub] flink pull request #5433: [FLINK-8610] [flip6] Remove RestfulGateway from Jo...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5433 [FLINK-8610] [flip6] Remove RestfulGateway from JobMasterGateway ## What is the purpose of the change The JobMaster no longer needs to implement the RestfulGateway. Therefore, it

[jira] [Commented] (FLINK-8610) Remove RestfulGateway from JobMasterGateway

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

[jira] [Created] (FLINK-8610) Remove RestfulGateway from JobMasterGateway

Till Rohrmann created FLINK-8610: Summary: Remove RestfulGateway from JobMasterGateway Key: FLINK-8610 URL: https://issues.apache.org/jira/browse/FLINK-8610 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8609) Add support to deploy detached job mode clusters

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

[GitHub] flink pull request #5432: [FLINK-8609] [flip6] Enable Flip-6 job mode in Cli...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5432 [FLINK-8609] [flip6] Enable Flip-6 job mode in CliFrontend ## What is the purpose of the change This commit allows to deploy detached job mode clusters via the CliFrontend. In

[jira] [Created] (FLINK-8609) Add support to deploy detached job mode clusters

Till Rohrmann created FLINK-8609: Summary: Add support to deploy detached job mode clusters Key: FLINK-8609 URL: https://issues.apache.org/jira/browse/FLINK-8609 Project: Flink Issue Type:

[jira] [Reopened] (FLINK-6590) Integrate generated tables into documentation

[ https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-6590: - reopen to modify title > Integrate generated tables into documentation >

[jira] [Closed] (FLINK-6590) Integrate generated tables into documentation

[ https://issues.apache.org/jira/browse/FLINK-6590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6590. --- Resolution: Fixed > Integrate generated tables into documentation >

[jira] [Closed] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8530. Resolution: Won't Do > Enable detached job submission for RestClusterClient >

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

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

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5431 [FLINK-8608] [flip6] Implement MiniDispatcher for job mode ## What is the purpose of the change The MiniDispatcher is responsible for submitting the single job with which a job

[jira] [Created] (FLINK-8608) Add MiniDispatcher for job mode

Till Rohrmann created FLINK-8608: Summary: Add MiniDispatcher for job mode Key: FLINK-8608 URL: https://issues.apache.org/jira/browse/FLINK-8608 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5425#discussion_r166973933 --- Diff: flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/BroadcastStateITCase.scala --- @@ -0,0 +1,125 @@ +/* + *

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5425#discussion_r166972253 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/broadcast/BroadcastExample.java --- @@ -0,0 +1,137 @@

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5425#discussion_r166972441 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/broadcast/BroadcastExample.java --- @@ -0,0 +1,137 @@

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5425#discussion_r166970474 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/broadcast/BroadcastExample.java --- @@ -0,0 +1,137 @@

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5425#discussion_r16697 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala --- @@ -441,6 +463,26 @@ class DataStream[T](stream:

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5425#discussion_r166972719 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/broadcast/BroadcastExample.java --- @@ -0,0 +1,137 @@

[jira] [Created] (FLINK-8607) Add a basic embedded SQL CLI client

Timo Walther created FLINK-8607: --- Summary: Add a basic embedded SQL CLI client Key: FLINK-8607 URL: https://issues.apache.org/jira/browse/FLINK-8607 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

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

[GitHub] flink issue #5426: [FLINK-8362] [elasticsearch] Shade all ES connector depen...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5426 Thanks! Since this is verified manually already, and we have a test that verifies everything is properly shaded, I'll merge this once Travis gives green. ---

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

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

[GitHub] flink issue #5426: [FLINK-8362] [elasticsearch] Shade all ES connector depen...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5426 notice files look good to me. ---

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357003#comment-16357003 ] Timo Walther commented on FLINK-8577: - Maybe we should also rename the methods to find them easier:

  1   2   >