[jira] [Commented] (FLINK-8969) Move TimerService into state backend

2018-03-15 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401485#comment-16401485 ] Sihua Zhou commented on FLINK-8969: --- Hi [~phoenixjiangnan], Where is the previous discussion, could you

[jira] [Closed] (FLINK-8364) Add iterator() to ListState which returns empty iterator when it has no value

2018-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-8364. --- Resolution: Invalid > Add iterator() to ListState which returns empty iterator when it has no value >

[jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8771: Affects Version/s: 1.5.0 > Upgrade scalastyle to 1.0.0 > --- > >

[jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0

2018-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8771: Fix Version/s: 1.6.0 > Upgrade scalastyle to 1.0.0 > --- > > Key:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

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

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

2018-03-15 Thread liurenjie1024
Github user liurenjie1024 commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174990348 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,162 @@ +/* + *

[jira] [Commented] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work

2018-03-15 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401420#comment-16401420 ] Wind commented on FLINK-8930: - ok, I've already understood, thanks for the explanations ! > TableApi

[jira] [Commented] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-03-15 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401391#comment-16401391 ] Renjie Liu commented on FLINK-8953: --- Hi, Tim: I want to look into this, could you assign this to me? >

[GitHub] flink issue #5698: [FLINK-8945] [kinesis] Allow customization of KinesisProx...

2018-03-15 Thread tweise
Github user tweise commented on the issue: https://github.com/apache/flink/pull/5698 +1 @StephanEwen can we get this into 1.5.0 ? ---

[jira] [Commented] (FLINK-8945) Allow customization of the KinesisProxy

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401380#comment-16401380 ] ASF GitHub Bot commented on FLINK-8945: --- Github user tweise commented on the issue:

[jira] [Created] (FLINK-8969) Move TimerService into state backend

2018-03-15 Thread Bowen Li (JIRA)
Bowen Li created FLINK-8969: --- Summary: Move TimerService into state backend Key: FLINK-8969 URL: https://issues.apache.org/jira/browse/FLINK-8969 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401356#comment-16401356 ] ASF GitHub Bot commented on FLINK-8915: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5703: [FLINK-8915] CheckpointingStatisticsHandler fails to retu...

2018-03-15 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5703 @tillrohrmann please review this PR, thanks! ---

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

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

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

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

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_...

2018-03-15 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r174962566 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/calcite/rel/rules/AggregateReduceFunctionsRule.java --- @@ -0,0 +1,590 @@ +/* + *

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_...

2018-03-15 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r174965171 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala --- @@ -103,6 +106,19 @@

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401160#comment-16401160 ] ASF GitHub Bot commented on FLINK-8903: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_...

2018-03-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/5706 [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_SAMP, STDEV_POP functions on GROUP BY windows. ## What is the purpose of the change * Fixes the computation of `VAR_SAMP`, `VAR_POP`,

[jira] [Assigned] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8903: Assignee: Fabian Hueske (was: Shuyi Chen) > Built-in agg functions VAR_POP, VAR_SAMP,

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

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

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 Travis CI pending after rebasing this, will push as soon at it gives us a green light... ---

[jira] [Commented] (FLINK-8304) Document Kubernetes and Flink HA setup

2018-03-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401026#comment-16401026 ] Ufuk Celebi commented on FLINK-8304: I think your understanding is correct (although the terminology

[jira] [Closed] (FLINK-7283) PythonPlanBinderTest issues with python paths

2018-03-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7283. -- Resolution: Fixed > PythonPlanBinderTest issues with python paths >

[jira] [Reopened] (FLINK-7283) PythonPlanBinderTest issues with python paths

2018-03-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7283: > PythonPlanBinderTest issues with python paths >

[jira] [Updated] (FLINK-7283) PythonPlanBinderTest issues with python paths

2018-03-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7283: --- Fix Version/s: (was: 1.3.4) 1.3.3 > PythonPlanBinderTest

[jira] [Updated] (FLINK-7282) Credit-based Network Flow Control

2018-03-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7282: External issue URL: https://docs.google.com/document/d/1chTOuOqe0sBsjldA_r-wXYeSIhU2zRGpUaTaik7QZ84

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400990#comment-16400990 ] Shuyi Chen commented on FLINK-8903: --- Hi [~fhueske], please work on it if you are already in the middle.

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400963#comment-16400963 ] Fabian Hueske commented on FLINK-8903: -- Thanks Shuyi! In fact, I was curious how hard it would be to

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400925#comment-16400925 ] Shuyi Chen commented on FLINK-8903: --- [~fhueske], I can help take a look at this issue. > Built-in agg

[jira] [Assigned] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-8903: - Assignee: Shuyi Chen > Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are

[jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2018-03-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7775: -- Description: {code} public int getNumberOfCachedJobs() { return jobRefCounters.size(); } {code} The

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400743#comment-16400743 ] Fernando Díaz commented on FLINK-6895: -- Do you mean the string to format? It can be a column

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Description: The built-in aggregation functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are

[jira] [Reopened] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStr

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8685: - reopen to change fixVersion > Code of method >

[jira] [Closed] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStrea

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8685. --- Resolution: Duplicate Fix Version/s: (was: 1.5.0) > Code of method >

[jira] [Reopened] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent()

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8806: - reopen to fix fixVErsion > Failure in UnionInputGate getNextBufferOrEvent() >

[jira] [Closed] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent()

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8806. --- Resolution: Duplicate Fix Version/s: (was: 1.6.0) (was:

[jira] [Closed] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8885. --- Resolution: Duplicate Fix Version/s: (was: 1.6.0) (was:

[jira] [Reopened] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8885: - reopen to fix fixVersion > The DispatcherThreadFactory should register uncaught exception

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Affects Version/s: (was: 1.4.1) 1.5.0 1.3.2

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Description: The built-in aggregation functions   was: Error calculation based on rolling

[jira] [Updated] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8903: - Summary: Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400662#comment-16400662 ] ASF GitHub Bot commented on FLINK-8968: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-15 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5705 LGTM 👍 ---

[jira] [Commented] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400654#comment-16400654 ] Fabian Hueske commented on FLINK-8903: -- Hi [~lilizhao], Sorry for being too eager when closing the

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400650#comment-16400650 ] ASF GitHub Bot commented on FLINK-8968: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-15 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 @StefanRRichter Could you please have a look at this? ---

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400646#comment-16400646 ] ASF GitHub Bot commented on FLINK-8968: --- GitHub user sihuazhou opened a pull request:

[GitHub] flink pull request #5705: [FLINK-8968][state]Fix native resource leak caused...

2018-03-15 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5705 [FLINK-8968][state]Fix native resource leak caused by ReadOptions ## What is the purpose of the change This PR fixes (FLINK-8968)[https://issues.apache.org/jira/browse/FLINK-8968] Pull

[jira] [Created] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-15 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8968: - Summary: Fix native resource leak caused by ReadOptions Key: FLINK-8968 URL: https://issues.apache.org/jira/browse/FLINK-8968 Project: Flink Issue Type: Bug

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

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

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

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

[GitHub] flink pull request #5675: [FLINK-7804][flip6] YarnResourceManager does not e...

2018-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5675#discussion_r174834515 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -325,67 +328,74 @@ public float getProgress() {

[GitHub] flink pull request #5675: [FLINK-7804][flip6] YarnResourceManager does not e...

2018-03-15 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5675#discussion_r174834772 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -395,10 +405,13 @@ public void onNodesUpdated(List list) {

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-15 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400595#comment-16400595 ] Sihua Zhou commented on FLINK-8922: --- Hmm... I will try it out, I'm looping the code of

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400580#comment-16400580 ] Stephan Ewen commented on FLINK-8922: - If I see this correctly, we still assume it is related to

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

2018-03-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400570#comment-16400570 ] Jan Lukavský commented on FLINK-8297: - Yes, that seems related. I'm not 100% convinced that simply

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

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

[GitHub] flink pull request #5704: [FLINK-8852] [sql-client] Add FLIP-6 support to SQ...

2018-03-15 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5704 [FLINK-8852] [sql-client] Add FLIP-6 support to SQL Client ## What is the purpose of the change This PR adds support for the new FLIP-6 mode in the SQL Client. For now, we only test the

[jira] [Closed] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-8930. Resolution: Not A Problem > TableApi validation test in ScalarFunctionsValidationTest doesn't work

[jira] [Commented] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400561#comment-16400561 ] Fabian Hueske commented on FLINK-8930: -- OK, I see what you mean. The difference is that the SQL

[jira] [Comment Edited] (FLINK-8930) TableApi validation test in ScalarFunctionsValidationTest doesn't work

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400561#comment-16400561 ] Fabian Hueske edited comment on FLINK-8930 at 3/15/18 3:17 PM: --- OK, I see

[jira] [Created] (FLINK-8967) Port NetworkStackThroughputITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8967: --- Summary: Port NetworkStackThroughputITCase to flip6 Key: FLINK-8967 URL: https://issues.apache.org/jira/browse/FLINK-8967 Project: Flink Issue Type:

[jira] [Created] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8966: --- Summary: Port AvroExternalJarProgramITCase to flip6 Key: FLINK-8966 URL: https://issues.apache.org/jira/browse/FLINK-8966 Project: Flink Issue Type:

[jira] [Created] (FLINK-8965) Port TimestampITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8965: --- Summary: Port TimestampITCase to flip6 Key: FLINK-8965 URL: https://issues.apache.org/jira/browse/FLINK-8965 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400529#comment-16400529 ] Timo Walther commented on FLINK-6895: - No, it is the first case that the return type depends on a

[jira] [Created] (FLINK-8964) Port JobSubmissionFailsITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8964: --- Summary: Port JobSubmissionFailsITCase to flip6 Key: FLINK-8964 URL: https://issues.apache.org/jira/browse/FLINK-8964 Project: Flink Issue Type:

[jira] [Created] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8963: --- Summary: Port BigUserProgramJobSubmitITCase to flip6 Key: FLINK-8963 URL: https://issues.apache.org/jira/browse/FLINK-8963 Project: Flink Issue Type:

[jira] [Created] (FLINK-8962) Port AccumulatorErrorITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8962: --- Summary: Port AccumulatorErrorITCase to flip6 Key: FLINK-8962 URL: https://issues.apache.org/jira/browse/FLINK-8962 Project: Flink Issue Type:

[jira] [Created] (FLINK-8961) Port JobRetrievalITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8961: --- Summary: Port JobRetrievalITCase to flip6 Key: FLINK-8961 URL: https://issues.apache.org/jira/browse/FLINK-8961 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-8702) Migrate tests from FlinkMiniCluster to MiniClusterResource

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8702: --- Assignee: Chesnay Schepler > Migrate tests from FlinkMiniCluster to

[jira] [Created] (FLINK-8959) Port AccumulatorLiveITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8959: --- Summary: Port AccumulatorLiveITCase to flip6 Key: FLINK-8959 URL: https://issues.apache.org/jira/browse/FLINK-8959 Project: Flink Issue Type:

[jira] [Created] (FLINK-8960) Port SavepointITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8960: --- Summary: Port SavepointITCase to flip6 Key: FLINK-8960 URL: https://issues.apache.org/jira/browse/FLINK-8960 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8958) Port TaskCancelAsyncProducerConsumerITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8958: --- Summary: Port TaskCancelAsyncProducerConsumerITCase to flip6 Key: FLINK-8958 URL: https://issues.apache.org/jira/browse/FLINK-8958 Project: Flink

[jira] [Created] (FLINK-8957) Port JMXJobManagerMetricTest to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8957: --- Summary: Port JMXJobManagerMetricTest to flip6 Key: FLINK-8957 URL: https://issues.apache.org/jira/browse/FLINK-8957 Project: Flink Issue Type:

[jira] [Created] (FLINK-8956) Port RescalingITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8956: --- Summary: Port RescalingITCase to flip6 Key: FLINK-8956 URL: https://issues.apache.org/jira/browse/FLINK-8956 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8955) Port ClassLoaderITCase to flip6

2018-03-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8955: --- Summary: Port ClassLoaderITCase to flip6 Key: FLINK-8955 URL: https://issues.apache.org/jira/browse/FLINK-8955 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8948) RescalingITCase fails on Travis

2018-03-15 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400499#comment-16400499 ] Piotr Nowojski commented on FLINK-8948: --- I will take a look at it > RescalingITCase fails on Travis

[jira] [Assigned] (FLINK-8948) RescalingITCase fails on Travis

2018-03-15 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-8948: - Assignee: Piotr Nowojski > RescalingITCase fails on Travis >

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400470#comment-16400470 ] Fabian Hueske commented on FLINK-6895: -- Returning a superclass does not work because Flink generates

[jira] [Updated] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8562: Fix Version/s: 1.5.0 > Fix YARNSessionFIFOSecuredITCase >

[jira] [Commented] (FLINK-8948) RescalingITCase fails on Travis

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400467#comment-16400467 ] Aljoscha Krettek commented on FLINK-8948: - [~NicoK] & [~pnowojski] Seems like the network stack

[jira] [Updated] (FLINK-8948) RescalingITCase fails on Travis

2018-03-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8948: Fix Version/s: 1.5.0 > RescalingITCase fails on Travis > --- >

[jira] [Commented] (FLINK-8952) Support setting the parallelism of individual operators of a query

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400438#comment-16400438 ] Fabian Hueske commented on FLINK-8952: -- Yes, they are definitely related. FLINK-8236 is explicitly

[jira] [Created] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

2018-03-15 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8954: --- Summary: Escape control characters when outputting on SQL Client CLI Key: FLINK-8954 URL: https://issues.apache.org/jira/browse/FLINK-8954 Project: Flink

[jira] [Updated] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

2018-03-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8954: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7594 > Escape control characters

[jira] [Updated] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

2018-03-15 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-8521: -- Priority: Critical (was: Blocker) > FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool

[jira] [Commented] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

2018-03-15 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400410#comment-16400410 ] Piotr Nowojski commented on FLINK-8521: --- This for 99% is another deadlock in Kafka brokers. Symptoms

[jira] [Comment Edited] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400385#comment-16400385 ] Fabian Hueske edited comment on FLINK-8855 at 3/15/18 1:19 PM: --- I ran a

[jira] [Commented] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

2018-03-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400385#comment-16400385 ] Fabian Hueske commented on FLINK-8855: -- I ran a simple {{SELECT a, COUNT(*) FROM x GROUP BY a}} on a

[jira] [Commented] (FLINK-8952) Support setting the parallelism of individual operators of a query

2018-03-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400350#comment-16400350 ] Xingcan Cui commented on FLINK-8952: Hi [~fhueske], thanks for this ticket and I suppose it's related

[jira] [Commented] (FLINK-8949) Rest API failure with long URL

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400326#comment-16400326 ] Chesnay Schepler commented on FLINK-8949: - huh, well that's a problem. Unfortunately the UI

[jira] [Comment Edited] (FLINK-8949) Rest API failure with long URL

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400326#comment-16400326 ] Chesnay Schepler edited comment on FLINK-8949 at 3/15/18 12:41 PM: --- huh,

[jira] [Comment Edited] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-03-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400182#comment-16400182 ] Fernando Díaz edited comment on FLINK-6895 at 3/15/18 12:27 PM: Taking a

[jira] [Updated] (FLINK-8949) Rest API failure with long URL

2018-03-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8949: Affects Version/s: 1.5.0 > Rest API failure with long URL > --

[jira] [Created] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2018-03-15 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8953: --- Summary: Resolve unresolved field references in FieldComputer expressions Key: FLINK-8953 URL: https://issues.apache.org/jira/browse/FLINK-8953 Project: Flink

[jira] [Commented] (FLINK-8906) Flip6DefaultCLI is not tested in org.apache.flink.client.cli tests

2018-03-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400258#comment-16400258 ] ASF GitHub Bot commented on FLINK-8906: --- Github user NicoK commented on the issue:

[GitHub] flink issue #5671: [FLINK-8906][flip6][tests] also test Flip6DefaultCLI in o...

2018-03-15 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5671 Thanks for the review - indeed I copied that part too easily. Fixed now - let's wait for travis to approve the changes though. ---

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

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

  1   2   >