[GitHub] tillrohrmann closed pull request #7443: [hotfix][docs] The CLI doc could not properly shown due to markdown i…

2019-01-10 Thread GitBox
tillrohrmann closed pull request #7443: [hotfix][docs] The CLI doc could not properly shown due to markdown i… URL: https://github.com/apache/flink/pull/7443 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-11082) Increase backlog only if it is available for consumption

2019-01-10 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739246#comment-16739246 ] zhijiang commented on FLINK-11082: -- Considering implementation, it seems a bit complicated for both

[jira] [Updated] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis

2019-01-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10895: - Labels: test-stability (was: ) > TypeSerializerSnapshotMigrationITCase.testSavepoint

[GitHub] tillrohrmann commented on a change in pull request #7414: [FLINK-11253] Add shutdown hook for yarn session client in attached mode

2019-01-10 Thread GitBox
tillrohrmann commented on a change in pull request #7414: [FLINK-11253] Add shutdown hook for yarn session client in attached mode URL: https://github.com/apache/flink/pull/7414#discussion_r246678977 ## File path:

[GitHub] dianfu commented on issue #7381: [FLINK-10593][table, cep] Add support for ALL ROWS PER MATCH

2019-01-10 Thread GitBox
dianfu commented on issue #7381: [FLINK-10593][table, cep] Add support for ALL ROWS PER MATCH URL: https://github.com/apache/flink/pull/7381#issuecomment-453021756 @dawidwys Thanks in advance for reviewing this PR. This is

[jira] [Commented] (FLINK-11298) Scheduling job in the unit of concurrent groups

2019-01-10 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739249#comment-16739249 ] shuai.xu commented on FLINK-11298: -- Hi [~till.rohrmann], thanks for you attention, Yes, this issue is

[jira] [Updated] (FLINK-11293) KafkaITCase.testConcurrentProducerConsumerTopology times out on Travis

2019-01-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11293: - Labels: test-stability (was: ) > KafkaITCase.testConcurrentProducerConsumerTopology

[GitHub] asfgit closed pull request #7437: [FLINK-11278] [docs] Add documentation for TableAPI in scala-shell

2019-01-10 Thread GitBox
asfgit closed pull request #7437: [FLINK-11278] [docs] Add documentation for TableAPI in scala-shell URL: https://github.com/apache/flink/pull/7437 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[GitHub] yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

2019-01-10 Thread GitBox
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-453031536 @pnowojski Just make sure that shall I implement a Class named for example

[GitHub] yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor

2019-01-10 Thread GitBox
yanghua commented on issue #6876: [FLINK-10251] Handle oversized response messages in AkkaRpcActor URL: https://github.com/apache/flink/pull/6876#issuecomment-453008668 @tillrohrmann I have updated this PR. This is an

[jira] [Commented] (FLINK-11297) Add a doc link of jobmanager ha details

2019-01-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739200#comment-16739200 ] vinoyang commented on FLINK-11297: -- cc [~till.rohrmann] and [~Zentol] > Add a doc link of jobmanager

[GitHub] tillrohrmann commented on a change in pull request #7430: [FLINK-10848] Remove container requests after successful container allocation

2019-01-10 Thread GitBox
tillrohrmann commented on a change in pull request #7430: [FLINK-10848] Remove container requests after successful container allocation URL: https://github.com/apache/flink/pull/7430#discussion_r246675293 ## File path: flink-yarn/src/test/resources/log4j-test.properties ##

[GitHub] leesf commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…

2019-01-10 Thread GitBox
leesf commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par… URL: https://github.com/apache/flink/pull/7420#issuecomment-453022668 @walterddr thanks for your reviewing. Updated this pr according to your comment. cc @aljoscha

[GitHub] tillrohrmann commented on issue #7445: [FLINK-11154][network] bump Netty to 4.1.32

2019-01-10 Thread GitBox
tillrohrmann commented on issue #7445: [FLINK-11154][network] bump Netty to 4.1.32 URL: https://github.com/apache/flink/pull/7445#issuecomment-453012828 Thanks for opening this PR @NicoK. Please let us know once the flink-shaded PR has been merged. Maybe you could already run the

[GitHub] aljoscha commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…

2019-01-10 Thread GitBox
aljoscha commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par… URL: https://github.com/apache/flink/pull/7420#issuecomment-453013004 Could we also have a test for this? Otherwise this looks like a good change, as @walterddr said.

[jira] [Comment Edited] (FLINK-11082) Increase backlog only if it is available for consumption

2019-01-10 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739246#comment-16739246 ] zhijiang edited comment on FLINK-11082 at 1/10/19 9:42 AM: --- Considering

[GitHub] aljoscha commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…

2019-01-10 Thread GitBox
aljoscha commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par… URL: https://github.com/apache/flink/pull/7420#issuecomment-453037254 Thanks @leesf! I'll merge once Travis is green.

[jira] [Commented] (FLINK-11298) Scheduling job in the unit of concurrent groups

2019-01-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739192#comment-16739192 ] Till Rohrmann commented on FLINK-11298: --- Hi [~tiemsn], thanks for opening this issue. I think we

[GitHub] tillrohrmann commented on issue #7448: [hotfix][runtime] fix synchronous snapshots completed log

2019-01-10 Thread GitBox
tillrohrmann commented on issue #7448: [hotfix][runtime] fix synchronous snapshots completed log URL: https://github.com/apache/flink/pull/7448#issuecomment-453011825 Thanks for opening this PR @zsq12138. I think we should not exclude the logging statement because also asynchronous

[jira] [Commented] (FLINK-11293) KafkaITCase.testConcurrentProducerConsumerTopology times out on Travis

2019-01-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739202#comment-16739202 ] Till Rohrmann commented on FLINK-11293: --- Another instance:

[GitHub] dawidwys commented on issue #7381: [FLINK-10593][table, cep] Add support for ALL ROWS PER MATCH

2019-01-10 Thread GitBox
dawidwys commented on issue #7381: [FLINK-10593][table, cep] Add support for ALL ROWS PER MATCH URL: https://github.com/apache/flink/pull/7381#issuecomment-453017964 Hi @dianfu , sorry for late response. I will try to have a look at this PR as soon as possible. Unfortunately it might take

[GitHub] zentol commented on issue #7444: [FLINK-11289][examples] Rework examples to account for licensing

2019-01-10 Thread GitBox
zentol commented on issue #7444: [FLINK-11289][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7444#issuecomment-453099291 There's an issue with the NOTICE file merging for these modules, will re-open once i found the cause.

[jira] [Updated] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7359: -- Labels: pull-request-available (was: ) > flink-storm should update ComponentConfiguration to

[jira] [Closed] (FLINK-2606) Extend StormFileSpout to handle HDFS

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2606. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739476#comment-16739476 ] Chesnay Schepler commented on FLINK-11301: -- The linked build finished successfully. > Travis

[GitHub] hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

2019-01-10 Thread GitBox
hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-453096853 @pnowojski Thanks a lot for the view. I have updated the PR according to your suggestions. Mainly include

[GitHub] hequn8128 edited a comment on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

2019-01-10 Thread GitBox
hequn8128 edited a comment on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-453096853 @pnowojski Thanks a lot for the view. I have updated the PR according to your suggestions. Mainly

[jira] [Closed] (FLINK-3117) Storm Tick Tuples are not supported

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3117. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. > Storm

[GitHub] zentol closed pull request #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor…

2019-01-10 Thread GitBox
zentol closed pull request #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor… URL: https://github.com/apache/flink/pull/4467 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] zentol closed pull request #3615: [FLINK-2720] support flink-storm metrics

2019-01-10 Thread GitBox
zentol closed pull request #3615: [FLINK-2720] support flink-storm metrics URL: https://github.com/apache/flink/pull/3615 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull

[jira] [Closed] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2720. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. > Add

[GitHub] zentol commented on issue #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor…

2019-01-10 Thread GitBox
zentol commented on issue #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor… URL: https://github.com/apache/flink/pull/4467#issuecomment-453108058 The storm-compatibility layer will be removed in FLINK-10509. Closing this PR.

[jira] [Closed] (FLINK-3144) [storm] LocalCluster prints nothing without a configured logger

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3144. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Closed] (FLINK-2571) Add task hooks support in Storm-compatibility

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2571. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. > Add

[GitHub] zentol commented on issue #3615: [FLINK-2720] support flink-storm metrics

2019-01-10 Thread GitBox
zentol commented on issue #3615: [FLINK-2720] support flink-storm metrics URL: https://github.com/apache/flink/pull/3615#issuecomment-453108081 The storm-compatibility layer will be removed in FLINK-10509. Closing this PR.

[jira] [Created] (FLINK-11302) FlinkS3FileSystem uses an incorrect path for temporary files.

2019-01-10 Thread Artsem Semianenka (JIRA)
Artsem Semianenka created FLINK-11302: - Summary: FlinkS3FileSystem uses an incorrect path for temporary files. Key: FLINK-11302 URL: https://issues.apache.org/jira/browse/FLINK-11302 Project:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246774009 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246361402 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246785880 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246428260 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246419067 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246774607 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246775496 ## File path:

[jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState

2019-01-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9481: Labels: test-stability (was: ) > FlinkKafkaProducer011ITCase deadlock in initializeState

[jira] [Closed] (FLINK-11278) Add documentation for TableAPI in scala-shell

2019-01-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11278. --- Resolution: Fixed Fix Version/s: 1.8.0 Fixed in master: 

[jira] [Updated] (FLINK-9924) Upgrade zookeeper to 3.4.13

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9924: -- Labels: pull-request-available (was: ) > Upgrade zookeeper to 3.4.13 >

[GitHub] leesf opened a new pull request #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13

2019-01-10 Thread GitBox
leesf opened a new pull request #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13 URL: https://github.com/apache/flink/pull/7449 ## What is the purpose of the change Upgrade zookeeper dependency to 3.4.13. ## Brief change log Upgrade zookeeper dependency to 3.4.13.

[jira] [Commented] (FLINK-11082) Increase backlog only if it is available for consumption

2019-01-10 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739380#comment-16739380 ] Piotr Nowojski commented on FLINK-11082: [~zjwang] why should we report backlog of -1? Shouldn't

[GitHub] zentol opened a new pull request #7456: [FLINK-11289][examples] Rework examples to account for licensing

2019-01-10 Thread GitBox
zentol opened a new pull request #7456: [FLINK-11289][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7456 ## What is the purpose of the change This PR adds separate fat-jar modules for the twitter and state-machine examples so that we

[jira] [Closed] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7359. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Commented] (FLINK-11082) Increase backlog only if it is available for consumption

2019-01-10 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739385#comment-16739385 ] Piotr Nowojski commented on FLINK-11082: Another issue. Could this bug might explain why one

[GitHub] dawidwys commented on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution …

2019-01-10 Thread GitBox
dawidwys commented on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution … URL: https://github.com/apache/flink/pull/7436#issuecomment-453101329 Thanks for the contribution @eaglewatcherwb . I don't think we should introduce incompatibilities with that

[GitHub] zentol closed pull request #7444: [FLINK-11289][examples] Rework examples to account for licensing

2019-01-10 Thread GitBox
zentol closed pull request #7444: [FLINK-11289][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7444 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[jira] [Updated] (FLINK-11289) Rework example module structure to account for licensing

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11289: --- Labels: pull-request-available (was: ) > Rework example module structure to account for

[jira] [Updated] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7359: Component/s: (was: flink-contrib) Storm Compatibility > flink-storm

[jira] [Closed] (FLINK-2588) Implement KillOptions

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2588. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Closed] (FLINK-2836) Cyclic Topologies not supported

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2836. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246772202 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246379055 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246422514 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246771871 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246378044 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246785747 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-10 Thread GitBox
StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246427849 ## File path:

[jira] [Updated] (FLINK-11296) Support truncate in TableAPI

2019-01-10 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11296: -- Component/s: Table API & SQL > Support truncate in TableAPI > > >

[GitHub] zentol commented on issue #7417: [FLINK-11268][release] Deploy multiple flink-shaded-hadoop2 artifacts

2019-01-10 Thread GitBox
zentol commented on issue #7417: [FLINK-11268][release] Deploy multiple flink-shaded-hadoop2 artifacts URL: https://github.com/apache/flink/pull/7417#issuecomment-453043597 > I'm ok with the format `-`. However, it is not aligned with the version format of the flink-shaded artifacts which

[GitHub] dawidwys edited a comment on issue #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13

2019-01-10 Thread GitBox
dawidwys edited a comment on issue #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13 URL: https://github.com/apache/flink/pull/7449#issuecomment-453052056 Hi @leesf . There is already an open PR that bumps the version of zookeeper: #7406 Could you coordinate with the author of this PR?

[jira] [Updated] (FLINK-10509) Drop flink-storm

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10509: - Fix Version/s: (was: 1.9.0) 1.8.0 > Drop flink-storm >

[GitHub] zjffdu commented on a change in pull request #7371: [FLINK-11224][scala-shell] Log is missing in scala-shell

2019-01-10 Thread GitBox
zjffdu commented on a change in pull request #7371: [FLINK-11224][scala-shell] Log is missing in scala-shell URL: https://github.com/apache/flink/pull/7371#discussion_r246725666 ## File path: flink-scala-shell/start-script/start-scala-shell.sh ## @@ -82,13 +82,25 @@ do

[GitHub] leesf commented on issue #7452: [hotfix] fix param typo in KeyedCoProcessOperator constructor

2019-01-10 Thread GitBox
leesf commented on issue #7452: [hotfix] fix param typo in KeyedCoProcessOperator constructor URL: https://github.com/apache/flink/pull/7452#issuecomment-453075581 cc @dawidwys @zentol This is an automated message from the

[GitHub] hequn8128 commented on a change in pull request #7418: FLINK-11053 Documentation - update scala sample code for bucketing sink according

2019-01-10 Thread GitBox
hequn8128 commented on a change in pull request #7418: FLINK-11053 Documentation - update scala sample code for bucketing sink according URL: https://github.com/apache/flink/pull/7418#discussion_r246736573 ## File path: docs/dev/connectors/filesystem_sink.md ## @@ -117,11

[GitHub] zentol closed pull request #7417: [FLINK-11268][release] Deploy multiple flink-shaded-hadoop2 artifacts

2019-01-10 Thread GitBox
zentol closed pull request #7417: [FLINK-11268][release] Deploy multiple flink-shaded-hadoop2 artifacts URL: https://github.com/apache/flink/pull/7417 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] zentol opened a new pull request #7455: [FLINK-11288][build] Exclude flink-ml from flink-dist

2019-01-10 Thread GitBox
zentol opened a new pull request #7455: [FLINK-11288][build] Exclude flink-ml from flink-dist URL: https://github.com/apache/flink/pull/7455 ## What is the purpose of the change With this PR we no longer deploy a flink-ml fat jar not include it in flink-dist. This way we

[GitHub] pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

2019-01-10 Thread GitBox
pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-453082287 @yanghua I'm not sure, I haven't thought about it. Keep in mind that we need: - migration tests of

[jira] [Updated] (FLINK-11296) Support truncate in TableAPI

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11296: --- Labels: pull-request-available (was: ) > Support truncate in TableAPI >

[jira] [Updated] (FLINK-11288) Add separate flink-ml module for building fat jar

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11288: - Fix Version/s: (was: 1.7.2) > Add separate flink-ml module for building fat jar >

[GitHub] pnowojski commented on a change in pull request #7438: [FLINK-11282][network] Merge StreamRecordWriter into RecordWriter

2019-01-10 Thread GitBox
pnowojski commented on a change in pull request #7438: [FLINK-11282][network] Merge StreamRecordWriter into RecordWriter URL: https://github.com/apache/flink/pull/7438#discussion_r246713184 ## File path:

[GitHub] leesf commented on issue #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13

2019-01-10 Thread GitBox
leesf commented on issue #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13 URL: https://github.com/apache/flink/pull/7449#issuecomment-453055319 @dawidwys, sorry, I didn't see pr( #7406) available in jira, I will close this pr submitted later.

[GitHub] zsq12138 commented on issue #7448: [hotfix][runtime] fix synchronous snapshots completed log

2019-01-10 Thread GitBox
zsq12138 commented on issue #7448: [hotfix][runtime] fix synchronous snapshots completed log URL: https://github.com/apache/flink/pull/7448#issuecomment-453059617 Thanks for review.I feel confused about why asynchronous checkpoints can have a synchronous part which can take > 0ms,and we

[GitHub] zentol opened a new pull request #7451: [FLINK-11270][build] Do not include hadoop in flink-dist by default

2019-01-10 Thread GitBox
zentol opened a new pull request #7451: [FLINK-11270][build] Do not include hadoop in flink-dist by default URL: https://github.com/apache/flink/pull/7451 Based on #7417. Please ignore commit for FLINK-11268. ## What is the purpose of the change With this PR hadoop is not

[jira] [Closed] (FLINK-11134) Invalid REST API request should not log the full exception in Flink logs

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11134. Resolution: Fixed Fix Version/s: 1.8.0 1.7.2

[jira] [Assigned] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

2019-01-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8424: --- Assignee: Benoit MERIAUX > [Cassandra Connector] Update Cassandra version to last

[jira] [Commented] (FLINK-11242) The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI

2019-01-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739269#comment-16739269 ] Fabian Hueske commented on FLINK-11242: --- Hi, SQL's three-value logic (true, false, null) is not

[jira] [Commented] (FLINK-11242) The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI

2019-01-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739268#comment-16739268 ] Fabian Hueske commented on FLINK-11242: --- Hi, SQL's three-value logic (true, false, null) is not

[GitHub] XuQianJin-Stars opened a new pull request #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI

2019-01-10 Thread GitBox
XuQianJin-Stars opened a new pull request #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI URL: https://github.com/apache/flink/pull/7450 ## What is the purpose of the change *This PR add `truncate` as core scalar operators in then codegen.* ## Brief

[jira] [Closed] (FLINK-11300) Make MetricFetcher update interval configurable

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11300. Resolution: Duplicate Fix Version/s: (was: 1.8.0) > Make MetricFetcher update

[GitHub] dawidwys commented on issue #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13

2019-01-10 Thread GitBox
dawidwys commented on issue #7449: [FLINK-9924] Upgrade zookeeper to 3.4.13 URL: https://github.com/apache/flink/pull/7449#issuecomment-453052056 Hi @leesf . There is already an open PR that bumps the version of zookeeper: #7406 Would you be ok with closing this PR?

[GitHub] azagrebin commented on issue #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

2019-01-10 Thread GitBox
azagrebin commented on issue #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320#issuecomment-453054089 @tillrohrmann @tzulitai Thanks for the review, guys! I addressed the comments.

[GitHub] leesf commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…

2019-01-10 Thread GitBox
leesf commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par… URL: https://github.com/apache/flink/pull/7420#issuecomment-453066604 @aljoscha thank you very much. This is an automated

[GitHub] aljoscha commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…

2019-01-10 Thread GitBox
aljoscha commented on issue #7420: [FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par… URL: https://github.com/apache/flink/pull/7420#issuecomment-453073668 Thanks again for your contribution! I merged

[jira] [Updated] (FLINK-11270) Do not include hadoop in flink-dist by default

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11270: --- Labels: pull-request-available (was: ) > Do not include hadoop in flink-dist by default >

[jira] [Created] (FLINK-11300) Make MetricFetcher update interval configurable

2019-01-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11300: - Summary: Make MetricFetcher update interval configurable Key: FLINK-11300 URL: https://issues.apache.org/jira/browse/FLINK-11300 Project: Flink Issue

[jira] [Closed] (FLINK-10866) Queryable state can prevent cluster from starting

2019-01-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10866. Resolution: Fixed Fixed on master in e8182dcd0987a7326a8c73df902c156e44a7cebf >

[GitHub] aljoscha closed pull request #7412: [FLINK-10866][Runtime] 1. Explicitly enable qs server and proxy. 2. QS

2019-01-10 Thread GitBox
aljoscha closed pull request #7412: [FLINK-10866][Runtime] 1. Explicitly enable qs server and proxy. 2. QS URL: https://github.com/apache/flink/pull/7412 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] aljoscha commented on issue #7412: [FLINK-10866][Runtime] 1. Explicitly enable qs server and proxy. 2. QS

2019-01-10 Thread GitBox
aljoscha commented on issue #7412: [FLINK-10866][Runtime] 1. Explicitly enable qs server and proxy. 2. QS URL: https://github.com/apache/flink/pull/7412#issuecomment-453042353 Merged, thanks again @eaglewatcherwb!  This is

[GitHub] aljoscha commented on issue #7444: [FLINK-11288][examples] Rework examples to account for licensing

2019-01-10 Thread GitBox
aljoscha commented on issue #7444: [FLINK-11288][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7444#issuecomment-453054657 https://issues.apache.org/jira/browse/FLINK-11288 is about `flink-ml`

[GitHub] dawidwys commented on a change in pull request #7371: [FLINK-11224][scala-shell] Log is missing in scala-shell

2019-01-10 Thread GitBox
dawidwys commented on a change in pull request #7371: [FLINK-11224][scala-shell] Log is missing in scala-shell URL: https://github.com/apache/flink/pull/7371#discussion_r246718103 ## File path: flink-scala-shell/start-script/start-scala-shell.sh ## @@ -82,13 +82,25 @@ do

[jira] [Closed] (FLINK-11267) Update create_binary_release.sh to not create hadoop-specific releases

2019-01-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11267. Resolution: Fixed master: ca9460bc8e91e206deb83e20b7fde5d7cb0d9e8b > Update

[GitHub] zentol closed pull request #7346: [FLINK-11134][rest] Do not log stacktrace handled exceptions

2019-01-10 Thread GitBox
zentol closed pull request #7346: [FLINK-11134][rest] Do not log stacktrace handled exceptions URL: https://github.com/apache/flink/pull/7346 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Commented] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11

2019-01-10 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739339#comment-16739339 ] Piotr Nowojski commented on FLINK-9700: --- What do you mean [~xleesf]? If you are asking whether the

  1   2   >