[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713561#comment-16713561 ] ASF GitHub Bot commented on FLINK-10865: wujinhu commented on issue #7123: [FLIN

[GitHub] wujinhu commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

wujinhu commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#issuecomment-445435454 @StefanRRichter Thanks, I have rebased master branch and revert merge history, I think this is what you mean. -

[jira] [Updated] (FLINK-11106) Remove legacy flink-yarn component

[ https://issues.apache.org/jira/browse/FLINK-11106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11106: - Description: After flink-yarn tests ported to new codebase, we are able to remove legacy flink-yarn com

[jira] [Created] (FLINK-11106) Remove legacy flink-yarn component

TisonKun created FLINK-11106: Summary: Remove legacy flink-yarn component Key: FLINK-11106 URL: https://issues.apache.org/jira/browse/FLINK-11106 Project: Flink Issue Type: Sub-task Com

[jira] [Commented] (FLINK-10478) Kafka Producer wrongly formats "%" for transaction ID

[ https://issues.apache.org/jira/browse/FLINK-10478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713505#comment-16713505 ] ASF GitHub Bot commented on FLINK-10478: leesf opened a new pull request #7262:

[jira] [Updated] (FLINK-10478) Kafka Producer wrongly formats "%" for transaction ID

[ https://issues.apache.org/jira/browse/FLINK-10478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10478: --- Labels: pull-request-available (was: ) > Kafka Producer wrongly formats "%" for transaction

[GitHub] leesf opened a new pull request #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

leesf opened a new pull request #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262 ## What is the purpose of the change *This pull request solve kafka transaction ID wrongly formats % problem.* ## Brief c

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713488#comment-16713488 ] vinoyang commented on FLINK-11103: -- I think this makes sense. FLINK-5232 is handled by

[jira] [Assigned] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11105: Assignee: vinoyang > Add a new implementation of the HighAvailabilityServices using etcd > --

[jira] [Assigned] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

[ https://issues.apache.org/jira/browse/FLINK-11102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11102: Assignee: vinoyang > Enable check for previous data in SpanningRecordSerializer > ---

[jira] [Assigned] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11103: Assignee: vinoyang > Set a default uncaught exception handler > -

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713157#comment-16713157 ] ASF GitHub Bot commented on FLINK-10887: tweise commented on issue #7099: [FLINK

[GitHub] tweise commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

tweise commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#issuecomment-445318396 > @aljoscha @tweise Can you guys comment on the above generic aggregator proposal? I'd like to keep this moving fo

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713143#comment-16713143 ] ASF GitHub Bot commented on FLINK-10887: jgrier commented on issue #7099: [FLINK

[GitHub] jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#issuecomment-445316366 > Can we always assume that the user-jar/class loader will be available where the `AggregateFunction` is needed? I

[jira] [Commented] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713102#comment-16713102 ] TisonKun commented on FLINK-11105: -- Thanks for bringing this proposal! I like it and th

[jira] [Closed] (FLINK-11104) LEFT JOIN with Table Function not working

[ https://issues.apache.org/jira/browse/FLINK-11104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Denys Fakhritdinov closed FLINK-11104. -- Resolution: Not A Bug > LEFT JOIN with Table Function not working > --

[jira] [Commented] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713070#comment-16713070 ] xuqianjin commented on FLINK-11065: --- hi [~twalthr] [~hequn8128] I added two subtasks,

[GitHub] tillrohrmann commented on issue #7148: [FLINK-10943][tests] Fix test failures in flink runtime caused by curator dependency conflicts

tillrohrmann commented on issue #7148: [FLINK-10943][tests] Fix test failures in flink runtime caused by curator dependency conflicts URL: https://github.com/apache/flink/pull/7148#issuecomment-445289736 Thanks for opening this PR @link3280. I'm wondering what the exact problem is which we

[jira] [Commented] (FLINK-10943) Flink runtime test failed caused by curator dependency conflicts

[ https://issues.apache.org/jira/browse/FLINK-10943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713069#comment-16713069 ] ASF GitHub Bot commented on FLINK-10943: tillrohrmann commented on issue #7148:

[jira] [Updated] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-11105: -- Summary: Add a new implementation of the HighAvailabilityServices using etcd (was: Add an new impleme

[jira] [Created] (FLINK-11105) Add an new implementation of the HighAvailabilityServices using etcd

Yang Wang created FLINK-11105: - Summary: Add an new implementation of the HighAvailabilityServices using etcd Key: FLINK-11105 URL: https://issues.apache.org/jira/browse/FLINK-11105 Project: Flink

[jira] [Commented] (FLINK-11037) Introduce another greedy mechanism for distributing floating buffers

[ https://issues.apache.org/jira/browse/FLINK-11037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713032#comment-16713032 ] Till Rohrmann commented on FLINK-11037: --- Thanks for opening this issue [~zjwang].

[jira] [Commented] (FLINK-10718) Use IO executor in RpcService for message serialization

[ https://issues.apache.org/jira/browse/FLINK-10718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713008#comment-16713008 ] vinoyang commented on FLINK-10718: -- [~till.rohrmann] when you have time, can you review

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

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712995#comment-16712995 ] vinoyang commented on FLINK-6437: - Based on [~Zentol] 's comment before, shall we split t

[jira] [Commented] (FLINK-11104) LEFT JOIN with Table Function not working

[ https://issues.apache.org/jira/browse/FLINK-11104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712978#comment-16712978 ] xueyu commented on FLINK-11104: --- It looks that the doc uses LEFT JOIN LATERAL TABLE..., an

[GitHub] StefanRRichter commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#issuecomment-445270894 Hi, sorry for the late reply I but I was not available for the last week. Your commits are still using merges

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712985#comment-16712985 ] ASF GitHub Bot commented on FLINK-10865: StefanRRichter commented on issue #7123

[jira] [Resolved] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz resolved FLINK-10832. - Resolution: Won't Fix Release Note: Not a flink problem, but a JDK one, solved by upgrading

[jira] [Updated] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11099: -- Priority: Major (was: Minor) > Migrate flink-table runtime CRow Types classes > ---

[jira] [Comment Edited] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711803#comment-16711803 ] Arnaud Linz edited comment on FLINK-10832 at 12/7/18 3:37 PM:

[jira] [Commented] (FLINK-11049) Unable to execute partial DAG

[ https://issues.apache.org/jira/browse/FLINK-11049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712947#comment-16712947 ] Jeff Zhang commented on FLINK-11049: [~till.rohrmann] IIUC, there're 2 kinds of exec

[jira] [Commented] (FLINK-11084) Incorrect ouput after two consecutive split and select

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712942#comment-16712942 ] Aljoscha Krettek commented on FLINK-11084: -- Agreed! Thanks for the explanation.

[jira] [Created] (FLINK-11104) LEFT JOIN with Table Function not working

Denys Fakhritdinov created FLINK-11104: -- Summary: LEFT JOIN with Table Function not working Key: FLINK-11104 URL: https://issues.apache.org/jira/browse/FLINK-11104 Project: Flink Issue T

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712929#comment-16712929 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on issue #7251: [FLINK

[GitHub] zentol commented on issue #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol commented on issue #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#issuecomment-445252542 It might make sense to move the SQL classes, but I believe this is an orthogonal issue to how the modules are structured. This P

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712877#comment-16712877 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on a change in pull re

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712876#comment-16712876 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on a change in pull re

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712875#comment-16712875 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239812506 ## File path: flink-filesystems/flink-s3-fs-presto/pom.xml ## @@ -272,12 +272,6 @@ under the

[GitHub] zentol commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239812427 ## File path: flink-connectors/flink-sql-connector-elasticsearch6/pom.xml ## @@ -0,0 +1,155 @

[GitHub] zentol commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239812303 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@ -174,95 +174,6 @@

[jira] [Created] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

Nico Kruber created FLINK-11102: --- Summary: Enable check for previous data in SpanningRecordSerializer Key: FLINK-11102 URL: https://issues.apache.org/jira/browse/FLINK-11102 Project: Flink Issu

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712862#comment-16712862 ] vinoyang commented on FLINK-11081: -- Will start to fix this issue. > Support binding po

[jira] [Created] (FLINK-11103) Set a default uncaught exception handler

Nico Kruber created FLINK-11103: --- Summary: Set a default uncaught exception handler Key: FLINK-11103 URL: https://issues.apache.org/jira/browse/FLINK-11103 Project: Flink Issue Type: Improvemen

[jira] [Assigned] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11099: Assignee: vinoyang > Migrate flink-table runtime CRow Types classes > -

[jira] [Updated] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11085: --- Labels: pull-request-available (was: ) > NoClassDefFoundError in presto-s3 filesystem > ---

[jira] [Assigned] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11099: Assignee: (was: vinoyang) > Migrate flink-table runtime CRow Types classes > --

[jira] [Assigned] (FLINK-11097) Migrate flink-table runtime InputFormat classes

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11097: Assignee: (was: vinoyang) > Migrate flink-table runtime InputFormat classes > --

[jira] [Assigned] (FLINK-11097) Migrate flink-table runtime InputFormat classes

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11097: Assignee: vinoyang > Migrate flink-table runtime InputFormat classes > -

[jira] [Commented] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712850#comment-16712850 ] ASF GitHub Bot commented on FLINK-11085: zentol opened a new pull request #7261:

[GitHub] zentol opened a new pull request #7261: [FLINK-11085][s3] Fix inclusion of presto hadoop classes

zentol opened a new pull request #7261: [FLINK-11085][s3] Fix inclusion of presto hadoop classes URL: https://github.com/apache/flink/pull/7261 ## What is the purpose of the change This PR fixes the bundling of hadoop classes from `com.facebook.presto.hadoop:hadoop-apache2` in the p

[jira] [Created] (FLINK-11101) Ineffective openjdk exclusion Presto S3 FileSystem module

Chesnay Schepler created FLINK-11101: Summary: Ineffective openjdk exclusion Presto S3 FileSystem module Key: FLINK-11101 URL: https://issues.apache.org/jira/browse/FLINK-11101 Project: Flink

[jira] [Commented] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712826#comment-16712826 ] Chesnay Schepler commented on FLINK-11085: -- Small correction on my part, if the

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712810#comment-16712810 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712815#comment-16712815 ] Chesnay Schepler commented on FLINK-11085: -- indeed, it is an include filter, bu

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712809#comment-16712809 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712811#comment-16712811 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712813#comment-16712813 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in p

[GitHub] tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239796476 ## File path: flink-connectors/flink-sql-connector-elasticsearch6/pom.xml ## @@ -0,0 +1

[GitHub] tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239795255 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@ -174,95 +17

[GitHub] tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239795529 ## File path: flink-connectors/flink-sql-connector-elasticsearch6/pom.xml ## @@ -0,0 +1

[GitHub] tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

tillrohrmann commented on a change in pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#discussion_r239795411 ## File path: flink-filesystems/flink-s3-fs-presto/pom.xml ## @@ -272,12 +272,6 @@ unde

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712768#comment-16712768 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on issue #7251: [FLINK

[GitHub] zentol commented on issue #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol commented on issue #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#issuecomment-445215947 Issue should be fixed; it was the uncommon issue about shading of test-jars for modules that don't have any test classes. -

[jira] [Updated] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11085: - Priority: Blocker (was: Major) > NoClassDefFoundError in presto-s3 filesystem > ---

[jira] [Assigned] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11085: Assignee: Chesnay Schepler > NoClassDefFoundError in presto-s3 filesystem > -

[jira] [Created] (FLINK-11100) Presto S3 FileSystem E2E test broken

Chesnay Schepler created FLINK-11100: Summary: Presto S3 FileSystem E2E test broken Key: FLINK-11100 URL: https://issues.apache.org/jira/browse/FLINK-11100 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712738#comment-16712738 ] ASF GitHub Bot commented on FLINK-11074: dianfu edited a comment on issue #7253:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712754#comment-16712754 ] ASF GitHub Bot commented on FLINK-11074: dianfu edited a comment on issue #7253:

[GitHub] dianfu edited a comment on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu edited a comment on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#issuecomment-445206839 @twalthr @sunjincheng121 @walterddr I have added an `AggFu

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712753#comment-16712753 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull re

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239785455 ## File path: flink-libraries/flink-tabl

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712746#comment-16712746 ] ASF GitHub Bot commented on FLINK-11074: dianfu edited a comment on issue #7253:

[GitHub] dianfu edited a comment on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu edited a comment on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#issuecomment-445206839 @twalthr @sunjincheng121 @walterddr I have added an `AggFu

[GitHub] dianfu edited a comment on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu edited a comment on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#issuecomment-445206839 @twalthr @sunjincheng121 @walterddr I have added an `AggFu

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712720#comment-16712720 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on issue #7251: [FLINK

[jira] [Commented] (FLINK-11097) Migrate flink-table runtime InputFormat classes

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712719#comment-16712719 ] xuqianjin commented on FLINK-11097: --- hi [~Tison]  Thanks for your help. I have submitt

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712721#comment-16712721 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on issue #7253: [FLINK

[GitHub] dianfu commented on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu commented on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#issuecomment-445206839 @twalthr @sunjincheng121 @walterddr I have added an `AggFunctionHa

[GitHub] zentol commented on issue #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol commented on issue #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251#issuecomment-445206789 There's an issue in this PR that causes `mvn install` to fail if the module was already built before. currently investigating wh

[jira] [Commented] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet

[ https://issues.apache.org/jira/browse/FLINK-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712717#comment-16712717 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on issue #7247: [FLINK

[jira] [Commented] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet

[ https://issues.apache.org/jira/browse/FLINK-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712715#comment-16712715 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on a change in pull re

[jira] [Commented] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet

[ https://issues.apache.org/jira/browse/FLINK-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712714#comment-16712714 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on a change in pull re

[jira] [Commented] (FLINK-11080) Define flink-connector-elasticsearch6 uber-jar dependencies via artifactSet

[ https://issues.apache.org/jira/browse/FLINK-11080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712716#comment-16712716 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on a change in pull re

[GitHub] zentol commented on issue #7247: [FLINK-11080][ES] Rework shade-plugin filters

zentol commented on issue #7247: [FLINK-11080][ES] Rework shade-plugin filters URL: https://github.com/apache/flink/pull/7247#issuecomment-445206457 I haven't tried the jar out yet; I'll run the E2E tests against this branch later today.

[GitHub] zentol commented on a change in pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters

zentol commented on a change in pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters URL: https://github.com/apache/flink/pull/7247#discussion_r239778646 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@ -197,29 +197,57 @@ under the L

[GitHub] zentol commented on a change in pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters

zentol commented on a change in pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters URL: https://github.com/apache/flink/pull/7247#discussion_r239778640 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@ -197,29 +197,57 @@ under the L

[GitHub] zentol commented on a change in pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters

zentol commented on a change in pull request #7247: [FLINK-11080][ES] Rework shade-plugin filters URL: https://github.com/apache/flink/pull/7247#discussion_r239778640 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ## @@ -197,29 +197,57 @@ under the L

[jira] [Comment Edited] (FLINK-11065) Migrate flink-table runtime classes

[ https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711649#comment-16711649 ] Timo Walther edited comment on FLINK-11065 at 12/7/18 11:30 AM: --

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712701#comment-16712701 ] ASF GitHub Bot commented on FLINK-11048: mxm commented on a change in pull reque

[jira] [Updated] (FLINK-11092) Migrate flink-table runtime Selector and Collector classes

[ https://issues.apache.org/jira/browse/FLINK-11092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11092: Issue Type: Sub-task (was: New Feature) Parent: FLINK-11065 > Migrate flink-table runtime Selecto

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239777131 ## File path: flink-streaming-java/src/main/java/org/apache/flink/stream

[jira] [Closed] (FLINK-11098) Migrate flink-table runtime Row Types classes

[ https://issues.apache.org/jira/browse/FLINK-11098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin closed FLINK-11098. - Resolution: Duplicate > Migrate flink-table runtime Row Types classes >

[jira] [Commented] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712681#comment-16712681 ] xuqianjin commented on FLINK-11099: --- I will try to finish it > Migrate flink-table ru

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r239773000 ## File path: flink-libraries/flink-tabl

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712680#comment-16712680 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull re

[jira] [Updated] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11099: -- Summary: Migrate flink-table runtime CRow Types classes (was: Migrate flink-table runtime Row Types

[jira] [Updated] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergei Poganshev updated FLINK-11085: - Attachment: image-2018-12-07-13-04-06-563.png > NoClassDefFoundError in presto-s3 filesy

[jira] [Commented] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712667#comment-16712667 ] Sergei Poganshev commented on FLINK-11085: -- [~StephanEwen] Yes, the inclusion r

  1   2   >