[jira] [Assigned] (FLINK-7857) Port JobVertexDetails to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7857: Assignee: Fang Yong > Port JobVertexDetails to REST endpoint >

[jira] [Assigned] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7856: Assignee: Fang Yong > Port JobVertexBackPressureHandler to REST endpoint >

[jira] [Assigned] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7855: Assignee: Fang Yong > Port JobVertexAccumulatorsHandler to REST endpoint >

[jira] [Assigned] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-7858: Assignee: Fang Yong > Port JobVertexTaskManagersHandler to REST endpoint >

[jira] [Created] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint

Fang Yong created FLINK-7858: Summary: Port JobVertexTaskManagersHandler to REST endpoint Key: FLINK-7858 URL: https://issues.apache.org/jira/browse/FLINK-7858 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7857) Port JobVertexDetails to REST endpoint

Fang Yong created FLINK-7857: Summary: Port JobVertexDetails to REST endpoint Key: FLINK-7857 URL: https://issues.apache.org/jira/browse/FLINK-7857 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

Fang Yong created FLINK-7856: Summary: Port JobVertexBackPressureHandler to REST endpoint Key: FLINK-7856 URL: https://issues.apache.org/jira/browse/FLINK-7856 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint

Fang Yong created FLINK-7855: Summary: Port JobVertexAccumulatorsHandler to REST endpoint Key: FLINK-7855 URL: https://issues.apache.org/jira/browse/FLINK-7855 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #4843: [FLINK-7703] Port JobExceptionsHandler to new REST...

GitHub user zjureel opened a pull request: https://github.com/apache/flink/pull/4843 [FLINK-7703] Port JobExceptionsHandler to new REST endpoint ## What is the purpose of the change Port JobExceptionsHandler to new REST endpoint ## Brief change log - *Create J

[jira] [Commented] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

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

[jira] [Assigned] (FLINK-7854) Reject lateral table outer joins with predicates in SQL

[ https://issues.apache.org/jira/browse/FLINK-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7854: -- Assignee: Xingcan Cui > Reject lateral table outer joins with predicates in SQL > -

[jira] [Commented] (FLINK-7853) Reject table function outer joins with predicates in Table API

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

[GitHub] flink pull request #4842: [FLINK-7853] [table] Reject table function outer j...

GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/4842 [FLINK-7853] [table] Reject table function outer joins with predicates in table API # What is the purpose of the change Due to CALCITE-2004, this PR aims to temporarily restrict the predicate

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206933#comment-16206933 ] ASF GitHub Bot commented on FLINK-7730: --- Github user xccui closed the pull request a

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

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

[GitHub] flink issue #4830: [FLINK-7730] [table] Restrict the predicates of table fun...

Github user xccui commented on the issue: https://github.com/apache/flink/pull/4830 @fhueske, I'll separate this PR into sub ones. ---

[GitHub] flink pull request #4830: [FLINK-7730] [table] Restrict the predicates of ta...

Github user xccui closed the pull request at: https://github.com/apache/flink/pull/4830 ---

[jira] [Created] (FLINK-7854) Reject lateral table outer joins with predicates in SQL

Xingcan Cui created FLINK-7854: -- Summary: Reject lateral table outer joins with predicates in SQL Key: FLINK-7854 URL: https://issues.apache.org/jira/browse/FLINK-7854 Project: Flink Issue Type:

[jira] [Created] (FLINK-7853) Reject table function outer joins with predicates in Table API

Xingcan Cui created FLINK-7853: -- Summary: Reject table function outer joins with predicates in Table API Key: FLINK-7853 URL: https://issues.apache.org/jira/browse/FLINK-7853 Project: Flink Iss

[jira] [Commented] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206774#comment-16206774 ] Rong Rong commented on FLINK-7373: -- Hi [~fhueske], no we haven't found a great solution s

[jira] [Comment Edited] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206280#comment-16206280 ] Zhenzhong Xu edited comment on FLINK-7844 at 10/16/17 5:58 PM: -

[jira] [Comment Edited] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206280#comment-16206280 ] Zhenzhong Xu edited comment on FLINK-7844 at 10/16/17 5:46 PM: -

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206280#comment-16206280 ] Zhenzhong Xu commented on FLINK-7844: - [~till.rohrmann] We have a use case where Task

[jira] [Assigned] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu reassigned FLINK-7844: --- Assignee: Zhenzhong Xu > Fine Grained Recovery triggers checkpoint timeout failure >

[jira] [Closed] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7798. Resolution: Implemented Implemented for 1.4.0 with e79cedf23b42a67f28c23c558a4b0be2179aba2d > Add s

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206152#comment-16206152 ] ASF GitHub Bot commented on FLINK-7798: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4825: [FLINK-7798] [table] Add support for stream window...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4825 ---

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206150#comment-16206150 ] Fabian Hueske commented on FLINK-7730: -- The pressing issue that needs to be fixed bef

[jira] [Created] (FLINK-7852) An input of GenericTypeInfo cannot be converted to Table

hanningning created FLINK-7852: -- Summary: An input of GenericTypeInfo cannot be converted to Table Key: FLINK-7852 URL: https://issues.apache.org/jira/browse/FLINK-7852 Project: Flink Issue Typ

[jira] [Comment Edited] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206121#comment-16206121 ] Xingcan Cui edited comment on FLINK-7730 at 10/16/17 4:17 PM: --

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206121#comment-16206121 ] Xingcan Cui commented on FLINK-7730: Hi [~fhueske], more reasons are revealed for thes

[jira] [Commented] (FLINK-7426) Table API does not support null values in keys

[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206118#comment-16206118 ] ASF GitHub Bot commented on FLINK-7426: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #4732: [FLINK-7426] [table] Support null values in keys

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4732#discussion_r144893264 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowKeySelector.scala --- @@ -0,0 +1,51 @@ +/* + * Licensed to t

[GitHub] flink pull request #4732: [FLINK-7426] [table] Support null values in keys

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4732#discussion_r144893205 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowKeySelector.scala --- @@ -0,0 +1,51 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-7426) Table API does not support null values in keys

[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206117#comment-16206117 ] ASF GitHub Bot commented on FLINK-7426: --- Github user twalthr commented on a diff in

[jira] [Resolved] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7371. - Resolution: Fixed Fixed in 1.4.0: 861c57cb10a3ccc862ec068869582bc1551feaa5 > user defined aggrega

[jira] [Commented] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206093#comment-16206093 ] ASF GitHub Bot commented on FLINK-7371: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4736 ---

[jira] [Commented] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

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

[GitHub] flink issue #4736: [FLINK-7371] [table] Add support for constant parameters ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4736 Thanks @fhueske. I addressed you feedback. Will merge this now... ---

[jira] [Comment Edited] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206046#comment-16206046 ] Piotr Nowojski edited comment on FLINK-7368 at 10/16/17 3:31 PM: ---

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7844: - Affects Version/s: 1.4.0 > Fine Grained Recovery triggers checkpoint timeout failure > ---

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7844: - Component/s: (was: Core) State Backends, Checkpointing > Fine Grained Recover

[jira] [Comment Edited] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206017#comment-16206017 ] Till Rohrmann edited comment on FLINK-7844 at 10/16/17 3:23 PM:

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

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

[GitHub] flink pull request #4841: [FLINK-7368][metrics] Backport synchronization fix...

GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4841 [FLINK-7368][metrics] Backport synchronization fix for MetricStore ## What is the purpose of the change This backports adding missing synchronization on MetricStore ## Verifying t

[jira] [Commented] (FLINK-7340) Taskmanager hung after temporary DNS outage

[ https://issues.apache.org/jira/browse/FLINK-7340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206053#comment-16206053 ] Till Rohrmann commented on FLINK-7340: -- Thanks for the pointer [~hadronzoo], I think

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206046#comment-16206046 ] Piotr Nowojski commented on FLINK-7368: --- [~Zentol] 1.3 branch doesn't have [~till.ro

[jira] [Comment Edited] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206046#comment-16206046 ] Piotr Nowojski edited comment on FLINK-7368 at 10/16/17 3:15 PM: ---

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

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

[GitHub] flink pull request #4840: [FLINK-7368][metrics] Make MetricStore ThreadSafe ...

GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4840 [FLINK-7368][metrics] Make MetricStore ThreadSafe class Remove external synchronisation on MetricStore ## What is the purpose of the change This is a refactor that makes `MetricSt

[jira] [Assigned] (FLINK-7783) Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover()

[ https://issues.apache.org/jira/browse/FLINK-7783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7783: --- Assignee: Aljoscha Krettek > Don't always remove checkpoints in ZooKeeperCompletedChe

[jira] [Comment Edited] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206017#comment-16206017 ] Till Rohrmann edited comment on FLINK-7844 at 10/16/17 2:54 PM:

[jira] [Assigned] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator

[ https://issues.apache.org/jira/browse/FLINK-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7851: Assignee: Till Rohrmann > Improve scheduling balance in case of fewer sub tasks than input

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206017#comment-16206017 ] Till Rohrmann commented on FLINK-7844: -- Hi [~zhenzhongxu], thanks for the feedback.

[jira] [Commented] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator

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

[GitHub] flink pull request #4839: [FLINK-7851] [scheduling] Improve scheduling balan...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4839 [FLINK-7851] [scheduling] Improve scheduling balance by round robin distribution ## What is the purpose of the change Polls in a round robin fashion from the slots multimap in `SlotSh

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205993#comment-16205993 ] ASF GitHub Bot commented on FLINK-6173: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4837#discussion_r144866086 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -252,6 +261,29 @@ under the License.

[jira] [Updated] (FLINK-7604) Add OpenTSDB metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-7604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7604: -- Fix Version/s: (was: 1.3.3) (was: 1.4.0) 1.5.0 > A

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205943#comment-16205943 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205942#comment-16205942 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3748 A few minor things left, but we're in pretty good shape now. ---

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r144854453 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@ -465,

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r144854466 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@ -465,

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205937#comment-16205937 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205936#comment-16205936 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205938#comment-16205938 ] ASF GitHub Bot commented on FLINK-6225: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r143966527 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java --- @@ -0,0 +1,59 @@

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r143965663 --- Diff: flink-connectors/flink-connector-cassandra/pom.xml --- @@ -187,5 +187,17 @@ under the License.

[GitHub] flink pull request #3748: [FLINK-6225] [Cassandra Connector] add CassandraTa...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3748#discussion_r143965738 --- Diff: flink-connectors/flink-connector-cassandra/pom.xml --- @@ -187,5 +187,17 @@ under the License.

[jira] [Updated] (FLINK-6861) Use OperatorID in metric system

[ https://issues.apache.org/jira/browse/FLINK-6861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6861: Fix Version/s: (was: 1.4.0) > Use OperatorID in metric system >

[jira] [Closed] (FLINK-7417) Create flink-shaded-jackson

[ https://issues.apache.org/jira/browse/FLINK-7417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7417. --- Resolution: Fixed Add to flink-shaded in 2e2fdcca6a655e2208d840d1f6a105681124bac6. > Create f

[jira] [Created] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator

Till Rohrmann created FLINK-7851: Summary: Improve scheduling balance in case of fewer sub tasks than input operator Key: FLINK-7851 URL: https://issues.apache.org/jira/browse/FLINK-7851 Project: Flin

[jira] [Commented] (FLINK-7826) Add support for all types of state to the QueryableStateClient.

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

[jira] [Commented] (FLINK-7826) Add support for all types of state to the QueryableStateClient.

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

[GitHub] flink issue #4838: [FLINK-7826][QS] Add support for all types of state to th...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4838 R @aljoscha ---

[GitHub] flink pull request #4838: [FLINK-7826][QS] Add support for all types of stat...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/4838 [FLINK-7826][QS] Add support for all types of state to the QS Client. ## What is the purpose of the change As the JIRA describes, it makes the queryable state client able to query all types of

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205911#comment-16205911 ] ASF GitHub Bot commented on FLINK-6173: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4837#discussion_r144850901 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -213,36 +209,49 @@ under the License.

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205904#comment-16205904 ] ASF GitHub Bot commented on FLINK-6173: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205905#comment-16205905 ] ASF GitHub Bot commented on FLINK-6173: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205906#comment-16205906 ] ASF GitHub Bot commented on FLINK-6173: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4837#discussion_r144850032 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -213,36 +209,49 @@ under the License.

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4837#discussion_r144848665 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -252,6 +261,29 @@ under the License.

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4837#discussion_r144849032 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -252,6 +261,29 @@ under the License.

[jira] [Commented] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205895#comment-16205895 ] Till Rohrmann commented on FLINK-7153: -- Looking at the code of the {{Scheduler#schedu

[jira] [Commented] (FLINK-7848) Allow time attributes for atomic types

[ https://issues.apache.org/jira/browse/FLINK-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205890#comment-16205890 ] Fabian Hueske commented on FLINK-7848: -- This would be supported with the refactoring

[jira] [Created] (FLINK-7850) Given each maven profile an activation property

Chesnay Schepler created FLINK-7850: --- Summary: Given each maven profile an activation property Key: FLINK-7850 URL: https://issues.apache.org/jira/browse/FLINK-7850 Project: Flink Issue Typ

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

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

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4837 [FLINK-6173] [table] Clean-up flink-table jar and dependencies ## What is the purpose of the change This PR cleans the `flink-table` dependencies almost entirely. The jar only contains file

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205885#comment-16205885 ] Chesnay Schepler commented on FLINK-7368: - We should be able to backport the synch

[jira] [Commented] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205877#comment-16205877 ] Till Rohrmann commented on FLINK-7153: -- Why don't we make the scheduling dependent on

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205876#comment-16205876 ] Piotr Nowojski commented on FLINK-7368: --- For 1.4 this was fixed by [~till.rohrmann]

[jira] [Commented] (FLINK-5968) Document WindowedStream.aggregate()

[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205864#comment-16205864 ] ASF GitHub Bot commented on FLINK-5968: --- Github user alpinegizmo commented on a diff

[GitHub] flink pull request #4833: [FLINK-5968] Add documentation for WindowedStream....

Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4833#discussion_r144842788 --- Diff: docs/dev/stream/operators/windows.md --- @@ -721,6 +808,111 @@ input + Incremental Window Aggregation with AggregateFu

[jira] [Commented] (FLINK-7849) Remove guava shading from hcatalog connector

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

[GitHub] flink pull request #4836: [FLINK-7849][hcatalog] Remove unnecessary gauva sh...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4836 [FLINK-7849][hcatalog] Remove unnecessary gauva shading see #4834. You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 7849 Alternativel

[jira] [Created] (FLINK-7849) Remove guava shading from hcatalog connector

Chesnay Schepler created FLINK-7849: --- Summary: Remove guava shading from hcatalog connector Key: FLINK-7849 URL: https://issues.apache.org/jira/browse/FLINK-7849 Project: Flink Issue Type:

  1   2   3   >