[jira] [Assigned] (FLINK-10562) Relax (or document) table name constraints

[ https://issues.apache.org/jira/browse/FLINK-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-10562: Assignee: winifredtang (was: vinoyang) > Relax (or document) table name constraints > --

[jira] [Commented] (FLINK-10511) Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils

[ https://issues.apache.org/jira/browse/FLINK-10511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654708#comment-16654708 ] ASF GitHub Bot commented on FLINK-10511: asfgit closed pull request #6845: [FLIN

[GitHub] asfgit closed pull request #6845: [FLINK-10511][Cluster Management] Reuse the port selection and RPC se…

asfgit closed pull request #6845: [FLINK-10511][Cluster Management] Reuse the port selection and RPC se… URL: https://github.com/apache/flink/pull/6845 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 provenanc

[GitHub] yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges

yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-430892698 @zentol About the `MetricRegistryConfiguration` I have reverted, please review.

[jira] [Resolved] (FLINK-10511) Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils

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

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

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

[jira] [Commented] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE

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

[GitHub] twalthr commented on a change in pull request #6815: [FLINK-7062][cep][table] Added basic support for MATCH_RECOGNIZE

twalthr commented on a change in pull request #6815: [FLINK-7062][cep][table] Added basic support for MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/6815#discussion_r225604789 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/match/

[jira] [Commented] (FLINK-10555) Port AkkaSslITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654698#comment-16654698 ] ASF GitHub Bot commented on FLINK-10555: TisonKun commented on issue #6849: [FLI

[GitHub] TisonKun commented on issue #6849: [FLINK-10555] [test] Port AkkaSslITCase to new code base

TisonKun commented on issue #6849: [FLINK-10555] [test] Port AkkaSslITCase to new code base URL: https://github.com/apache/flink/pull/6849#issuecomment-430890279 @tillrohrmann yes I agree with moving the `BlobServer` SSL specific failures could go into a `BlobServerSSLTest`. For the

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654688#comment-16654688 ] ASF GitHub Bot commented on FLINK-10319: TisonKun commented on issue #6680: [FLI

[GitHub] TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-430886993 As "deploying tasks in topological order", I agree that it could help. It is a orthonormal improvement though.

[jira] [Commented] (FLINK-10577) CEP's greedy() doesn't work

[ https://issues.apache.org/jira/browse/FLINK-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654571#comment-16654571 ] Dian Fu commented on FLINK-10577: - Hi [~simahoa], this is currently by design. For patte

[jira] [Commented] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE

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

[GitHub] dianfu commented on a change in pull request #6815: [FLINK-7062][cep][table] Added basic support for MATCH_RECOGNIZE

dianfu commented on a change in pull request #6815: [FLINK-7062][cep][table] Added basic support for MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/6815#discussion_r226155097 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCo

[jira] [Commented] (FLINK-10436) Example config uses deprecated key jobmanager.rpc.address

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

[GitHub] TisonKun opened a new pull request #6872: [FLINK-10436] Add ConfigOption#withFallbackKeys

TisonKun opened a new pull request #6872: [FLINK-10436] Add ConfigOption#withFallbackKeys URL: https://github.com/apache/flink/pull/6872 ## What is the purpose of the change Add `ConfigOption#withFallbackKeys` to implement a similar function with `ConfigOption#withDeprecatedKeys`. T

[GitHub] zentol closed pull request #6861: [hotfix] [javadocs] Fix some single quote problems

zentol closed pull request #6861: [hotfix] [javadocs] Fix some single quote problems URL: https://github.com/apache/flink/pull/6861 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 is a for

[GitHub] zentol commented on issue #6855: [FLINK-10563] Expose shaded Presto S3 filesystem under "s3p" scheme

zentol commented on issue #6855: [FLINK-10563] Expose shaded Presto S3 filesystem under "s3p" scheme URL: https://github.com/apache/flink/pull/6855#issuecomment-430771951 the shading check must be updated This is an automated

[jira] [Commented] (FLINK-10563) Expose shaded Presto S3 filesystem under "s3p" scheme

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

[jira] [Updated] (FLINK-10586) Running RestServerEndpointITCase may cause Kernel Panic

[ https://issues.apache.org/jira/browse/FLINK-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10586: - Summary: Running RestServerEndpointITCase may cause Kernel Panic (was: Running {{RestServerEndpointITCa

[jira] [Created] (FLINK-10586) Running {{RestServerEndpointITCase}} may cause Kernel Panic

Gary Yao created FLINK-10586: Summary: Running {{RestServerEndpointITCase}} may cause Kernel Panic Key: FLINK-10586 URL: https://issues.apache.org/jira/browse/FLINK-10586 Project: Flink Issue Ty

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

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

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r226050176 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java ## @@

[jira] [Commented] (FLINK-9697) Provide connector for modern Kafka

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

[GitHub] alexeyt820 commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka

alexeyt820 commented on issue #6703: [FLINK-9697] Provide connector for modern Kafka URL: https://github.com/apache/flink/pull/6703#issuecomment-430720238 Fine with me This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-10579) Remove unused deploysettings.xml

[ https://issues.apache.org/jira/browse/FLINK-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10579. Resolution: Fixed master: 812b84c332d2e23c5a9930c81f2a3002fe2e9dd2 > Remove unused deploy

[jira] [Commented] (FLINK-10579) Remove unused deploysettings.xml

[ https://issues.apache.org/jira/browse/FLINK-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653825#comment-16653825 ] ASF GitHub Bot commented on FLINK-10579: zentol closed pull request #6865: [FLIN

[GitHub] zentol closed pull request #6865: [FLINK-10579][build] Remove unused deploysettings.xml

zentol closed pull request #6865: [FLINK-10579][build] Remove unused deploysettings.xml URL: https://github.com/apache/flink/pull/6865 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 is a

[jira] [Commented] (FLINK-10579) Remove unused deploysettings.xml

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

[jira] [Commented] (FLINK-10579) Remove unused deploysettings.xml

[ https://issues.apache.org/jira/browse/FLINK-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653748#comment-16653748 ] ASF GitHub Bot commented on FLINK-10579: StefanRRichter removed a comment on iss

[GitHub] StefanRRichter removed a comment on issue #6865: [FLINK-10579][build] Remove unused deploysettings.xml

StefanRRichter removed a comment on issue #6865: [FLINK-10579][build] Remove unused deploysettings.xml URL: https://github.com/apache/flink/pull/6865#issuecomment-430679849 LGTM 👍 This is an automated message from the Apache

[GitHub] StefanRRichter commented on issue #6865: [FLINK-10579][build] Remove unused deploysettings.xml

StefanRRichter commented on issue #6865: [FLINK-10579][build] Remove unused deploysettings.xml URL: https://github.com/apache/flink/pull/6865#issuecomment-430679849 LGTM 👍 This is an automated message from the Apache Git Ser

[jira] [Commented] (FLINK-10567) Lost serialize fields when ttl state store with the mutable serializer

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

[GitHub] StefanRRichter commented on a change in pull request #6860: [FLINK-10567]Fix TtlStateSerializer lost field during duplicate()

StefanRRichter commented on a change in pull request #6860: [FLINK-10567]Fix TtlStateSerializer lost field during duplicate() URL: https://github.com/apache/flink/pull/6860#discussion_r225984090 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFa

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r225970725 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[jira] [Commented] (FLINK-9715) Support versioned joins with event time

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225960810 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225961569 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225957024 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225962699 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225957516 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225955291 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225957668 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225956138 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225954133 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225957980 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225965180 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtim

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

pnowojski commented on a change in pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#discussion_r225959340 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtim

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

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

[GitHub] tillrohrmann commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

tillrohrmann commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-430661796 Alright, now the problem is a bit clearer to me. The underlying problem is that the `InputSplitAssigner's` sem

[jira] [Closed] (FLINK-10582) Make REST executor thread priority configurable

[ https://issues.apache.org/jira/browse/FLINK-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10582. Resolution: Fixed master: 3f231ac46537654aebdd73b0f42aa823386bf901 1.6: 967b31b333e6f4b01

[jira] [Updated] (FLINK-10582) Make REST executor thread priority configurable

[ https://issues.apache.org/jira/browse/FLINK-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10582: - Fix Version/s: 1.6.2 1.5.5 > Make REST executor thread priority confi

[jira] [Commented] (FLINK-10582) Make REST executor thread priority configurable

[ https://issues.apache.org/jira/browse/FLINK-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653652#comment-16653652 ] ASF GitHub Bot commented on FLINK-10582: zentol closed pull request #6868: [FLIN

[GitHub] zentol closed pull request #6868: [FLINK-10582] Make REST executor's thread priority configurable

zentol closed pull request #6868: [FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6868 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

[jira] [Commented] (FLINK-10582) Make REST executor thread priority configurable

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

[GitHub] zentol commented on a change in pull request #6868: [FLINK-10582] Make REST executor's thread priority configurable

zentol commented on a change in pull request #6868: [FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6868#discussion_r225961269 ## File path: flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java #

[GitHub] zentol closed pull request #6869: [BP-1.6][FLINK-10582] Make REST executor's thread priority configurable

zentol closed pull request #6869: [BP-1.6][FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6869 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 provenan

[GitHub] zentol closed pull request #6870: [BP-1.5][FLINK-10582] Make REST executor's thread priority configurable

zentol closed pull request #6870: [BP-1.5][FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6870 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 provenan

[jira] [Commented] (FLINK-10575) Remove deprecated ExecutionGraphBuilder.buildGraph method

[ https://issues.apache.org/jira/browse/FLINK-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653630#comment-16653630 ] Till Rohrmann commented on FLINK-10575: --- I think this method should only be remove

[jira] [Commented] (FLINK-10436) Example config uses deprecated key jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-10436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653624#comment-16653624 ] Till Rohrmann commented on FLINK-10436: --- Yes, I think this would solve the problem

[jira] [Updated] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test.

[ https://issues.apache.org/jira/browse/FLINK-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10585: - Description: Running the test {{RestServerEndpointITCase#testRequestInterleaving}} in a loop may trigge

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

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

[jira] [Updated] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10583: --- Labels: pull-request-available (was: ) > Add support for state retention to the Processing

[GitHub] kl0u opened a new pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

kl0u opened a new pull request #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871 ## What is the purpose of the change This is the first step for the implementation of FLINK-10583 and FLINK-10584. It in

[jira] [Updated] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test.

[ https://issues.apache.org/jira/browse/FLINK-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10585: - Description: Running the test {{RestServerEndpointITCase#testRequestInterleaving}} in a loop may trigge

[jira] [Updated] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test.

[ https://issues.apache.org/jira/browse/FLINK-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10585: - Environment: *Rev:* 3566bb8987872b29aa88b8f7d5b0f122e74bd518 *OS:* macOS High Sierra 10.13.6 (17G65) *Ma

[jira] [Updated] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test.

[ https://issues.apache.org/jira/browse/FLINK-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10585: - Environment: *Rev:* 3566bb8987872b29aa88b8f7d5b0f122e74bd518 *OS:* macOS High Sierra 10.13.6 (17G65) *M

[jira] [Created] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test.

Gary Yao created FLINK-10585: Summary: RestServerEndpoint responds with wrong Content-Type in Integration Test. Key: FLINK-10585 URL: https://issues.apache.org/jira/browse/FLINK-10585 Project: Flink

[jira] [Commented] (FLINK-10578) Support writable state corresponding to queryable state

[ https://issues.apache.org/jira/browse/FLINK-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653587#comment-16653587 ] Kostas Kloudas commented on FLINK-10578: Thanks a lot [~wind_ljy]! > Support wr

[jira] [Commented] (FLINK-10564) tm costs too much time when communicating with jm

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

[jira] [Closed] (FLINK-10578) Support writable state corresponding to queryable state

[ https://issues.apache.org/jira/browse/FLINK-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-10578. -- Resolution: Not A Problem > Support writable state corresponding to queryable state >

[jira] [Commented] (FLINK-10578) Support writable state corresponding to queryable state

[ https://issues.apache.org/jira/browse/FLINK-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653581#comment-16653581 ] Jiayi Liao commented on FLINK-10578: [~kkl0u] Thanks for pointing out the risks and

[jira] [Created] (FLINK-10584) Add support for state retention to the Event Time versioned joins.

Kostas Kloudas created FLINK-10584: -- Summary: Add support for state retention to the Event Time versioned joins. Key: FLINK-10584 URL: https://issues.apache.org/jira/browse/FLINK-10584 Project: Flink

[jira] [Created] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

Kostas Kloudas created FLINK-10583: -- Summary: Add support for state retention to the Processing Time versioned joins. Key: FLINK-10583 URL: https://issues.apache.org/jira/browse/FLINK-10583 Project:

[jira] [Updated] (FLINK-10578) Support writable state queryable state

[ https://issues.apache.org/jira/browse/FLINK-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10578: --- Summary: Support writable state queryable state (was: Support writable state in QueryableStateClie

[jira] [Updated] (FLINK-10578) Support writable state corresponding to queryable state

[ https://issues.apache.org/jira/browse/FLINK-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10578: --- Summary: Support writable state corresponding to queryable state (was: Support writable state quer

[GitHub] fhueske commented on issue #6857: [hotfix] [table] Refactor SqlToConverter configuration

fhueske commented on issue #6857: [hotfix] [table] Refactor SqlToConverter configuration URL: https://github.com/apache/flink/pull/6857#issuecomment-430625614 +1 to merge This is an automated message from the Apache Git Servi

[jira] [Commented] (FLINK-10253) Run MetricQueryService with lower priority

[ https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653532#comment-16653532 ] ASF GitHub Bot commented on FLINK-10253: asfgit closed pull request #6839: [FLIN

[GitHub] asfgit closed pull request #6839: [FLINK-10253] Run MetricQueryService with lower priority

asfgit closed pull request #6839: [FLINK-10253] Run MetricQueryService with lower priority URL: https://github.com/apache/flink/pull/6839 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 is

[jira] [Closed] (FLINK-10253) Run MetricQueryService with lower priority

[ https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10253. - Resolution: Fixed Fix Version/s: (was: 1.5.6) (was: 1.6.3) Fix

[GitHub] tillrohrmann opened a new pull request #6870: [BP-1.5][FLINK-10582] Make REST executor's thread priority configurable

tillrohrmann opened a new pull request #6870: [BP-1.5][FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6870 Backport of #6868 to `release-1.5`. This is an automated

[GitHub] tillrohrmann opened a new pull request #6869: [BP-1.6][FLINK-10582] Make REST executor's thread priority configurable

tillrohrmann opened a new pull request #6869: [BP-1.6][FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6869 Backport of #6868 to `release-1.6`. This is an automated

[jira] [Commented] (FLINK-10582) Make REST executor thread priority configurable

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

[jira] [Updated] (FLINK-10582) Make REST executor thread priority configurable

[ https://issues.apache.org/jira/browse/FLINK-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10582: --- Labels: pull-request-available (was: ) > Make REST executor thread priority configurable >

[GitHub] tillrohrmann opened a new pull request #6868: [FLINK-10582] Make REST executor's thread priority configurable

tillrohrmann opened a new pull request #6868: [FLINK-10582] Make REST executor's thread priority configurable URL: https://github.com/apache/flink/pull/6868 ## What is the purpose of the change Introduce RestOptions#SERVER_THREAD_PRIORITY("rest.server.thread-priority") to configure

[jira] [Commented] (FLINK-10537) Network throughput performance regression after broadcast changes

[ https://issues.apache.org/jira/browse/FLINK-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653494#comment-16653494 ] ASF GitHub Bot commented on FLINK-10537: pnowojski closed pull request #6833: [F

[GitHub] pnowojski closed pull request #6833: [FLINK-10537][network] Fix network small performance degradation after merging [FLINK-9913]

pnowojski closed pull request #6833: [FLINK-10537][network] Fix network small performance degradation after merging [FLINK-9913] URL: https://github.com/apache/flink/pull/6833 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below f

  1   2   3   >