[jira] [Commented] (FLINK-9182) async checkpoints for timer service

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469988#comment-16469988 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on the issue

[GitHub] flink issue #5908: [FLINK-9182]async checkpoints for timer service

2018-05-09 Thread makeyang
Github user makeyang commented on the issue: https://github.com/apache/flink/pull/5908 @StefanRRichter sorry for the late answer. just take a surgery few days ago and come back now. I'll take close look at you comments and then answer back. ---

[jira] [Commented] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469980#comment-16469980 ] ASF GitHub Bot commented on FLINK-9295: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5977: [FLINK-9295][kafka] Fix transactional.id collision...

2018-05-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5977#discussion_r187250723 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/MockStreamConfig.java --- @@ -0,0 +1,35 @@ +/* + * Licensed to the Apach

[GitHub] flink issue #5981: fix syntax error in dataset_transformations.md

2018-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5981 merging. ---

[jira] [Updated] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

2018-05-09 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9325: -- Summary: generate the _meta file for checkpoint only when the writing is truly successful (was: generat

[jira] [Updated] (FLINK-9325) generate the _meta file for checkpoint only when the writing is totally successful

2018-05-09 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9325: -- Summary: generate the _meta file for checkpoint only when the writing is totally successful (was: gener

[jira] [Commented] (FLINK-9325) generate the _meta file only when the writing is totally successful

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

[GitHub] flink pull request #5982: [FLINK-9325][checkpoint]generate the meta file for...

2018-05-09 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5982 [FLINK-9325][checkpoint]generate the meta file for checkpoint only when the writing is truly successful ## What is the purpose of the change *This PR in order to enhance the checkpoint's

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469935#comment-16469935 ] ASF GitHub Bot commented on FLINK-9309: --- Github user alpinegizmo commented on the is

[GitHub] flink issue #5976: [FLINK-9309] Recommend HA setup on Production Readiness C...

2018-05-09 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/5976 +1 ---

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469855#comment-16469855 ] ASF GitHub Bot commented on FLINK-9309: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5976: [FLINK-9309] Recommend HA setup on Production Readiness C...

2018-05-09 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5976 cc @alpinegizmo @fhueske ---

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469847#comment-16469847 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ...

2018-05-09 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5931#discussion_r187227128 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -293,21 +293,16 @@ public void startNewWorker(ResourceProfile res

[jira] [Assigned] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

2018-05-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-8993: --- Assignee: (was: mingleizhang) > Add a test operator with keyed state that uses Kryo seria

[jira] [Resolved] (FLINK-5030) Support hostname verification

2018-05-09 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright resolved FLINK-5030. - Resolution: Won't Fix I think this is obsolete and/or covered by FLINK-9103 > Support hostname ve

[jira] [Commented] (FLINK-9312) Perform mutual authentication during SSL handshakes

2018-05-09 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469744#comment-16469744 ] Eron Wright commented on FLINK-9312: - I believe that this enhancement can be consider

[jira] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for FLIP-6

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469718#comment-16469718 ] ASF GitHub Bot commented on FLINK-8286: --- Github user EronWright commented on the iss

[GitHub] flink issue #5896: [FLINK-8286][Security] Fix kerberos security configuratio...

2018-05-09 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5896 This PR seems to obfuscate the fix. The issue was with the interpretation of the keytab path, right? But the bulk of the change was to clarify the ordering of context installation vs use? ---

[jira] [Assigned] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

2018-05-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9326: --- Assignee: vinoyang > TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode > --

[jira] [Commented] (FLINK-9312) Perform mutual authentication during SSL handshakes

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469612#comment-16469612 ] ASF GitHub Bot commented on FLINK-9312: --- Github user GJL commented on the issue:

[GitHub] flink issue #5966: [FLINK-9312] [security] Add mutual authentication for RPC...

2018-05-09 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5966 I will take a look at this later today. ---

[jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469611#comment-16469611 ] ASF GitHub Bot commented on FLINK-9261: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5973: [FLINK-9261][ssl] Fix SSL support for REST API and...

2018-05-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5973#discussion_r187194770 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -81,16 +85,62 @@ public static void setSSLVerAndCipherSuites(ServerSocke

[jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469600#comment-16469600 ] ASF GitHub Bot commented on FLINK-9261: --- Github user StephanEwen commented on the is

[GitHub] flink issue #5973: [FLINK-9261][ssl] Fix SSL support for REST API and Web UI...

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5973 Merging this... ---

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5980#discussion_r187191338 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java --- @@ -159,10 +159,51 @@ public SlotSharingGro

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469585#comment-16469585 ] ASF GitHub Bot commented on FLINK-9324: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5980#discussion_r187189887 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java --- @@ -159,10 +159,51 @@ public SlotSharingGro

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469586#comment-16469586 ] ASF GitHub Bot commented on FLINK-9324: --- Github user StephanEwen commented on a diff

[jira] [Created] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

2018-05-09 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9327: - Summary: Support explicit ROW value constructor in Flink SQL Key: FLINK-9327 URL: https://issues.apache.org/jira/browse/FLINK-9327 Project: Flink Issue Type: Sub-t

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

2018-05-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469496#comment-16469496 ] Ted Yu commented on FLINK-9091: --- I think I was running 'mvn package -DskipTests' > Failure

[GitHub] flink pull request #5981: fix syntax error in dataset_transformations.md

2018-05-09 Thread kgeis
GitHub user kgeis opened a pull request: https://github.com/apache/flink/pull/5981 fix syntax error in dataset_transformations.md fix minor code syntax error You can merge this pull request into a Git repository by running: $ git pull https://github.com/kgeis/flink patch-2 Alt

[jira] [Commented] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

2018-05-09 Thread Samuel Doyle (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469326#comment-16469326 ] Samuel Doyle commented on FLINK-9326: - I'm guessing this is because it appears whateve

[jira] [Created] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

2018-05-09 Thread Samuel Doyle (JIRA)
Samuel Doyle created FLINK-9326: --- Summary: TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode Key: FLINK-9326 URL: https://issues.apache.org/jira/browse/FLINK-9326 Project: Flink

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469170#comment-16469170 ] ASF GitHub Bot commented on FLINK-9138: --- Github user glaksh100 commented on the issu

[GitHub] flink issue #5860: [FLINK-9138][filesystem-connectors] Implement time based ...

2018-05-09 Thread glaksh100
Github user glaksh100 commented on the issue: https://github.com/apache/flink/pull/5860 @fhueske I gave it some thought and your suggestion makes sense to me. I have extended `checkForInactiveBuckets` to include the rollover check. I have also updated Javadocs in a few places: -

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469114#comment-16469114 ] ASF GitHub Bot commented on FLINK-9190: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #5931: [FLINK-9190][flip6,yarn] Request new container if contain...

2018-05-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5931 I looked into the problem @GJL reported and I think it is not caused by killed TMs which don't have the chance to tell the JMs about the slot allocations (even though this can theoretically happ

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469093#comment-16469093 ] ASF GitHub Bot commented on FLINK-9190: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469092#comment-16469092 ] ASF GitHub Bot commented on FLINK-9190: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ...

2018-05-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5931#discussion_r187106742 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -293,21 +293,16 @@ public void startNewWorker(ResourceProfile

[GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ...

2018-05-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5931#discussion_r187102871 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -293,21 +293,16 @@ public void startNewWorker(ResourceProfile

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469054#comment-16469054 ] ASF GitHub Bot commented on FLINK-9070: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5979: [FLINK-9070][state]improve the performance of RocksDBMapS...

2018-05-09 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5979 cc @StefanRRichter (This is for 1.6, I just complete it when I have time currently) ---

[jira] [Created] (FLINK-9325) generate the _meta file only when the writing is totally successful

2018-05-09 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9325: - Summary: generate the _meta file only when the writing is totally successful Key: FLINK-9325 URL: https://issues.apache.org/jira/browse/FLINK-9325 Project: Flink

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469038#comment-16469038 ] ASF GitHub Bot commented on FLINK-9324: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

2018-05-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5980 [FLINK-9324] Wait for slot release before completing release future in SingleLogicalSlot ## What is the purpose of the change This commit properly waits for the completion of the Singl

[jira] [Commented] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469036#comment-16469036 ] ASF GitHub Bot commented on FLINK-9215: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5879: [FLINK-9215][resoucemanager] Reduce noise in SlotPool's l...

2018-05-09 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5879 cc @tillrohrmann ---

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

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

[GitHub] flink pull request #5979: [FLINK-9070][state]improve the performance of Rock...

2018-05-09 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5979 [FLINK-9070][state]improve the performance of RocksDBMapState.clear() ## What is the purpose of the change This PR intend to improve the performance of `RocksDBMapState.clear()` base on

[jira] [Updated] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-05-09 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9070: -- Priority: Major (was: Minor) > Improve performance of RocksDBMapState.clear() > ---

[jira] [Created] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

2018-05-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9324: Summary: SingleLogicalSlot returns completed release future before slot is properly returned Key: FLINK-9324 URL: https://issues.apache.org/jira/browse/FLINK-9324 Pro

[GitHub] flink issue #5847: [FLINK-9174][datastream]Fix the type of state created in ...

2018-05-09 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5847 cc @StephanEwen Could you please have a look at this? I think it's already for another review. ---

[jira] [Commented] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469015#comment-16469015 ] ASF GitHub Bot commented on FLINK-9174: --- Github user sihuazhou commented on the issu

[jira] [Commented] (FLINK-9192) Undo parameterization of StateMachine Example

2018-05-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16469000#comment-16469000 ] Kostas Kloudas commented on FLINK-9192: --- This issue is trivial after the resolution

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468981#comment-16468981 ] ASF GitHub Bot commented on FLINK-9168: --- Github user pluppens commented on a diff in

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468982#comment-16468982 ] ASF GitHub Bot commented on FLINK-9168: --- Github user pluppens commented on a diff in

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-09 Thread pluppens
Github user pluppens commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r187085104 --- Diff: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducerTest.java --- @@ -0,0 +1,10

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

2018-05-09 Thread pluppens
Github user pluppens commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r187084563 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarProduceMode.java --- @@ -0,0 +1,36 @@

[jira] [Closed] (FLINK-9310) Update default cyphersuites

2018-05-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9310. --- > Update default cyphersuites > --- > > Key: FLINK-9310 >

[jira] [Resolved] (FLINK-9310) Update default cyphersuites

2018-05-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-9310. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in - 1.5.0 via e7e1baca856609c95516857feef92

[jira] [Commented] (FLINK-9310) Update default cyphersuites

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468922#comment-16468922 ] ASF GitHub Bot commented on FLINK-9310: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5965: [FLINK-9310] [security] Update standard cipher sui...

2018-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5965 ---

[jira] [Commented] (FLINK-8554) Upgrade AWS SDK

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468915#comment-16468915 ] ASF GitHub Bot commented on FLINK-8554: --- Github user StephanEwen commented on the is

[GitHub] flink issue #5978: [FLINK-8554] Upgrade AWS SDK

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5978 Before merging this, we need to - diff the dependency trees between the versions - clear all licenses for the dependency changes. put changes into the NOTICE files - check that n

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468890#comment-16468890 ] ASF GitHub Bot commented on FLINK-9309: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5976: [FLINK-9309] Recommend HA setup on Production Readiness C...

2018-05-09 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5976 @alpinegizmo good suggestion, will accept it and change it soon. ---

[GitHub] flink issue #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ (Transp...

2018-05-09 Thread cjolif
Github user cjolif commented on the issue: https://github.com/apache/flink/pull/5374 good news the issue reported by @jdewald is now fixed in Elasticsearch master. Not sure which version of Elasticsearch will contain the fix though. ---

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468840#comment-16468840 ] ASF GitHub Bot commented on FLINK-8101: --- Github user cjolif commented on the issue:

[jira] [Commented] (FLINK-8989) End-to-end test: ElasticSearch connector

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468819#comment-16468819 ] ASF GitHub Bot commented on FLINK-8989: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5761: [FLINK-8989] [e2eTests] Elasticsearch1&2&5 end to end tes...

2018-05-09 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5761 Hi, @tzulitai What is the state of this PR ? thanks. This PR is ready to have another review. ---

[jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager

2018-05-09 Thread Alon Galant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468809#comment-16468809 ] Alon Galant commented on FLINK-8707: Thanks Nico. My problem is solved :) We run Fli

[jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468807#comment-16468807 ] ASF GitHub Bot commented on FLINK-9138: --- Github user StephanEwen commented on the is

[GitHub] flink issue #5975: [FLINK-9138][docs][tests] Make ConfigOptionsDocsCompleten...

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5975 +1 ---

[jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468802#comment-16468802 ] ASF GitHub Bot commented on FLINK-9261: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #5973: [FLINK-9261][ssl] Fix SSL support for REST API and...

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5973#discussion_r187025268 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -81,16 +85,62 @@ public static void setSSLVerAndCipherSuites(Ser

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468797#comment-16468797 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test

2018-05-09 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5823 Hi, @zentol . What is the state of this PR ? Thanks. ---

[GitHub] flink issue #5972: [FLINK-9323][build] Properly organize checkstyle-plugin c...

2018-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5972 the build failed because of a copy&paste error, flink-core and flink-optimizer are using the flink-runtime suppressions file... ---

[jira] [Commented] (FLINK-9323) Move checkstyle configuration to plugin management

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468795#comment-16468795 ] ASF GitHub Bot commented on FLINK-9323: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

2018-05-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9141: Fix Version/s: 1.5.0 > Calling getSideOutput() and split() on one DataStream causes NPE > --

[jira] [Commented] (FLINK-9316) Expose operator unique ID to the user defined functions in DataStream .

2018-05-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468783#comment-16468783 ] Piotr Nowojski commented on FLINK-9316: --- Ops, yes, I meant to expose it to UDF's lik

[jira] [Commented] (FLINK-9323) Move checkstyle configuration to plugin management

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468785#comment-16468785 ] ASF GitHub Bot commented on FLINK-9323: --- Github user StephanEwen commented on the is

[GitHub] flink issue #5972: [FLINK-9323][build] Properly organize checkstyle-plugin c...

2018-05-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5972 +1 to the cleanup, but I think this might be breaking relative paths of the suppression files, hence causing the build to fail. Probably need to make the paths relative to "root dir" or some "hig

[jira] [Updated] (FLINK-9316) Expose operator unique ID to the user defined functions in DataStream .

2018-05-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9316: -- Summary: Expose operator unique ID to the user defined functions in DataStream . (was: Expose o

[jira] [Commented] (FLINK-8554) Upgrade AWS SDK

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

[GitHub] flink pull request #5978: [FLINK-8554] Upgrade AWS SDK

2018-05-09 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5978 [FLINK-8554] Upgrade AWS SDK ## What is the purpose of the change *This pull request upgrades AWS SDK* ## Brief change log - *Upgrades AWS SDK* ## Verifying this

[jira] [Commented] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468761#comment-16468761 ] ASF GitHub Bot commented on FLINK-9295: --- GitHub user pnowojski opened a pull request

[GitHub] flink pull request #5977: [FLINK-9295][kafka] Fix transactional.id collision...

2018-05-09 Thread pnowojski
GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/5977 [FLINK-9295][kafka] Fix transactional.id collisions for FlinkKafkaProducer011 Previously if there were two completely independent FlinkKafkaProducer011 data sinks in the job graph, their transact

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468759#comment-16468759 ] ASF GitHub Bot commented on FLINK-9309: --- Github user yanghua commented on the issue:

[GitHub] flink pull request #5976: [FLINK-9309] Recommend HA setup on Production Read...

2018-05-09 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5976 [FLINK-9309] Recommend HA setup on Production Readiness Checklist ## What is the purpose of the change *This pull request adds HA setup on Production Readiness Checklist* ## Br

[jira] [Commented] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

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

[GitHub] flink issue #5976: [FLINK-9309] Recommend HA setup on Production Readiness C...

2018-05-09 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5976 cc @fhueske @zentol ---

[jira] [Updated] (FLINK-7983) Bump prometheus java client to 0.1.0

2018-05-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7983: Component/s: Metrics > Bump prometheus java client to 0.1.0 > --

[jira] [Closed] (FLINK-7983) Bump prometheus java client to 0.1.0

2018-05-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7983. --- Resolution: Duplicate > Bump prometheus java client to 0.1.0 > ---

[jira] [Commented] (FLINK-9265) Upgrade Prometheus version

2018-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16468757#comment-16468757 ] ASF GitHub Bot commented on FLINK-9265: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-7983) Bump prometheus java client to 0.1.0

2018-05-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7983: Fix Version/s: (was: 1.5.0) > Bump prometheus java client to 0.1.0 > ---

  1   2   >