[jira] [Closed] (FLINK-2739) Release script depends on the order of parent module information

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2739. --- Resolution: Won't Fix > Release script depends on the order of parent module information >

[jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2491: Fix Version/s: (was: 1.0.0) > Checkpointing only works if all operators/tasks are

[jira] [Updated] (FLINK-3249) Wrong "unknown partition state/input gate" error messages

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3249: Fix Version/s: (was: 1.0.0) > Wrong "unknown partition state/input gate" error

[jira] [Updated] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3154: Fix Version/s: (was: 1.0.0) > Update Kryo version from 2.24.0 to 3.0.3 >

[jira] [Updated] (FLINK-3448) WebRuntimeMonitor: Move initialization of handlers to start() method

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3448: Fix Version/s: (was: 1.0.0) > WebRuntimeMonitor: Move initialization of handlers to

[jira] [Updated] (FLINK-3388) Expose task accumulators via JMX

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3388: Fix Version/s: (was: 1.0.0) > Expose task accumulators via JMX >

[jira] [Updated] (FLINK-2739) Release script depends on the order of parent module information

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2739: Fix Version/s: (was: 1.0.0) > Release script depends on the order of parent module

[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577935#comment-16577935 ] ASF GitHub Bot commented on FLINK-6437: --- yanghua edited a comment on issue #6542:

[jira] [Commented] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

2018-08-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577974#comment-16577974 ] Till Rohrmann commented on FLINK-8336: -- Another instance:

[GitHub] tillrohrmann commented on issue #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

2018-08-13 Thread GitBox
tillrohrmann commented on issue #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client URL: https://github.com/apache/flink/pull/6539#issuecomment-412454181 Thanks for the review @zentol and @yanghua. Waiting for Travis to become stable again

[jira] [Commented] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577988#comment-16577988 ] ASF GitHub Bot commented on FLINK-10123: tillrohrmann commented on issue #6539: [FLINK-10123]

[jira] [Created] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file

2018-08-13 Thread Keshav Lodhi (JIRA)
Keshav Lodhi created FLINK-10130: Summary: How to define two hdfs name-node IPs in flink-conf.yaml file Key: FLINK-10130 URL: https://issues.apache.org/jira/browse/FLINK-10130 Project: Flink

[jira] [Commented] (FLINK-10048) Migrate module flink-gelly-examples to flink-examples and rename it

2018-08-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578024#comment-16578024 ] vinoyang commented on FLINK-10048: -- [~till.rohrmann] Ok, I agree. And I haven't started yet. In

[GitHub] NicoK closed pull request #6470: [FLINK-10006][network] improve logging in BarrierBuffer: prepend owning task name

2018-08-13 Thread GitBox
NicoK closed pull request #6470: [FLINK-10006][network] improve logging in BarrierBuffer: prepend owning task name URL: https://github.com/apache/flink/pull/6470 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Closed] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2540. --- Resolution: Cannot Reproduce > LocalBufferPool.requestBuffer gets into infinite loop >

[jira] [Updated] (FLINK-10001) Improve Kubernetes documentation

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10001: - Fix Version/s: (was: 1.6.0) 1.6.1 > Improve Kubernetes

[jira] [Updated] (FLINK-9510) State TTL API with cleanup on explicit access

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9510: Fix Version/s: (was: 1.6.0) 1.6.1 > State TTL API with cleanup on

[jira] [Commented] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

2018-08-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577972#comment-16577972 ] Till Rohrmann commented on FLINK-8408: -- Are you still working on this issue [~NicoK]? >

[jira] [Updated] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-08-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9920: - Fix Version/s: 1.7.0 > BucketingSinkFaultToleranceITCase fails on travis >

[jira] [Commented] (FLINK-10104) Job super slow to start

2018-08-13 Thread Florian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577989#comment-16577989 ] Florian commented on FLINK-10104: - Hi [~gjy], Thanky a lot for your time and your investigation. I

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-08-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578001#comment-16578001 ] Till Rohrmann commented on FLINK-10074: --- I would be ok with defining the maximum number of

[jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

2018-08-13 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578017#comment-16578017 ] Sebastian Klemke commented on FLINK-9891: - Exactly, in the past, doing exactly that proved to be

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578040#comment-16578040 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW commented on a change in pull request #6417:

[GitHub] yanghua commented on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-13 Thread GitBox
yanghua commented on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#issuecomment-412495733 @twalthr Does this PR look good to you? This is an

[jira] [Commented] (FLINK-10066) Keep only archived version of previous executions

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578181#comment-16578181 ] ASF GitHub Bot commented on FLINK-10066: StefanRRichter commented on issue #6500: [FLINK-10066]

[GitHub] StefanRRichter commented on issue #6500: [FLINK-10066] Keep only archived version of previous executions

2018-08-13 Thread GitBox
StefanRRichter commented on issue #6500: [FLINK-10066] Keep only archived version of previous executions URL: https://github.com/apache/flink/pull/6500#issuecomment-412497332 Thanks for the review @zentol! Will merge. This

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578188#comment-16578188 ] ASF GitHub Bot commented on FLINK-10012: StefanRRichter commented on issue #6475: [FLINK-10012]

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578202#comment-16578202 ] ASF GitHub Bot commented on FLINK-7205: --- twalthr commented on a change in pull request #6381:

[GitHub] twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r209584866 ## File path:

[GitHub] twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r209586333 ## File path:

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578199#comment-16578199 ] ASF GitHub Bot commented on FLINK-7205: --- twalthr commented on a change in pull request #6381:

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578198#comment-16578198 ] ASF GitHub Bot commented on FLINK-7205: --- twalthr commented on a change in pull request #6381:

[GitHub] twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r209585954 ## File path:

[GitHub] twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r209585386 ## File path:

[GitHub] twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r209586160 ## File path:

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578200#comment-16578200 ] ASF GitHub Bot commented on FLINK-7205: --- twalthr commented on a change in pull request #6381:

[GitHub] twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r209584511 ## File path: docs/dev/table/sql.md ## @@ -1664,6 +1664,17 @@ RAND_INTEGER(seed integer,

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578201#comment-16578201 ] ASF GitHub Bot commented on FLINK-7205: --- twalthr commented on a change in pull request #6381:

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578203#comment-16578203 ] ASF GitHub Bot commented on FLINK-7205: --- twalthr commented on a change in pull request #6381:

[GitHub] zentol commented on issue #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5

2018-08-13 Thread GitBox
zentol commented on issue #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5 URL: https://github.com/apache/flink/pull/6511#issuecomment-412499229 the added migration versions can be verified by running the test locally. Verifying the savepoint is a bit trickier as

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

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578216#comment-16578216 ] ASF GitHub Bot commented on FLINK-6895: --- twalthr commented on a change in pull request #6359:

[jira] [Commented] (FLINK-10085) Update AbstractOperatorRestoreTestBase

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578224#comment-16578224 ] ASF GitHub Bot commented on FLINK-10085: zentol commented on issue #6511: [FLINK-10085][tests]

[GitHub] zentol commented on issue #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5

2018-08-13 Thread GitBox
zentol commented on issue #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5 URL: https://github.com/apache/flink/pull/6511#issuecomment-412503331 I'm not sure about the binary contents being deterministic, but the _state_ contents most definitely should be. I'm

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578231#comment-16578231 ] ASF GitHub Bot commented on FLINK-10107: twalthr commented on issue #6534: [FLINK-10107]

[GitHub] zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-13 Thread GitBox
zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-412508686 so, given that we do not care about situations where multiple connectors are on the CP (as concluded in previous

[GitHub] zentol commented on a change in pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink

2018-08-13 Thread GitBox
zentol commented on a change in pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink URL: https://github.com/apache/flink/pull/6532#discussion_r209600326 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -0,0 +1,123 @@ +--- +title: "Streaming

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578262#comment-16578262 ] ASF GitHub Bot commented on FLINK-7205: --- buptljy commented on issue #6381: [FLINK-7205] [table] Add

[GitHub] buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-13 Thread GitBox
buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-412511793 @twalthr Thanks! I've already fixed them. This is an

[GitHub] Guibo-Pan commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

2018-08-13 Thread GitBox
Guibo-Pan commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#discussion_r209612423 ## File path:

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578174#comment-16578174 ] ASF GitHub Bot commented on FLINK-10059: yanghua commented on issue #6494: [FLINK-10059] [table]

[jira] [Commented] (FLINK-9853) add hex support in table api and sql

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578171#comment-16578171 ] ASF GitHub Bot commented on FLINK-9853: --- twalthr commented on a change in pull request #6337:

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578172#comment-16578172 ] ASF GitHub Bot commented on FLINK-10012: yanghua commented on issue #6475: [FLINK-10012] Add

[jira] [Commented] (FLINK-10085) Update AbstractOperatorRestoreTestBase

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578195#comment-16578195 ] ASF GitHub Bot commented on FLINK-10085: zentol commented on issue #6511: [FLINK-10085][tests]

[GitHub] dawidwys commented on issue #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5

2018-08-13 Thread GitBox
dawidwys commented on issue #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5 URL: https://github.com/apache/flink/pull/6511#issuecomment-412500769 Are the savepoints binary deterministic? I've tried to generate savepoints twice and each time I got different

[jira] [Commented] (FLINK-10104) Job super slow to start

2018-08-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578281#comment-16578281 ] Chesnay Schepler commented on FLINK-10104: -- The version properties are set correctly in the

[GitHub] StefanRRichter commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-13 Thread GitBox
StefanRRichter commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-412497988 @tillrohrmann maybe you could please comment on this?

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578183#comment-16578183 ] ASF GitHub Bot commented on FLINK-10012: zentol commented on issue #6475: [FLINK-10012] Add

[GitHub] zentol commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-13 Thread GitBox
zentol commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-412497674 @StefanRRichter I'm not aware of any such discussion taking place on the public or pmc-private

[jira] [Commented] (FLINK-10085) Update AbstractOperatorRestoreTestBase

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578208#comment-16578208 ] ASF GitHub Bot commented on FLINK-10085: dawidwys commented on issue #6511: [FLINK-10085][tests]

[GitHub] twalthr commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL

2018-08-13 Thread GitBox
twalthr commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL URL: https://github.com/apache/flink/pull/6359#discussion_r209589672 ## File path:

[GitHub] twalthr commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-13 Thread GitBox
twalthr commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-412504536 Currently, only the Kafka JARs are affected. The format JARs have their own namespaces.

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578247#comment-16578247 ] ASF GitHub Bot commented on FLINK-10107: zentol edited a comment on issue #6534: [FLINK-10107]

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578246#comment-16578246 ] ASF GitHub Bot commented on FLINK-10107: zentol commented on issue #6534: [FLINK-10107]

[GitHub] zentol edited a comment on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-13 Thread GitBox
zentol edited a comment on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-412508686 so, given that we do not care about situations where multiple connectors are on the CP (as concluded in

[jira] [Commented] (FLINK-10109) Add documentation for StreamingFileSink

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578254#comment-16578254 ] ASF GitHub Bot commented on FLINK-10109: zentol commented on a change in pull request #6532:

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578299#comment-16578299 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan commented on a change in pull request #6544:

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578456#comment-16578456 ] ASF GitHub Bot commented on FLINK-9739: --- zentol commented on issue #6452: [FLINK-9739] Regression

[GitHub] zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412561511 When would a relative path make sense, and wouldn't this always result in effectively random behavior? I would be fine

[jira] [Commented] (FLINK-9222) Add a Gradle Quickstart

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578467#comment-16578467 ] ASF GitHub Bot commented on FLINK-9222: --- twalthr commented on a change in pull request #105:

[jira] [Commented] (FLINK-9222) Add a Gradle Quickstart

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578466#comment-16578466 ] ASF GitHub Bot commented on FLINK-9222: --- twalthr commented on a change in pull request #105:

[GitHub] StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412565039 Given this implication on Yarn / Mesos, I am +1 to remove the absolute path requirement (my mistake to introduce that in

[GitHub] StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412564568 My understanding is that relative paths may make sense in setups like YARN or Mesos, where the exact temp directories

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578480#comment-16578480 ] ASF GitHub Bot commented on FLINK-9739: --- StephanEwen commented on issue #6452: [FLINK-9739]

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578496#comment-16578496 ] ASF GitHub Bot commented on FLINK-9739: --- StephanEwen commented on issue #6452: [FLINK-9739]

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412570942 @stephanEwen I agree with your point but with the user perspective wouldn't it be odd to provide schema to some config

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578516#comment-16578516 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLINK-9739]

[jira] [Commented] (FLINK-10061) Fix unsupported reconfiguration in KafkaTableSink

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578548#comment-16578548 ] ASF GitHub Bot commented on FLINK-10061: tragicjun commented on issue #6495: [FLINK-10061]

[GitHub] tragicjun commented on issue #6495: [FLINK-10061] [table] [kafka] Fix unsupported reconfiguration in KafkaTableSink

2018-08-13 Thread GitBox
tragicjun commented on issue #6495: [FLINK-10061] [table] [kafka] Fix unsupported reconfiguration in KafkaTableSink URL: https://github.com/apache/flink/pull/6495#issuecomment-412575692 @fhueske @twalthr have you decided that `Table.writeToSink()` would be dropped? If then, this pull

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578448#comment-16578448 ] ASF GitHub Bot commented on FLINK-9739: --- StephanEwen commented on issue #6452: [FLINK-9739]

[GitHub] StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412559130 Do we want to restore the previous behavior? I mean, RocksDB paths must be local file paths. Having URIs with file

[jira] [Commented] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

2018-08-13 Thread Xiangyu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578452#comment-16578452 ] Xiangyu Zhu commented on FLINK-10133: - [~Wosinsan] Sure, but I have no access to my servers right

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578483#comment-16578483 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLINK-9739]

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578484#comment-16578484 ] ASF GitHub Bot commented on FLINK-9739: --- StephanEwen commented on issue #6452: [FLINK-9739]

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412565010 If we decide to provide file paths without the schema then the same provision must be provided for all other

[GitHub] StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-412566310 @sampathBhat There are two very different config parameter types: URIs across file systems (like where checkpoints go

[GitHub] StephanEwen commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file

2018-08-13 Thread GitBox
StephanEwen commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file URL: https://github.com/apache/flink/pull/6542#issuecomment-412570277 @yanghua You are right, this was not marked as "later" or anything in JIRA. There is never really

[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578511#comment-16578511 ] ASF GitHub Bot commented on FLINK-6437: --- StephanEwen commented on issue #6542: [FLINK-6437][History

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

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578312#comment-16578312 ] ASF GitHub Bot commented on FLINK-6895: --- buptljy commented on a change in pull request #6359:

[GitHub] buptljy commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL

2018-08-13 Thread GitBox
buptljy commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL URL: https://github.com/apache/flink/pull/6359#discussion_r209618514 ## File path:

[jira] [Commented] (FLINK-10131) Improve logging around ResultSubpartition

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578317#comment-16578317 ] ASF GitHub Bot commented on FLINK-10131: NicoK opened a new pull request #6547:

[jira] [Updated] (FLINK-10131) Improve logging around ResultSubpartition

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10131: --- Labels: pull-request-available (was: ) > Improve logging around ResultSubpartition >

[GitHub] NicoK opened a new pull request #6547: [FLINK-10131][network] improve logging around subpartitions

2018-08-13 Thread GitBox
NicoK opened a new pull request #6547: [FLINK-10131][network] improve logging around subpartitions URL: https://github.com/apache/flink/pull/6547 ## What is the purpose of the change This PR improves several log messages in `PipelinedSubpartition` and `PipelinedSubpartition`.

[GitHub] zentol commented on a change in pull request #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-13 Thread GitBox
zentol commented on a change in pull request #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#discussion_r209628463 ## File path:

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

2018-08-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578333#comment-16578333 ] ASF GitHub Bot commented on FLINK-9739: --- zentol commented on a change in pull request #6452:

[jira] [Created] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

2018-08-13 Thread Xiangyu Zhu (JIRA)
Xiangyu Zhu created FLINK-10133: --- Summary: finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters) Key: FLINK-10133 URL:

[jira] [Updated] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

2018-08-13 Thread Xiangyu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiangyu Zhu updated FLINK-10133: Description: Hi, We have 3 servers in our test environment, noted as node1-3. Setup is as

[GitHub] aljoscha commented on issue #6536: Fix Javadoc links in documentation

2018-08-13 Thread GitBox
aljoscha commented on issue #6536: Fix Javadoc links in documentation URL: https://github.com/apache/flink/pull/6536#issuecomment-412542148 `update_branch_version.sh` is only used on master to update, e.g. `1.6-SNAPSHOT` to `1.7-SNAPSHOT`. If we always point to the "master" docs from

[GitHub] fhueske commented on a change in pull request #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs

2018-08-13 Thread GitBox
fhueske commented on a change in pull request #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs URL: https://github.com/apache/flink/pull/6535#discussion_r209626394 ## File path:

[jira] [Updated] (FLINK-9938) State TTL cleanup of full state snapshot upon checkpointing

2018-08-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9938: --- Summary: State TTL cleanup of full state snapshot upon checkpointing (was: State TTL

[jira] [Updated] (FLINK-9938) State TTL cleanup of full state snapshot upon checkpointing

2018-08-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9938: --- Description: We can try to piggyback full state scan during certain checkpoint processes in

<    1   2   3   4   >