[jira] [Created] (FLINK-7578) WindowStream should support rich AggregateFunction

Hequn Cheng created FLINK-7578: -- Summary: WindowStream should support rich AggregateFunction Key: FLINK-7578 URL: https://issues.apache.org/jira/browse/FLINK-7578 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

[ https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu resolved FLINK-7169. Resolution: Fixed > Support AFTER MATCH SKIP function in CEP library API >

[jira] [Updated] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7573: Description: Currently, all connectors as far as I have known that merely support the TCP

[jira] [Updated] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7573: Description: Currently, all connectors as far as I have known that merely support the TCP

[jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153064#comment-16153064 ] mingleizhang commented on FLINK-7573: - I want to reach an agreement on this issue before start working

[jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153063#comment-16153063 ] mingleizhang commented on FLINK-7573: - Thanks [~yew1eb] You are right. > Introduce Http protocol

[jira] [Resolved] (FLINK-6995) Add a warning to outdated documentation

[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang resolved FLINK-6995. - Resolution: Fixed Fix Version/s: 1.3.2 > Add a warning to outdated documentation >

[jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153060#comment-16153060 ] Hai Zhou commented on FLINK-7573: - Hi [~mingleizhang], Maybe you need to know first: TCP protocol

[jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153058#comment-16153058 ] mingleizhang commented on FLINK-7573: - Hi, [~tzulitai] I guess you should be more familiar with this

[jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153054#comment-16153054 ] sunjincheng commented on FLINK-7465: Hi [~jparkie] Thanks for your suggestion. At current time I think

[jira] [Closed] (FLINK-7558) Improve SQL ValidationException message.

[ https://issues.apache.org/jira/browse/FLINK-7558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-7558. -- Resolution: Fixed Release Note: Fixed in e6fddbc3e5bdb42764191990ac29ba382bbe6016 > Improve SQL

[jira] [Commented] (FLINK-7572) Improve TableSchema ValidationException message.

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

[GitHub] flink pull request #4640: [FLINK-7572][table]Improve TableSchema and FlinkTa...

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4640 [FLINK-7572][table]Improve TableSchema and FlinkTable validation exce… ## What is the purpose of the change Currently, the exception message of `TableScheam` and `FlinkTable` a little

[jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

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

[GitHub] flink pull request #4639: [FLINK-7524] Remove potentially blocking behaviour...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4639#discussion_r136879648 --- Diff: flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java --- @@ -61,13 +75,14 @@ public final void registerClosable(C

[jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

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

[GitHub] flink pull request #4639: [FLINK-7524] Remove potentially blocking behaviour...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4639#discussion_r136877817 --- Diff: flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java --- @@ -61,13 +75,14 @@ public final void registerClosable(C

[jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

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

[GitHub] flink pull request #4639: [FLINK-7524] Remove potentially blocking behaviour...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4639#discussion_r136877616 --- Diff: flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java --- @@ -61,13 +75,14 @@ public final void registerClosable(C

[jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

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

[GitHub] flink pull request #4639: [FLINK-7524] Remove potentially blocking behaviour...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4639#discussion_r136877433 --- Diff: flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java --- @@ -61,13 +75,14 @@ public final void registerClosable(C

[jira] [Commented] (FLINK-5281) Extend KafkaJsonTableSources to support nested data

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

[GitHub] flink issue #3026: [FLINK-2980] [table] Support for GROUPING SETS clause in ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3026 @twalthr and @KurtYoung Do you think this PR is still going somewhere or should we rather close it? ---

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

[GitHub] flink issue #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInfo; add ...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4585 Thanks @suez1224, I'm quite busy atm but will try to have a look soon. Thanks, Fabian ---

[GitHub] flink pull request #4634: [FLINK-7568] Improve Windowing Documentation

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4634#discussion_r136852688 --- Diff: docs/dev/stream/operators/windows.md --- @@ -663,25 +623,42 @@ input .keyBy() .window() .process(new

[jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

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

[GitHub] flink issue #3124: [FLINK-5281] Extend KafkaJsonTableSources to support nest...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3124 @fhueske Is this PR (which has been open) for a while) still relevant for the current state of the Table API? ---

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve

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

[jira] [Commented] (FLINK-7564) Fix Watermark semantics in Table API

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

[GitHub] flink issue #4633: [FLINK-7564] [table] Fix Watermark semantics in RowTimeUn...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4633 Thanks for the PR @xccui. This is good to merge. ---

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r136847905 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -19,9 +19,21 @@ package

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3829 Hi @lincoln-lil, thanks for the JIRA! We usually have code and documentation changes in one PR. This way the docs are always up to date. I responded to the open questions. Please

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r136850229 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala --- @@ -106,6 +106,43 @@ abstract class

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve

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

[GitHub] flink pull request #4634: [FLINK-7568] Improve Windowing Documentation

Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4634#discussion_r136843813 --- Diff: docs/dev/stream/operators/windows.md --- @@ -663,25 +623,42 @@ input .keyBy() .window() .process(new

[jira] [Assigned] (FLINK-3831) flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-3831: --- Assignee: Hai Zhou Environment: Apache Maven 3.3.9, Java version: 1.8.0_144 Description:

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r136845193 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -502,26 +513,140 @@ abstract class

[jira] [Commented] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve

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

[GitHub] flink pull request #4634: [FLINK-7568] Improve Windowing Documentation

Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4634#discussion_r136845008 --- Diff: docs/dev/stream/operators/windows.md --- @@ -490,15 +490,35 @@ public abstract class ProcessWindowFunction

[jira] [Updated] (FLINK-7525) Add config option to disable Cancel functionality on UI

[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7525: -- Description: In this email thread

[jira] [Updated] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7488: -- Description: {code}

[jira] [Updated] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers

[ https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7433: -- Description: {code} try { if (throwable != null) {

[jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

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

[jira] [Commented] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

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

[GitHub] flink pull request #4638: [FLINK-6563] [table] Add time indicator support to...

GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4638 [FLINK-6563] [table] Add time indicator support to KafkaTableSource. ## What is the purpose of the change Add support for time indicators (processing time, ingestion time, event time) for

[GitHub] flink pull request #4639: [FLINK-7524] Remove potentially blocking behaviour...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4639 [FLINK-7524] Remove potentially blocking behaviour from AbstractClose… …ableRegistry ## What is the purpose of the change This PR removes potential for blocking

[jira] [Created] (FLINK-7577) flink-core

Hai Zhou created FLINK-7577: --- Summary: flink-core Key: FLINK-7577 URL: https://issues.apache.org/jira/browse/FLINK-7577 Project: Flink Issue Type: Sub-task Components: Build System

[jira] [Assigned] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

[ https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-7575: -- Assignee: James Lafa > Dashboard jobs/tasks metrics display 0 when metrics are not yet

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

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

[GitHub] flink issue #4639: [FLINK-7524] Remove potentially blocking behaviour from A...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4639 CC @aljoscha ---

[jira] [Commented] (FLINK-7576) Add FutureUtils.retryWithDelay

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

[GitHub] flink pull request #4637: [FLINK-7576] [futures] Add FutureUtils.retryWithDe...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4637 [FLINK-7576] [futures] Add FutureUtils.retryWithDelay ## What is the purpose of the change FutureUtils.retryWithDelay executes the given operation of type

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152674#comment-16152674 ] Fabian Hueske commented on FLINK-6563: -- Hi [~wheat9], I addressed this issue but did not check for an

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r136836067 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -220,6 +216,7 @@ void releaseBuffer() {

[jira] [Created] (FLINK-7576) Add FutureUtils.retryWithDelay

Till Rohrmann created FLINK-7576: Summary: Add FutureUtils.retryWithDelay Key: FLINK-7576 URL: https://issues.apache.org/jira/browse/FLINK-7576 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

James Lafa created FLINK-7575: - Summary: Dashboard jobs/tasks metrics display 0 when metrics are not yet available Key: FLINK-7575 URL: https://issues.apache.org/jira/browse/FLINK-7575 Project: Flink

[jira] [Commented] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

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

[GitHub] flink pull request #4518: [FLINK-7412][network] optimise NettyMessage.TaskEv...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4518#discussion_r136834211 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -440,12 +440,11 @@ ByteBuf

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r136831143 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -378,11 +373,14 @@ ByteBuf

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r136831126 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -313,20 +308,20 @@ ByteBuf

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r136827653 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -130,34 +128,31 @@ protected void

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r136831169 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -439,20 +437,23 @@ ByteBuf

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r136830945 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -242,21 +239,22 @@ ByteBuf

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

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

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4239 @aljoscha I have addressed you "high level" comments and fixed some bugs. Please latest 5 commits (one of them is a new dependency on another PR: https://github.com/apache/flink/pull/4631 ) ---

[jira] [Assigned] (FLINK-3828) flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-3828: --- Assignee: Hai Zhou Environment: Apache Maven 3.3.9, Java version: 1.8.0_144 Description:

[jira] [Created] (FLINK-7574) flink-clients

Hai Zhou created FLINK-7574: --- Summary: flink-clients Key: FLINK-7574 URL: https://issues.apache.org/jira/browse/FLINK-7574 Project: Flink Issue Type: Sub-task Components: Build System

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136822032 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136822393 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136821811 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136822467 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[jira] [Commented] (FLINK-2268) Provide Flink binary release without Hadoop

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

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136818368 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala --- @@ -320,14 +315,6 @@ private[flink] trait

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136822623 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136819789 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/KerberosUtils.java --- @@ -52,6 +51,13 @@ private static final

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136821489 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java --- @@ -112,29 +114,29 @@ public static void runYarnTaskManager(String[]

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136817884 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java --- @@ -284,7 +284,16 @@ public static void

[GitHub] flink pull request #4636: [FLINK-2268] Allow Flink binary release without Ha...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4636#discussion_r136818648 --- Diff: flink-tests/pom.xml --- @@ -54,6 +54,12 @@ under the License. org.apache.flink +

  1   2   >