[jira] [Updated] (FLINK-4375) Introduce rpc protocols implemented by job manager

[ https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-4375: --- Summary: Introduce rpc protocols implemented by job manager (was: Introduce rpc protocols provided

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

[jira] [Commented] (FLINK-3870) Add IntelliJ code style file

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

[jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

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

[jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

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

[GitHub] flink issue #1963: [FLINK-3870][docs] Added IntelliJ code style

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/1963 Hi @danielblazevski , I find a way to solve this. Just copy the `FlinkCodeStyle.xml` to the config/codestyles directory (for me is `~/Library/Preferences/IntelliJIdea15/codestyles`) and restarting

[jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

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

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

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

[GitHub] flink pull request #2361: [FLINK-3318][cep] Add support for quantifiers to C...

Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/2361 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

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

[GitHub] flink pull request #2361: [FLINK-3318][cep] Add support for quantifiers to C...

GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2361 [FLINK-3318][cep] Add support for quantifiers to CEP's pattern API Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417880#comment-15417880 ] Elias Levy commented on FLINK-4035: --- FWIW I generated a flink-connector-kafka-0.9_2.11-1.1.1.jar that

[jira] [Commented] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time

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

[GitHub] flink issue #2359: [FLINK-4198] Replace org.apache.flink.streaming.api.windo...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2359 I think this breaks the API compatibility. This issue was scheduled as part of the API breaking changes for FLINK 2.0 Compatibility for `@Public` annotated methods is something we

[jira] [Created] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread

Stephan Ewen created FLINK-4386: --- Summary: Add as way to assert that code runs in the RpcEndpoint's Main Thread Key: FLINK-4386 URL: https://issues.apache.org/jira/browse/FLINK-4386 Project: Flink

[jira] [Created] (FLINK-4385) Union on Timestamp fields does not work

Timo Walther created FLINK-4385: --- Summary: Union on Timestamp fields does not work Key: FLINK-4385 URL: https://issues.apache.org/jira/browse/FLINK-4385 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

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

[GitHub] flink issue #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoint has b...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2358 Not completely sure about the message stashing. Why not drop the messages? That would be safer (less to clean up, no overflow). Is this mainly to not loose the messages from the "self

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

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

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2360 [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint NOTE: This builds on top of #2357 - only the second commit belongs actually to this pull request is relevant. Add a

[jira] [Commented] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417617#comment-15417617 ] Stephan Ewen commented on FLINK-4374: - True, but the test should not try a Tuple2 if tuples

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink issue #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via Java pr...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2357 +1 from my side I would suggest as a followup to find out the gateway type for reflection. The `ReflectionUtil` helps with that. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74463001 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RpcInvocation.java --- @@ -0,0 +1,98 @@ +/* + * Licensed to the

[GitHub] flink pull request #2359: [FLINK-4198] Replace org.apache.flink.streaming.ap...

GitHub user kishorekgarg opened a pull request: https://github.com/apache/flink/pull/2359 [FLINK-4198] Replace org.apache.flink.streaming.api.windowing.time.Ti… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time

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

[jira] [Assigned] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message

[ https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4383: Assignee: Till Rohrmann > Check parameters for serializability before sending a remote

[jira] [Commented] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

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

[GitHub] flink pull request #2358: [FLINK-4382] Buffer rpc calls until the RpcEndpoin...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2358 [FLINK-4382] Buffer rpc calls until the RpcEndpoint has been started This PR allows the AkkaRpcActor to stash messages until the corresponding RcpEndpoint has been started. When receiving

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417522#comment-15417522 ] Elias Levy commented on FLINK-4326: --- That would be my expectation. Writing out the PID would be nice,

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

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

[GitHub] flink issue #2340: [FLINK-3155] Update docker flink container to the latest ...

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2340 And remember that my ultimate goal is not to host that image but that we can convert it into an official one. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

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

[GitHub] flink issue #2340: [FLINK-3155] Update docker flink container to the latest ...

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2340 Of course, who do you think I am :P You can check a ready to run build here in case you don't want to test that one. But it is true that we need some kind of automatized tests for the image.

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74446628 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java --- @@ -172,6 +173,13 @@ public void runAsync(Runnable runnable) {

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

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

[GitHub] flink issue #2340: [FLINK-3155] Update docker flink container to the latest ...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2340 Thanks! Looks good. Did you run the changes with Docker? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

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

[GitHub] flink pull request #2340: [FLINK-3155] Update docker flink container to the ...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2340#discussion_r74445659 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,25 +22,30 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

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

[GitHub] flink pull request #2340: [FLINK-3155] Update docker flink container to the ...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2340#discussion_r74445485 --- Diff: flink-contrib/docker-flink/Dockerfile --- @@ -22,25 +22,30 @@ FROM java:8-jre-alpine RUN apk add --no-cache bash snappy # Configure

[jira] [Created] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

Stephan Ewen created FLINK-4384: --- Summary: Add a "scheduleRunAsync()" feature to the RpcEndpoint Key: FLINK-4384 URL: https://issues.apache.org/jira/browse/FLINK-4384 Project: Flink Issue

[jira] [Commented] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

[ https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417432#comment-15417432 ] Stephan Ewen commented on FLINK-4382: - Would it buffer the messages, or simply discard them while the

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 >HDFS and Yarn are handled through the @BeforeClass and @AfterClass style and they do not use custom JRunner implementation. As you have suggested, I could keep just one or two tests for each of the

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Closed] (FLINK-4368) Eagerly initialize RrcProtocol members

[ https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4368. --- > Eagerly initialize RrcProtocol members > -- > >

[jira] [Commented] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream

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

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink issue #2354: [FLINK-4366] Enforce parallelism=1 For AllWindowedStream

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2354 Something like `NonParallelSingleOutputStreamOperator` but that's quite a mouthful. (`SingleOutputStreamOperator` is already too long for my taste ...). Or maybe `NonParallelStreamOperator`.

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74443700 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java --- @@ -0,0 +1,176 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink issue #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via Java pr...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2357 Yes you're right @StephanEwen. We shouldn't stop the actor upon receiving an unknown message type. I'll change the behaviour. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74443304 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RpcInvocation.java --- @@ -0,0 +1,98 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74443020 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java --- @@ -0,0 +1,176 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message

Till Rohrmann created FLINK-4383: Summary: Check parameters for serializability before sending a remote RpcInvocation message Key: FLINK-4383 URL: https://issues.apache.org/jira/browse/FLINK-4383

[GitHub] flink issue #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to let typ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2337 @StephanEwen I have updated the PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Created] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

Till Rohrmann created FLINK-4382: Summary: Buffer rpc calls until RpcEndpoint is properly started Key: FLINK-4382 URL: https://issues.apache.org/jira/browse/FLINK-4382 Project: Flink Issue

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74439866 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RpcInvocation.java --- @@ -0,0 +1,98 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2357#discussion_r74439096 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java --- @@ -0,0 +1,176 @@ +/* + * Licensed to the Apache

[GitHub] flink issue #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via Java pr...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2357 Good stuff! I am not sure we should throw an Exception in the `AkkaRpcActor` upon receiving an incorrect message. In the past we decided to only log those cases. Seems to easy to bring

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[jira] [Commented] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload

[ https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417338#comment-15417338 ] Stephan Ewen commented on FLINK-4377: - Yes, this can currently happen. The only way to immediately

[jira] [Commented] (FLINK-4362) Auto generate message sender classes via Java Proxies

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

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417302#comment-15417302 ] Stephan Ewen commented on FLINK-4370: - In theory, putting it in "tools" and referencing in the docs is

[jira] [Commented] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417316#comment-15417316 ] Timo Walther commented on FLINK-4374: - The null support in general is a bit inconsistent. The Date or

[jira] [Updated] (FLINK-4368) Eagerly initialize RrcProtocol members

[ https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4368: - Assignee: Stephan Ewen > Eagerly initialize RrcProtocol members >

[jira] [Resolved] (FLINK-4368) Eagerly initialize RrcProtocol members

[ https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4368. -- Resolution: Done Added via 08af7def60d54c22126b902e6fa57101d5fbb8fa > Eagerly initialize

[GitHub] flink pull request #2357: [FLINK-4362] [rpc] Auto generate rpc gateways via ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2357 [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies This PR introduces a generic `AkkaRpcActor` which receives rpc calls as a `RpcInvocation` message. The `RpcInvocation` message

[jira] [Commented] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417298#comment-15417298 ] Stephan Ewen commented on FLINK-4374: - Tuples do not support null fields, so the test is somewhat

[jira] [Created] (FLINK-4381) Refactor State to Prepare For Key-Group State Backends

Aljoscha Krettek created FLINK-4381: --- Summary: Refactor State to Prepare For Key-Group State Backends Key: FLINK-4381 URL: https://issues.apache.org/jira/browse/FLINK-4381 Project: Flink

[jira] [Created] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter

Aljoscha Krettek created FLINK-4380: --- Summary: Introduce KeyGroupAssigner and Max-Parallelism Parameter Key: FLINK-4380 URL: https://issues.apache.org/jira/browse/FLINK-4380 Project: Flink

[jira] [Commented] (FLINK-4359) Add INTERVAL type

[ https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417270#comment-15417270 ] Timo Walther commented on FLINK-4359: - Once the roadmap for that is defined (most likely with a

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417286#comment-15417286 ] Greg Hogan commented on FLINK-4326: --- Isn't the expectation that the supervisor would monitor and control

[jira] [Created] (FLINK-4379) Add Rescalable Non-Partitioned State

Ufuk Celebi created FLINK-4379: -- Summary: Add Rescalable Non-Partitioned State Key: FLINK-4379 URL: https://issues.apache.org/jira/browse/FLINK-4379 Project: Flink Issue Type: New Feature

[GitHub] flink pull request #2356: [FLINK-4378]Enable RollingSink to custom HDFS clie...

GitHub user wenlong88 opened a pull request: https://github.com/apache/flink/pull/2356 [FLINK-4378]Enable RollingSink to custom HDFS client configuration Adding a new interface to rolling sink You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417255#comment-15417255 ] Ismaël Mejía commented on FLINK-4326: - A separation of (daemon/console) scripts would be the nicest,

[jira] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

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

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417241#comment-15417241 ] Greg Hogan commented on FLINK-4370: --- I'd rather add this to its proper place ({{.idea}}) and have

[jira] [Created] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

Wenlong Lyu created FLINK-4378: -- Summary: Enable RollingSink to custom HDFS client configuration Key: FLINK-4378 URL: https://issues.apache.org/jira/browse/FLINK-4378 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

Github user uce commented on the issue: https://github.com/apache/flink/pull/2342 I think we need to change more than just that single variable. The other variables should match, e.g. `recovery.jobmanager.port => high-availability.jobmanager.port` and also `recovery.zookeeper.*

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417208#comment-15417208 ] Jark Wu commented on FLINK-4370: Yes. We can put this files into tools folder (or other) as well as the

[jira] [Commented] (FLINK-4335) Add jar id, and job parameters information to job status rest call

[ https://issues.apache.org/jira/browse/FLINK-4335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417195#comment-15417195 ] Robert Metzger commented on FLINK-4335: --- I see. The jar ID is an internal id of the web job

[jira] [Commented] (FLINK-4359) Add INTERVAL type

[ https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417187#comment-15417187 ] Jark Wu commented on FLINK-4359: Okay, I see. I'm interested in this, and I'm glad if I can help

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417185#comment-15417185 ] Greg Hogan commented on FLINK-4370: --- We've had pull requests rejected due to formatting changes, and

[jira] [Created] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload

Sajeev Ramakrishnan created FLINK-4377: -- Summary: akka.remote.OversizedPayloadException: Discarding oversized payload Key: FLINK-4377 URL: https://issues.apache.org/jira/browse/FLINK-4377

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

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

[GitHub] flink pull request #2355: [FLINK-4282]Add Offset Parameter to WindowAssigner...

GitHub user Renkai opened a pull request: https://github.com/apache/flink/pull/2355 [FLINK-4282]Add Offset Parameter to WindowAssigners Although there is already a merge request for this issue,I think this implementation is more sensible. You can merge this pull request into a Git

[jira] [Comment Edited] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417162#comment-15417162 ] Stefan Richter edited comment on FLINK-4374 at 8/11/16 12:52 PM: - Yes, it

[jira] [Commented] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417162#comment-15417162 ] Stefan Richter commented on FLINK-4374: --- Yes, it is the data field of the Tuple2 in

  1   2   >