[GitHub] tillrohrmann commented on issue #7111: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann commented on issue #7111: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7111#issuecomment-439315975 Thanks for the review @zentol. Merging.

[jira] [Resolved] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom

[ https://issues.apache.org/jira/browse/FLINK-10877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10877. --- Resolution: Fixed Fixed via master:

[jira] [Commented] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689145#comment-16689145 ] Fabian Wollert commented on FLINK-10705: build and deployment to our dev cluster worked fine.

[GitHub] tillrohrmann closed pull request #7094: [FLINK-10877] Cleanup flink-connector-kafka pom file

tillrohrmann closed pull request #7094: [FLINK-10877] Cleanup flink-connector-kafka pom file URL: https://github.com/apache/flink/pull/7094 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

[jira] [Commented] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom

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

[GitHub] tillrohrmann closed pull request #7113: [BP-1.6][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann closed pull request #7113: [BP-1.6][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7113 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[GitHub] tillrohrmann closed pull request #7111: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann closed pull request #7111: [FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7111 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[GitHub] tillrohrmann closed pull request #7112: [BP-1.7][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann closed pull request #7112: [BP-1.7][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7112 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

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

[GitHub] tillrohrmann closed pull request #7114: [BP-1.5][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test

tillrohrmann closed pull request #7114: [BP-1.5][FLINK-10856] Find latest completed checkpoint for resume from externalized checkpoint e2e test URL: https://github.com/apache/flink/pull/7114 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689159#comment-16689159 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on issue #7087: [FLINK-10843]

[GitHub] twalthr commented on issue #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on issue #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#issuecomment-439317653 @pnowojski I updated the PR. Now we just matched against the version `universal`.

[GitHub] ambition119 opened a new pull request #7120: fix up RowSerializer.copy occur ClassCastException

ambition119 opened a new pull request #7120: fix up RowSerializer.copy occur ClassCastException URL: https://github.com/apache/flink/pull/7120 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10908: -- Description: Add yarn.application.priority in YarnConfigOptions, changes the priority of the

[GitHub] tillrohrmann closed pull request #7115: [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann closed pull request #7115: [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7115 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[GitHub] tillrohrmann commented on issue #7115: [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann commented on issue #7115: [FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7115#issuecomment-439316401 Thanks for the review @zentol. Merging.

[jira] [Closed] (FLINK-10856) Harden resume from externalized checkpoint E2E test

[ https://issues.apache.org/jira/browse/FLINK-10856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10856. - Resolution: Fixed Fixed via master:

[GitHub] tillrohrmann closed pull request #7117: [BP-1.6][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann closed pull request #7117: [BP-1.6][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7117 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[GitHub] tillrohrmann closed pull request #7116: [BP-1.7][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out

tillrohrmann closed pull request #7116: [BP-1.7][FLINK-10883] Failing batch jobs with NoResourceAvailableException when slot request times out URL: https://github.com/apache/flink/pull/7116 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Commented] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

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

[jira] [Resolved] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

[ https://issues.apache.org/jira/browse/FLINK-10883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10883. --- Resolution: Fixed Fixed via master:

[jira] [Commented] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout

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

[jira] [Commented] (FLINK-10856) Harden resume from externalized checkpoint E2E test

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

[jira] [Created] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

xymaqingxiang created FLINK-10908: - Summary: Add yarn.application.priority in YarnConfigOptions Key: FLINK-10908 URL: https://issues.apache.org/jira/browse/FLINK-10908 Project: Flink Issue

[GitHub] zentol closed pull request #7119: [FLINK-10907] Fix Flink JobManager metrics from getting stuck after a job recovery.

zentol closed pull request #7119: [FLINK-10907] Fix Flink JobManager metrics from getting stuck after a job recovery. URL: https://github.com/apache/flink/pull/7119 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[jira] [Closed] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values

[ https://issues.apache.org/jira/browse/FLINK-10907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10907. Resolution: Won't Fix Not a problem in 1.5 and above. The JobManagerJobMetricGroup is

[jira] [Commented] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values

[ https://issues.apache.org/jira/browse/FLINK-10907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689414#comment-16689414 ] ASF GitHub Bot commented on FLINK-10907: zentol closed pull request #7119: [FLINK-10907] Fix

[GitHub] zentol commented on issue #7119: [FLINK-10907] Fix Flink JobManager metrics from getting stuck after a job recovery.

zentol commented on issue #7119: [FLINK-10907] Fix Flink JobManager metrics from getting stuck after a job recovery. URL: https://github.com/apache/flink/pull/7119#issuecomment-439391428 Not a problem in 1.5 and above, see the JIRA for more details.

[jira] [Commented] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values

[ https://issues.apache.org/jira/browse/FLINK-10907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689413#comment-16689413 ] ASF GitHub Bot commented on FLINK-10907: zentol commented on issue #7119: [FLINK-10907] Fix

[GitHub] zentol commented on issue #7120: fix up RowSerializer.copy occur ClassCastException

zentol commented on issue #7120: fix up RowSerializer.copy occur ClassCastException URL: https://github.com/apache/flink/pull/7120#issuecomment-439391864 Please open a JIRA before opening a PR, and include a description as to when this issue can occur. Additionally we require a test to

[GitHub] zentol closed pull request #7120: fix up RowSerializer.copy occur ClassCastException

zentol closed pull request #7120: fix up RowSerializer.copy occur ClassCastException URL: https://github.com/apache/flink/pull/7120 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

[GitHub] wujinhu opened a new pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

wujinhu opened a new pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123 ## What is the purpose of the change This PR will add an implementation of a file system that read from & write to

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

[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10865: --- Labels: pull-request-available (was: ) > Implement Flink's own Aliyun OSS filesystem >

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

[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689419#comment-16689419 ] ASF GitHub Bot commented on FLINK-10865: wujinhu opened a new pull request #7123: [FLINK-10865]

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10908: -- Description: Add yarn.application.priority in YarnConfigOptions, Changes the priority of the

[jira] [Commented] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689246#comment-16689246 ] ASF GitHub Bot commented on FLINK-10908: maqingxiang opened a new pull request #7122:

[GitHub] maqingxiang opened a new pull request #7122: [FLINK-10908][flink-yarn]Add yarn.application.priority in YarnConfigOptions

maqingxiang opened a new pull request #7122: [FLINK-10908][flink-yarn]Add yarn.application.priority in YarnConfigOptions URL: https://github.com/apache/flink/pull/7122 ## What is the purpose of the change Add the priority of the Flink YARN application.

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10908: --- Labels: pull-request-available (was: ) > Add yarn.application.priority in

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10908: -- Description:   Changes the priority of the job. Allowed priority values are VERY_HIGH, HIGH,

[jira] [Created] (FLINK-10909) Possible RocksDBStateBackend performance regression with rocksdbjni-5.7.5

Mohamed Amine ABDESSEMED created FLINK-10909: Summary: Possible RocksDBStateBackend performance regression with rocksdbjni-5.7.5 Key: FLINK-10909 URL: https://issues.apache.org/jira/browse/FLINK-10909

[jira] [Commented] (FLINK-10909) Possible RocksDBStateBackend performance regression with rocksdbjni-5.7.5

[ https://issues.apache.org/jira/browse/FLINK-10909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689332#comment-16689332 ] Stefan Richter commented on FLINK-10909: The test you mentioned is part of the flink test suite,

[GitHub] asfgit closed pull request #6900: [FLINK-10642][table] fix CodeGen split fields errors in special config

asfgit closed pull request #6900: [FLINK-10642][table] fix CodeGen split fields errors in special config URL: https://github.com/apache/flink/pull/6900 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

[jira] [Commented] (FLINK-10642) CodeGen split fields errors when maxGeneratedCodeLength equals 1

[ https://issues.apache.org/jira/browse/FLINK-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689453#comment-16689453 ] ASF GitHub Bot commented on FLINK-10642: asfgit closed pull request #6900: [FLINK-10642][table]

[jira] [Resolved] (FLINK-10642) CodeGen split fields errors when maxGeneratedCodeLength equals 1

[ https://issues.apache.org/jira/browse/FLINK-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10642. -- Resolution: Fixed Fix Version/s: 1.7.0 1.6.3

[GitHub] twalthr closed pull request #3830: [hotfix] [table] Optimize aggregate function get type

twalthr closed pull request #3830: [hotfix] [table] Optimize aggregate function get type URL: https://github.com/apache/flink/pull/3830 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] twalthr closed pull request #3569: [FLINK-6036] [table] Let catalog support partition

twalthr closed pull request #3569: [FLINK-6036] [table] Let catalog support partition URL: https://github.com/apache/flink/pull/3569 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

[GitHub] tzulitai opened a new pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution

tzulitai opened a new pull request #7124: [FLINK-9574] [doc] Rework documentation for custom state serializers and state evolution URL: https://github.com/apache/flink/pull/7124 ## What is the purpose of the change This PR adds a new "State Schema Evolution" page under "State &

[jira] [Updated] (FLINK-6036) Let catalog support partition

[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6036: -- Labels: pull-request-available (was: ) > Let catalog support partition >

[jira] [Updated] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9574: -- Labels: pull-request-available (was: ) > Add a dedicated documentation page for state

[jira] [Commented] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689502#comment-16689502 ] ASF GitHub Bot commented on FLINK-9574: --- tzulitai opened a new pull request #7124: [FLINK-9574]

[jira] [Commented] (FLINK-6457) Clean up ScalarFunction and TableFunction interface

[ https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689515#comment-16689515 ] ASF GitHub Bot commented on FLINK-6457: --- twalthr closed pull request #3880: [FLINK-6457] [table]

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

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

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

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

[GitHub] twalthr commented on issue #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

twalthr commented on issue #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#issuecomment-439437076 Thanks @pnowojski. Will merge this. This is

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689586#comment-16689586 ] ASF GitHub Bot commented on FLINK-10843: twalthr commented on issue #7087: [FLINK-10843]

[jira] [Commented] (FLINK-10880) Failover strategies should not be applied to Batch Execution

[ https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689606#comment-16689606 ] TisonKun commented on FLINK-10880: -- [~till.rohrmann] alright I agree your quick fix and hope we can

[jira] [Commented] (FLINK-10872) Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

[ https://issues.apache.org/jira/browse/FLINK-10872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689607#comment-16689607 ] ASF GitHub Bot commented on FLINK-10872: asfgit closed pull request #7100: [FLINK-10872] Extend

[GitHub] asfgit closed pull request #7100: [FLINK-10872] Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

asfgit closed pull request #7100: [FLINK-10872] Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11 URL: https://github.com/apache/flink/pull/7100 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689665#comment-16689665 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on issue #7108: [FLINK-10455][Kafka

[GitHub] pnowojski commented on issue #7108: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

pnowojski commented on issue #7108: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/7108#issuecomment-439457861 Thanks @azagrebin merged This

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689664#comment-16689664 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on issue #7107: [FLINK-10455][Kafka

[GitHub] tillrohrmann commented on a change in pull request #7129: [FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation

tillrohrmann commented on a change in pull request #7129: [FLINK-10880] Exclude JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation URL: https://github.com/apache/flink/pull/7129#discussion_r234281426 ## File path:

[jira] [Reopened] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values

[ https://issues.apache.org/jira/browse/FLINK-10907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10907: -- The issue may affect the legacy mode in 1.5/1.6 . > Job recovery on the same JobManager

[jira] [Commented] (FLINK-10869) Update S3 testing settings

[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689517#comment-16689517 ] ASF GitHub Bot commented on FLINK-10869: zentol commented on a change in pull request #7098:

[GitHub] zentol commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

zentol commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#discussion_r234231999 ## File path: flink-end-to-end-tests/test-scripts/common_s3.sh

[GitHub] zentol commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

zentol commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#discussion_r234230495 ## File path:

[jira] [Commented] (FLINK-10869) Update S3 testing settings

[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689528#comment-16689528 ] ASF GitHub Bot commented on FLINK-10869: StephanEwen commented on a change in pull request

[jira] [Commented] (FLINK-10906) docker-entrypoint.sh logs credentails during startup

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

[GitHub] tillrohrmann opened a new pull request #7125: [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

tillrohrmann opened a new pull request #7125: [FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7125 ## What is the purpose of the change In order to not leak secrets we should not print the configuration in

[jira] [Closed] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

[ https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10900. -- Resolution: Fixed merged commit 1680132 into apache:master commits 146f4340ed..d02af7eda3

[jira] [Resolved] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10843. -- Resolution: Fixed Fix Version/s: 1.7.0 Fixed in master:

[jira] [Resolved] (FLINK-10872) Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

[ https://issues.apache.org/jira/browse/FLINK-10872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10872. -- Resolution: Fixed Fix Version/s: 1.7.0 Fixed in master:

[GitHub] pnowojski closed pull request #7108: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

pnowojski closed pull request #7108: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/7108 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

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

[jira] [Closed] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10455. -- Resolution: Fixed Fix Version/s: 1.6.3 1.5.6 merged commit e493d83

[jira] [Commented] (FLINK-10880) Failover strategies should not be applied to Batch Execution

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

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

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

[jira] [Reopened] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-10455: > Potential Kafka producer leak in case of failures >

[GitHub] pnowojski commented on issue #7107: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

pnowojski commented on issue #7107: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/7107#issuecomment-439457778 Thanks @azagrebin, merged

[GitHub] pnowojski closed pull request #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

pnowojski closed pull request #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101 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] [Commented] (FLINK-10891) Upgrade Kafka client version to 2.0.1

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

[GitHub] pnowojski commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1

pnowojski commented on issue #7101: [FLINK-10891] Upgrade Kafka client version to 2.0.1 URL: https://github.com/apache/flink/pull/7101#issuecomment-439462934 I'm merging it, thanks again for the contribution @yanghua. Regarding the issues, I'm always looking on apache JIRA for

[jira] [Commented] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689722#comment-16689722 ] Stephan Ewen commented on FLINK-10904: -- Anywhere in the Flink processes (TaskManager) where any

[GitHub] twalthr commented on issue #3880: [FLINK-6457] [table] Clean up ScalarFunction and TableFunction interface

twalthr commented on issue #3880: [FLINK-6457] [table] Clean up ScalarFunction and TableFunction interface URL: https://github.com/apache/flink/pull/3880#issuecomment-439417094 I also agree with @fhueske. I will close this PR for now. The affected classes might be ported to Java soon

[GitHub] twalthr closed pull request #3880: [FLINK-6457] [table] Clean up ScalarFunction and TableFunction interface

twalthr closed pull request #3880: [FLINK-6457] [table] Clean up ScalarFunction and TableFunction interface URL: https://github.com/apache/flink/pull/3880 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

[jira] [Commented] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print

[ https://issues.apache.org/jira/browse/FLINK-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689512#comment-16689512 ] Fabian Hueske commented on FLINK-10889: --- Hmm, OK. I see. This (or a similar) behavior would in

[jira] [Commented] (FLINK-10869) Update S3 testing settings

[ https://issues.apache.org/jira/browse/FLINK-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689525#comment-16689525 ] ASF GitHub Bot commented on FLINK-10869: StephanEwen commented on a change in pull request

[GitHub] StephanEwen commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

StephanEwen commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#discussion_r234235828 ## File path: flink-end-to-end-tests/test-scripts/common_s3.sh

[jira] [Commented] (FLINK-10903) Shade Internal Akka Dependencies

[ https://issues.apache.org/jira/browse/FLINK-10903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689718#comment-16689718 ] Stephan Ewen commented on FLINK-10903: -- Are you referring specifically to the akka dependency, or

[jira] [Commented] (FLINK-10880) Failover strategies should not be applied to Batch Execution

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

[jira] [Commented] (FLINK-6036) Let catalog support partition

[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689489#comment-16689489 ] ASF GitHub Bot commented on FLINK-6036: --- twalthr closed pull request #3569: [FLINK-6036] [table]

[GitHub] StephanEwen commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables.

StephanEwen commented on a change in pull request #7098: [FLINK-10869] [build] Update S3 tests to reference new access key environment variables. URL: https://github.com/apache/flink/pull/7098#discussion_r234236294 ## File path:

[GitHub] pnowojski commented on a change in pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta

pnowojski commented on a change in pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta URL: https://github.com/apache/flink/pull/7109#discussion_r234248328 ## File path: docs/dev/connectors/kafka.md ## @@ -110,13 +123,17 @@ Note that the

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

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

[GitHub] pnowojski commented on a change in pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta

pnowojski commented on a change in pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta URL: https://github.com/apache/flink/pull/7109#discussion_r234248328 ## File path: docs/dev/connectors/kafka.md ## @@ -110,13 +123,17 @@ Note that the

[GitHub] pnowojski commented on a change in pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta

pnowojski commented on a change in pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta URL: https://github.com/apache/flink/pull/7109#discussion_r234248328 ## File path: docs/dev/connectors/kafka.md ## @@ -110,13 +123,17 @@ Note that the

[GitHub] pnowojski closed pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta

pnowojski closed pull request #7109: [FLINK-10900][kafka][docs] Mark universal Kafka connector as beta URL: https://github.com/apache/flink/pull/7109 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

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

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

[jira] [Updated] (FLINK-10906) docker-entrypoint.sh logs credentails during startup

[ https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10906: --- Labels: pull-request-available (was: ) > docker-entrypoint.sh logs credentails during

[GitHub] tillrohrmann opened a new pull request #7127: [BP-1.6][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh

tillrohrmann opened a new pull request #7127: [BP-1.6][FLINK-10906][docker] Don't print configuration in docker-entrypoint.sh URL: https://github.com/apache/flink/pull/7127 Backport of #7125 to `release-1.6`. This is an

  1   2   >