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

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712615#comment-16712615 ] xuqianjin commented on FLINK-11097: --- I will try to finish it > Migrate flink-table runtime io classes

[jira] [Updated] (FLINK-11093) Migrate flink-table runtime Function classes

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

[jira] [Updated] (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 ] Jark Wu updated FLINK-11097: Summary: Migrate flink-table runtime InputFormat classes (was: Migrate flink-table InputFormat classes

[GitHub] tillrohrmann closed pull request #7118: [FLINK-10482] Fix double counting of checkpoint stat

tillrohrmann closed pull request #7118: [FLINK-10482] Fix double counting of checkpoint stat URL: https://github.com/apache/flink/pull/7118 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[GitHub] tillrohrmann commented on issue #7118: [FLINK-10482] Fix double counting of checkpoint stat

tillrohrmann commented on issue #7118: [FLINK-10482] Fix double counting of checkpoint stat URL: https://github.com/apache/flink/pull/7118#issuecomment-445194513 Manually merged. This is an automated message from the Apache

[jira] [Updated] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11083: -- Fix Version/s: 1.7.1 1.8.0 > CRowSerializerConfigSnapshot is not

[jira] [Updated] (FLINK-11097) Migrate flink-table runtime io classes

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11097: Issue Type: Task (was: New Feature) > Migrate flink-table runtime io classes >

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

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

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

xuqianjin created FLINK-11098: - Summary: Migrate flink-table runtime Row Types classes Key: FLINK-11098 URL: https://issues.apache.org/jira/browse/FLINK-11098 Project: Flink Issue Type: New

[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

[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=16712754#comment-16712754 ] ASF GitHub Bot commented on FLINK-11074: dianfu edited a comment on issue #7253: [FLINK-11074]

[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] [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=16712768#comment-16712768 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on issue #7251: [FLINK-11026][ES6]

[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 @@

[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

[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

[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=16712875#comment-16712875 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on a change in pull request #7251:

[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

[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_r239812506 ## File path: flink-filesystems/flink-s3-fs-presto/pom.xml ## @@ -272,12 +272,6 @@ under the

[jira] [Closed] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-10809. --- Resolution: Fixed > Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state

[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=16711649#comment-16711649 ] Timo Walther edited comment on FLINK-11065 at 12/7/18 11:30 AM:

[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:

[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=16712753#comment-16712753 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull request #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

[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=16712862#comment-16712862 ] vinoyang commented on FLINK-11081: -- Will start to fix this issue. > Support binding port range for

[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:

[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

[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=16712664#comment-16712664 ] ASF GitHub Bot commented on FLINK-11080: tillrohrmann commented on a change in pull request

[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=16712667#comment-16712667 ] Sergei Poganshev commented on FLINK-11085: -- [~StephanEwen] Yes, the inclusion rule is there,

[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

[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=16712813#comment-16712813 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in pull request

[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=16712809#comment-16712809 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in pull request

[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=16712811#comment-16712811 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in pull request

[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

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11087: -- Fix Version/s: 1.8.0 > Broadcast state migration Incompatibility from 1.5.3 to 1.7.0 >

[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=16712618#comment-16712618 ] ASF GitHub Bot commented on FLINK-10887: aljoscha commented on issue #7099: [FLINK-10887]

[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=16712701#comment-16712701 ] ASF GitHub Bot commented on FLINK-11048: mxm commented on a change in pull request #7249:

[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=16712738#comment-16712738 ] ASF GitHub Bot commented on FLINK-11074: dianfu edited a comment on issue #7253: [FLINK-11074]

[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] [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-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-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] [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

[jira] [Reopened] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-10809: - > Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state > after restore >

[jira] [Updated] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10809: Affects Version/s: 1.5.5 1.6.2 > Using

[jira] [Updated] (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 ] Jark Wu updated FLINK-11097: Affects Version/s: (was: 1.7.0) > Migrate flink-table runtime InputFormat classes >

[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:

[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=16712680#comment-16712680 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull request #7253:

[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

[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

[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=16712815#comment-16712815 ] Chesnay Schepler commented on FLINK-11085: -- indeed, it is an include filter, but for some

[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:

[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

[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

[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=16712721#comment-16712721 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on issue #7253: [FLINK-11074]

[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

[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=16712719#comment-16712719 ] xuqianjin commented on FLINK-11097: --- hi [~Tison]  Thanks for your help. I have submitted the email >

[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=16712720#comment-16712720 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on issue #7251: [FLINK-11026][ES6]

[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] [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=16712826#comment-16712826 ] Chesnay Schepler commented on FLINK-11085: -- Small correction on my part, if the following

[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=16712850#comment-16712850 ] ASF GitHub Bot commented on FLINK-11085: zentol opened a new pull request #7261:

[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 >

[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

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

aljoscha commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#issuecomment-445189806 Also, congratulations, I guess!  This is an

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

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

[jira] [Updated] (FLINK-11097) Migrate flink-table runtime io classes

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11097: -- Issue Type: New Feature (was: Bug) > Migrate flink-table runtime io classes >

[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=16712616#comment-16712616 ] ASF GitHub Bot commented on FLINK-10887: aljoscha commented on issue #7099: [FLINK-10887]

[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=16712631#comment-16712631 ] TisonKun commented on FLINK-11097: -- [~x1q1j1] if you don't have contributor permission yet(to assign

[GitHub] StefanRRichter commented on issue #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

StefanRRichter commented on issue #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#issuecomment-445192951 @Clark background is that it will make things easier and otherwise you have

[GitHub] TisonKun commented on issue #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd…

TisonKun commented on issue #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd… URL: https://github.com/apache/flink/pull/7184#issuecomment-445196825 cc @StephanEwen who introduced these classes

[jira] [Resolved] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10482. --- Resolution: Fixed Fix Version/s: 1.5.6 Fixed via 1.8.0:

[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=16712681#comment-16712681 ] xuqianjin commented on FLINK-11099: --- I will try to finish it > Migrate flink-table runtime CRow

[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=16712876#comment-16712876 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on a change in pull request #7251:

[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=16712877#comment-16712877 ] ASF GitHub Bot commented on FLINK-11026: zentol commented on a change in pull request #7251:

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11094: -- Fix Version/s: 1.8.0 > Restored state in RocksDBStateBackend that has not been accessed in

[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

[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] [Updated] (FLINK-11097) Migrate flink-table InputFormat classes

[ https://issues.apache.org/jira/browse/FLINK-11097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11097: -- Issue Type: New Feature (was: Task) Summary: Migrate flink-table InputFormat classes (was:

[jira] [Commented] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712643#comment-16712643 ] ASF GitHub Bot commented on FLINK-10482: tillrohrmann commented on issue #7118: [FLINK-10482]

[jira] [Created] (FLINK-11099) Migrate flink-table runtime Row Types classes

xuqianjin created FLINK-11099: - Summary: Migrate flink-table runtime Row Types classes Key: FLINK-11099 URL: https://issues.apache.org/jira/browse/FLINK-11099 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712644#comment-16712644 ] ASF GitHub Bot commented on FLINK-10482: tillrohrmann closed pull request #7118: [FLINK-10482]

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712632#comment-16712632 ] ASF GitHub Bot commented on FLINK-10431: StefanRRichter commented on issue #6898: [FLINK-10431]

[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=16712665#comment-16712665 ] ASF GitHub Bot commented on FLINK-11080: tillrohrmann commented on a change in pull request

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

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

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

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

[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-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=16712717#comment-16712717 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on issue #7247: [FLINK-11080][ES]

[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=16712715#comment-16712715 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on a change in pull request #7247:

[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=16712714#comment-16712714 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on a change in pull request #7247:

[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=16712716#comment-16712716 ] ASF GitHub Bot commented on FLINK-11080: zentol commented on a change in pull request #7247:

[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

[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.

[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=16712746#comment-16712746 ] ASF GitHub Bot commented on FLINK-11074: dianfu edited a comment on issue #7253: [FLINK-11074]

[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=16712810#comment-16712810 ] ASF GitHub Bot commented on FLINK-11026: tillrohrmann commented on a change in pull request

[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=16712942#comment-16712942 ] Aljoscha Krettek commented on FLINK-11084: -- Agreed! Thanks for the explanation. We should fix

[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=16712978#comment-16712978 ] xueyu commented on FLINK-11104: --- It looks that the doc uses LEFT JOIN LATERAL TABLE..., and your sql

[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=16713069#comment-16713069 ] ASF GitHub Bot commented on FLINK-10943: tillrohrmann commented on issue #7148:

  1   2   >