[jira] [Commented] (FLINK-9098) ClassLoaderITCase unstable

2018-07-24 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553930#comment-16553930 ] Piotr Nowojski commented on FLINK-9098: --- Here it is: 

[jira] [Commented] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

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

[GitHub] flink issue #6398: [FLINK-9923][tests] Harden OneInputStreamTaskTest#testWat...

2018-07-24 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6398 I got this from an IntelliJ inspection warning which says >Reports fields of type long or double which are declared as volatile. While Java specifies that reads and writes from such fields

[jira] [Commented] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

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

[GitHub] flink issue #6398: [FLINK-9923][tests] Harden OneInputStreamTaskTest#testWat...

2018-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6398 well, that's a fairly general statement isn't it :/ Unless we find any mention anywhere of a major JVM not adhering to the JLS in this regard, that is suited for Flink applications, I would

[jira] [Comment Edited] (FLINK-9918) Outsource fastutil dependency to flink-shading.

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552884#comment-16552884 ] Chesnay Schepler edited comment on FLINK-9918 at 7/24/18 8:09 AM: -- the

[jira] [Commented] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

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

[GitHub] flink pull request #6401: [hotfix]fix typo for variable name dynamicProperti...

2018-07-24 Thread rileyli
GitHub user rileyli opened a pull request: https://github.com/apache/flink/pull/6401 [hotfix]fix typo for variable name dynamicProperties in FlinkYarnSessionCli.java ### What is the purpose of the change fix typo for variable name dynamicProperties in FlinkYarnSessionCli.java

[jira] [Closed] (FLINK-9883) Filter the target window to calculate when deal with slidewindow

2018-07-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi closed FLINK-9883. - Resolution: Won't Fix > Filter the target window to calculate when deal with slidewindow >

[GitHub] flink issue #6398: [FLINK-9923][tests] Harden OneInputStreamTaskTest#testWat...

2018-07-24 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6398 Given that the `WatermarkGauge` is not super critical, I'm ok with changing it to a `volatile long`. If the `OneInputStreamTask` should fail again with a similar problem, then we know that the

[jira] [Created] (FLINK-9932) If task executor offer slot to job master timeout the first time, the slot will leak

2018-07-24 Thread shuai.xu (JIRA)
shuai.xu created FLINK-9932: --- Summary: If task executor offer slot to job master timeout the first time, the slot will leak Key: FLINK-9932 URL: https://issues.apache.org/jira/browse/FLINK-9932 Project:

[jira] [Commented] (FLINK-9098) ClassLoaderITCase unstable

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553947#comment-16553947 ] Chesnay Schepler commented on FLINK-9098: - That failure is caused by your changes. You removed

[jira] [Updated] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to read more records in the case of long running loops

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9897: --- Summary: Further enhance adaptive reads in Kinesis Connector to read more records in the case of

[jira] [Updated] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9897: --- Summary: Further enhance adaptive reads in Kinesis Connector to depend on run loop time (was:

[jira] [Updated] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9897: --- Affects Version/s: 1.4.2 1.5.1 > Further enhance adaptiveReads in Kinesis

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-07-24 Thread Juan Miguel Cejuela (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554689#comment-16554689 ] Juan Miguel Cejuela commented on FLINK-7811: Moved to 1.7.0? So unfortunate :-( By that

[jira] [Commented] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

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

[GitHub] flink pull request #6408: [FLINK-9897] Make adaptive reads depend on run loo...

2018-07-24 Thread glaksh100
GitHub user glaksh100 opened a pull request: https://github.com/apache/flink/pull/6408 [FLINK-9897] Make adaptive reads depend on run loop time instead of fetchintervalmillis ## What is the purpose of the change [FLINK-9692](https://github.com/apache/flink/pull/6300) introduced

[jira] [Updated] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

2018-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9897: -- Labels: pull-request-available (was: ) > Further enhance adaptiveReads in Kinesis Connector

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554732#comment-16554732 ] Lakshmi Rao commented on FLINK-9899: [~yanghua] Are you planning on working on this?  I have changes

[jira] [Updated] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao updated FLINK-9899: --- Affects Version/s: 1.4.2 1.5.1 > Add more metrics to the Kinesis source

[jira] [Assigned] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lakshmi Rao reassigned FLINK-9897: -- Assignee: Lakshmi Rao > Further enhance adaptiveReads in Kinesis Connector to read more

[jira] [Commented] (FLINK-9098) ClassLoaderITCase unstable

2018-07-24 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554024#comment-16554024 ] Piotr Nowojski commented on FLINK-9098: --- Ops sorry my bad, now I remembered. I didn't manage to

[jira] [Commented] (FLINK-9906) Flink Job not running with no resource

2018-07-24 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554033#comment-16554033 ] godfrey johnson commented on FLINK-9906: https://issues.apache.org/jira/browse/FLINK-8275

[jira] [Closed] (FLINK-9906) Flink Job not running with no resource

2018-07-24 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey johnson closed FLINK-9906. -- Resolution: Fixed Fix Version/s: 1.6.0 > Flink Job not running with no resource >

[jira] [Updated] (FLINK-9928) Add LOG2 function for table/sql API

2018-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9928: -- Labels: pull-request-available (was: ) > Add LOG2 function for table/sql API >

[jira] [Commented] (FLINK-9928) Add LOG2 function for table/sql API

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

[GitHub] flink pull request #6404: [FLINK-9928] Add LOG2 function for table/sql API

2018-07-24 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/6404 [FLINK-9928] Add LOG2 function for table/sql API ## What is the purpose of the change *This pull request adds LOG2 function for table/sql API* ## Brief change log - *Add

[jira] [Created] (FLINK-9933) Simplify taskmanager memory default values

2018-07-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9933: --- Summary: Simplify taskmanager memory default values Key: FLINK-9933 URL: https://issues.apache.org/jira/browse/FLINK-9933 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9933) Simplify taskmanager memory default values

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9933: Priority: Minor (was: Major) > Simplify taskmanager memory default values >

[GitHub] flink pull request #6392: [FLINK-9694][table] Fix NPE in CRowSerializerConfi...

2018-07-24 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/6392#discussion_r204684670 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerConfigSnapshot.java --- @@ -46,8 +46,6 @@ public

[jira] [Commented] (FLINK-9694) Potentially NPE in CompositeTypeSerializerConfigSnapshot constructor

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

[GitHub] flink pull request #6073: [FLINK-9091] [table] Fix dependency convergence fo...

2018-07-24 Thread twalthr
Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/6073 ---

[jira] [Created] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-07-24 Thread Renjie Liu (JIRA)
Renjie Liu created FLINK-9936: - Summary: Mesos resource manager unable to connect to master after failover Key: FLINK-9936 URL: https://issues.apache.org/jira/browse/FLINK-9936 Project: Flink

[jira] [Assigned] (FLINK-9933) Simplify taskmanager memory default values

2018-07-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9933: --- Assignee: vinoyang > Simplify taskmanager memory default values >

[jira] [Updated] (FLINK-9935) Batch Table API: grouping by window and attribute causes java.lang.ClassCastException:

2018-07-24 Thread Roman Wozniak (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Wozniak updated FLINK-9935: - Priority: Blocker (was: Major) > Batch Table API: grouping by window and attribute causes >

[jira] [Reopened] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9765: - > Improve CLI responsiveness when cluster is not reachable >

[jira] [Updated] (FLINK-9935) Batch Table API: grouping by window and attribute causes java.lang.ClassCastException:

2018-07-24 Thread Roman Wozniak (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Wozniak updated FLINK-9935: - Component/s: Table API & SQL > Batch Table API: grouping by window and attribute causes >

[jira] [Closed] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9765. --- Resolution: Fixed > Improve CLI responsiveness when cluster is not reachable >

[jira] [Updated] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9765: Fix Version/s: (was: 1.5.2) 1.5.3 > Improve CLI responsiveness when

[jira] [Closed] (FLINK-9602) Extend CommonOption section

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9602. --- Resolution: Invalid Fix Version/s: (was: 1.6.0) The current section looks

[GitHub] flink pull request #6402: [FLINK-9914][docs] Update Docker docs

2018-07-24 Thread patricklucas
GitHub user patricklucas opened a pull request: https://github.com/apache/flink/pull/6402 [FLINK-9914][docs] Update Docker docs ## What is the purpose of the change Clarify the Docker-related docs for current releases. You can merge this pull request into a Git repository

[jira] [Updated] (FLINK-9914) Flink docker information in official website is out of date and should be update

2018-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9914: -- Labels: pull-request-available (was: ) > Flink docker information in official website is out

[jira] [Commented] (FLINK-9914) Flink docker information in official website is out of date and should be update

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

[jira] [Commented] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554042#comment-16554042 ] ASF GitHub Bot commented on FLINK-9765: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9694) Potentially NPE in CompositeTypeSerializerConfigSnapshot constructor

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

[GitHub] flink pull request #6265: [FLINK-9765] [sql-client] Improve CLI responsivene...

2018-07-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6265 ---

[GitHub] flink pull request #6392: [FLINK-9694][table] Fix NPE in CRowSerializerConfi...

2018-07-24 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6392#discussion_r204696678 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerConfigSnapshot.java --- @@ -46,8 +46,6 @@ public

[jira] [Closed] (FLINK-9098) ClassLoaderITCase unstable

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

[jira] [Closed] (FLINK-9704) QueryableState E2E test failed on travis

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9704. --- Resolution: Fixed Assignee: Chesnay Schepler Fix Version/s: 1.6.0 May have

[jira] [Updated] (FLINK-9934) Kafka table source factory produces invalid field mapping

2018-07-24 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9934: Issue Type: Bug (was: Improvement) > Kafka table source factory produces invalid field mapping >

[jira] [Commented] (FLINK-9927) Error in Python Stream API example on website

2018-07-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553994#comment-16553994 ] Chesnay Schepler commented on FLINK-9927: - the example should use {{output()}} instead of

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

2018-07-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9862. Resolution: Fixed Merged. 1.7.0: b9a916afee65913c113cf4f6fdf314576644eb19 1.6.0:

[jira] [Commented] (FLINK-9934) Kafka table source factory produces invalid field mapping

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

[GitHub] flink issue #6265: [FLINK-9765] [sql-client] Improve CLI responsiveness when...

2018-07-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6265 Thank you @yanghua and @zentol. Merging this... ---

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554027#comment-16554027 ] ASF GitHub Bot commented on FLINK-9091: --- Github user twalthr closed the pull request at:

[jira] [Commented] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

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

[GitHub] flink pull request #6409: Flink 9899.kinesis connector metrics

2018-07-24 Thread glaksh100
GitHub user glaksh100 opened a pull request: https://github.com/apache/flink/pull/6409 Flink 9899.kinesis connector metrics ## What is the purpose of the change The purpose of this change is to add metrics to the `ShardConsumer` to get more observability into the

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

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

[jira] [Comment Edited] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554822#comment-16554822 ] Lakshmi Rao edited comment on FLINK-9899 at 7/24/18 9:35 PM: - [~yanghua] I

[GitHub] flink pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive read...

2018-07-24 Thread tweise
Github user tweise commented on a diff in the pull request: https://github.com/apache/flink/pull/6408#discussion_r204922265 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@ -233,26

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

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

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-24 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554866#comment-16554866 ] Rong Rong commented on FLINK-9294: -- Had an initial diff for discussion on what needs to be done here:

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554822#comment-16554822 ] Lakshmi Rao commented on FLINK-9899: [~yanghua] I created a PR with my changes - Let me know what you

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread Lakshmi Rao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554917#comment-16554917 ] Lakshmi Rao commented on FLINK-9899: Thanks [~yanghua] !  > Add more metrics to the Kinesis source

[GitHub] flink pull request #6401: [hotfix]fix typo for variable name dynamicProperti...

2018-07-24 Thread rileyli
Github user rileyli closed the pull request at: https://github.com/apache/flink/pull/6401 ---

[GitHub] flink pull request #6410: Release 1.6

2018-07-24 Thread uang520
GitHub user uang520 opened a pull request: https://github.com/apache/flink/pull/6410 Release 1.6 *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 contribution in the best possible way,

[GitHub] flink pull request #6410: Release 1.6

2018-07-24 Thread uang520
Github user uang520 closed the pull request at: https://github.com/apache/flink/pull/6410 ---

[GitHub] flink issue #6399: [FLINK-5860] [tests] Replace java.io.tmpdir with JUnit Te...

2018-07-24 Thread maheshsenni
Github user maheshsenni commented on the issue: https://github.com/apache/flink/pull/6399 @zentol I have addressed your comments in a new commit. Can you look into it please? ---

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

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

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

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

[GitHub] flink pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive read...

2018-07-24 Thread glaksh100
Github user glaksh100 commented on a diff in the pull request: https://github.com/apache/flink/pull/6408#discussion_r204942574 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java --- @@

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554915#comment-16554915 ] vinoyang commented on FLINK-9899: - hi [~glaksh100] I have not started this issue yet. I have released the

[jira] [Assigned] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9899: --- Assignee: Lakshmi Rao (was: vinoyang) > Add more metrics to the Kinesis source connector >

[jira] [Created] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

2018-07-24 Thread Huyen Levan (JIRA)
Huyen Levan created FLINK-9940: -- Summary: File source continuous monitoring mode: S3 files sometimes missed Key: FLINK-9940 URL: https://issues.apache.org/jira/browse/FLINK-9940 Project: Flink

[jira] [Updated] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

2018-07-24 Thread Huyen Levan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huyen Levan updated FLINK-9940: --- Priority: Blocker (was: Major) > File source continuous monitoring mode: S3 files sometimes missed

[jira] [Commented] (FLINK-9834) Unable to support scala BasicArrayTypeInfo

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555157#comment-16555157 ] buptljy commented on FLINK-9834: It seems that we can use _*implicitly[TypeInformation[Array[Byte]]]*_ to

[jira] [Closed] (FLINK-9834) Unable to support scala BasicArrayTypeInfo

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] buptljy closed FLINK-9834. -- Resolution: Won't Do > Unable to support scala BasicArrayTypeInfo > --

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-07-24 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555162#comment-16555162 ] Timo Walther commented on FLINK-5315: - Thanks for working on this [~walterddr].

[jira] [Assigned] (FLINK-6938) IterativeCondition should support RichFunction interface

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] buptljy reassigned FLINK-6938: -- Assignee: buptljy (was: Jark Wu) > IterativeCondition should support RichFunction interface >

[jira] [Assigned] (FLINK-6938) IterativeCondition should support RichFunction interface

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] buptljy reassigned FLINK-6938: -- Assignee: Jark Wu (was: buptljy) > IterativeCondition should support RichFunction interface >

[jira] [Commented] (FLINK-6935) Integration of SQL and CEP

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555165#comment-16555165 ] buptljy commented on FLINK-6935: I am very interested in the CEP part. And my team is exploring this

[jira] [Created] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2018-07-24 Thread Rannn Tao (JIRA)
Rannn Tao created FLINK-9941: Summary: Flush in ScalaCsvOutputFormat before close method Key: FLINK-9941 URL: https://issues.apache.org/jira/browse/FLINK-9941 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2018-07-24 Thread Rannn Tao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rannn Tao updated FLINK-9941: - Description: Because not every stream's close method will flush, in order to ensure the stability of

[jira] [Updated] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2018-07-24 Thread Rannn Tao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rannn Tao updated FLINK-9941: - Description: Because not every stream's close method will flush, in order to ensure the stability of

[jira] [Assigned] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] buptljy reassigned FLINK-9941: -- Assignee: buptljy > Flush in ScalaCsvOutputFormat before close method >

[jira] [Commented] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

2018-07-24 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555175#comment-16555175 ] buptljy commented on FLINK-9941: [~lemonjing] You're right. I'll fix it. > Flush in ScalaCsvOutputFormat

[GitHub] flink pull request #6406: [FLINK-9159][runtime] Sanity check default timeout...

2018-07-24 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/6406 [FLINK-9159][runtime] Sanity check default timeout values ## What is the purpose of the change *Set the default timeouts for resource release to sane values. Consolidate config keys and

[GitHub] flink issue #6396: [FLINK-9806][docs] Add canonical link element to docs

2018-07-24 Thread patricklucas
Github user patricklucas commented on the issue: https://github.com/apache/flink/pull/6396 The "hotfix" was a necessary modification to the dev-only helper scripts for building the docs locally. I assumed that it would just get squashed into the main commit when being merged, though

[jira] [Updated] (FLINK-9159) Sanity check default timeout values

2018-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9159: -- Labels: flip-6 pull-request-available (was: flip-6) > Sanity check default timeout values >

[jira] [Commented] (FLINK-9806) Add a canonical link element to documentation HTML

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

[jira] [Commented] (FLINK-9159) Sanity check default timeout values

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

[GitHub] flink pull request #6406: [FLINK-9159][runtime] Sanity check default timeout...

2018-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6406#discussion_r204819304 --- Diff: flink-docs/README.md --- @@ -28,7 +28,7 @@ The `RestAPIDocGenerator` can be used to generate a full reference of the REST A To integrate a new

[jira] [Commented] (FLINK-9159) Sanity check default timeout values

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

[GitHub] flink issue #6396: [FLINK-9806][docs] Add canonical link element to docs

2018-07-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6396 we can keep the hotfix in this PR but it shouldn't be squashed into the main commit as it is unrelated. ---

[jira] [Commented] (FLINK-9806) Add a canonical link element to documentation HTML

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

[GitHub] flink pull request #6406: [FLINK-9159][runtime] Sanity check default timeout...

2018-07-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6406#discussion_r204820593 --- Diff: flink-docs/README.md --- @@ -28,7 +28,7 @@ The `RestAPIDocGenerator` can be used to generate a full reference of the REST A To integrate a new

[jira] [Commented] (FLINK-9159) Sanity check default timeout values

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

[jira] [Commented] (FLINK-9098) ClassLoaderITCase unstable

2018-07-24 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554473#comment-16554473 ] Andrey Zagrebin commented on FLINK-9098: I also looped it 668 iterations, no error:

[GitHub] flink pull request #6407: [FLINK-8478][docs] Add documentation page for diff...

2018-07-24 Thread florianschmidt1994
GitHub user florianschmidt1994 opened a pull request: https://github.com/apache/flink/pull/6407 [FLINK-8478][docs] Add documentation page for different datastream joins ## What is the purpose of the change Add a documentation page under Application Development / Streaming /

  1   2   3   >