[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718202041 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718219633 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java

[GitHub] [flink] flinkbot edited a comment on pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17370: URL: https://github.com/apache/flink/pull/17370#issuecomment-929030266 ## CI report: * 579496274548581d5e08f9597ebfb4644192f86a Azure:

[jira] [Updated] (FLINK-24387) Support a "to JSON" function

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-24387: -- Description: We should consider adding a JSON_STRING function which can simply convert some

[jira] [Commented] (FLINK-24387) Support a "to JSON" function

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421960#comment-17421960 ] Ingo Bürk commented on FLINK-24387: --- JSON_STRING sounds like a good fit to me. > Support a "to JSON"

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718203666 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchProcessor.java ##

[GitHub] [flink-ml] gaoyunhaii opened a new pull request #12: [FLINK-6][iteration] add unbounded iteration.

2021-09-29 Thread GitBox
gaoyunhaii opened a new pull request #12: URL: https://github.com/apache/flink-ml/pull/12 This PR implements the unbounded iteration construction method. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[jira] [Closed] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest?

2021-09-29 Thread jacky jia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jacky jia closed FLINK-24400. - Resolution: Won't Do for elasticsearch batch skd only support insert\delete\upsert ,so it can not

[jira] [Commented] (FLINK-24270) Rewrite tests for illegal job modification against VertexFinishedStateChecker

2021-09-29 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421975#comment-17421975 ] Dawid Wysakowicz commented on FLINK-24270: -- The tests that need to be rewritten are in

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718222862 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchProcessor.java ##

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718222090 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718201189 ## File path: flink-connectors/flink-connector-elasticsearch7/pom.xml ## @@ -92,6 +92,12 @@ under the License. test

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718224708 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-927544424 ## CI report: * 70568032b21299c96c12505b8e7a413370318ae6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17365: [hotfix][web]Modify the configuration of prettier

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17365: URL: https://github.com/apache/flink/pull/17365#issuecomment-928705859 ## CI report: * c877606f26e4de8ad5e6b62a05dcbf88eed6807a Azure:

[jira] [Updated] (FLINK-24387) Support a JSON_STRING function

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-24387: -- Summary: Support a JSON_STRING function (was: Support a "to JSON" function) > Support a JSON_STRING

[jira] [Assigned] (FLINK-24387) Support a JSON_STRING function

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-24387: - Assignee: Ingo Bürk > Support a JSON_STRING function > -- > >

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718199624 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java

[GitHub] [flink] ljdavns commented on pull request #17325: [FLINK-24337] fix WEB UI build failure on windows

2021-09-29 Thread GitBox
ljdavns commented on pull request #17325: URL: https://github.com/apache/flink/pull/17325#issuecomment-929887095 > The PR title / commit message seem to reference the wrong JIRA issue? Sry, it's [FLINK-24337] -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-22243: -- Affects Version/s: 1.14.0 > Reactive Mode parallelism changes are not shown in the job graph

[jira] [Updated] (FLINK-24337) WEB UI build failure in Flink 1.15-SNAPSHOT current code

2021-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24337: --- Labels: pull-request-available (was: ) > WEB UI build failure in Flink 1.15-SNAPSHOT

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718202530 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java ## @@

[GitHub] [flink] ljdavns edited a comment on pull request #17325: [FLINK-24337] fix WEB UI build failure on windows

2021-09-29 Thread GitBox
ljdavns edited a comment on pull request #17325: URL: https://github.com/apache/flink/pull/17325#issuecomment-929887095 > The PR title / commit message seem to reference the wrong JIRA issue? Sry, it's [FLINK-24337] -- This is an automated message from the Apache Git Service.

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718221569 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/BulkProcessorConfig.java ## @@

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718220854 ## File path: flink-connectors/flink-connector-elasticsearch7/pom.xml ## @@ -92,6 +92,12 @@ under the License. test

[jira] [Commented] (FLINK-24399) Make handling of DataType less verbose

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421962#comment-17421962 ] Ingo Bürk commented on FLINK-24399: --- I couldn't think of a name I really prefer to

[jira] [Comment Edited] (FLINK-24399) Make handling of DataType less verbose

2021-09-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421962#comment-17421962 ] Ingo Bürk edited comment on FLINK-24399 at 9/29/21, 6:39 AM: - I couldn't

[GitHub] [flink] flinkbot edited a comment on pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17371: URL: https://github.com/apache/flink/pull/17371#issuecomment-929030407 ## CI report: * 1f761e65aa4c3ce202641a88d2c579f9db8b3567 Azure:

[jira] [Updated] (FLINK-6) [GitHub] Fix the delimited record format double/decimal parsers.

2021-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6: --- Labels: github-import pull-request-available (was: github-import) > [GitHub] Fix the delimited record

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718206431 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchProcessor.java ##

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718223674 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchProcessor.java ##

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718239254 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718238615 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java

[jira] [Updated] (FLINK-18405) Add watermark support for unaligned checkpoints

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18405: --- Priority: Not a Priority (was: Minor) > Add watermark support for unaligned checkpoints >

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718240545 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java ## @@

[GitHub] [flink] wangyang0918 merged pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed

2021-09-29 Thread GitBox
wangyang0918 merged pull request #17361: URL: https://github.com/apache/flink/pull/17361 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat)

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23451: --- Fix Version/s: (was: 1.15.0) 1.14.0 > FLIP-183: Dynamic buffer size

[jira] [Closed] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat)

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23451. -- Resolution: Fixed > FLIP-183: Dynamic buffer size adjustment (Buffer debloat) >

[jira] [Closed] (FLINK-23928) Test the buffer debloating

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23928. -- Fix Version/s: (was: 1.15.0) 1.14.0 Resolution: Fixed > Test

[jira] [Closed] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22562. -- Resolution: Fixed > Translate recent updates to backpressure and checkpointing docs >

[jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14920: --- Fix Version/s: (was: 1.15.0) > Set up environment to run performance e2e tests >

[jira] [Updated] (FLINK-13698) Rework threading model of CheckpointCoordinator

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13698: --- Fix Version/s: (was: 1.15.0) > Rework threading model of CheckpointCoordinator >

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14971: --- Fix Version/s: (was: 1.15.0) > Make all the non-IO operations in CheckpointCoordinator

[jira] [Closed] (FLINK-23273) Implement basic authentication handler

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-23273. - > Implement basic authentication handler > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[jira] [Updated] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22562: --- Fix Version/s: (was: 1.14.1) (was: 1.15.0)

[GitHub] [flink] flinkbot commented on pull request #17380: [hotfix][docs] Fix typo in sources doc

2021-09-29 Thread GitBox
flinkbot commented on pull request #17380: URL: https://github.com/apache/flink/pull/17380#issuecomment-929965247 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] Airblader commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

2021-09-29 Thread GitBox
Airblader commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r718326427 ## File path:

[jira] [Comment Edited] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

2021-09-29 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419055#comment-17419055 ] Roc Marshal edited comment on FLINK-15352 at 9/29/21, 9:36 AM: --- Hi,

[GitHub] [flink] flinkbot edited a comment on pull request #17380: [hotfix][docs] Fix typo in sources doc

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17380: URL: https://github.com/apache/flink/pull/17380#issuecomment-929996988 ## CI report: * 6ae4697e929283ee170ec125bff276ddbd0c2690 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 2ef3f7299009cb78d02fa495d95520168b6b44b1 Azure:

[jira] [Updated] (FLINK-24399) Make handling of DataType less verbose

2021-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24399: --- Labels: pull-request-available (was: ) > Make handling of DataType less verbose >

[GitHub] [flink] slinkydeveloper opened a new pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

2021-09-29 Thread GitBox
slinkydeveloper opened a new pull request #17381: URL: https://github.com/apache/flink/pull/17381 Signed-off-by: slinkydeveloper ## What is the purpose of the change Simplify the handling of `DataType` for connector developers ## Brief change log -

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718235473 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSink.java ## @@

[jira] [Updated] (FLINK-15922) Show "Warn - received late message for checkpoint" only when checkpoint actually expired

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15922: --- Labels: auto-deprioritized-major beginner beginner-friendly usability (was:

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * cf263d95d228b4ce6a65c887679d69fa33f1ba3a Azure:

[jira] [Resolved] (FLINK-23273) Implement basic authentication handler

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-23273. --- Resolution: Information Provided > Implement basic authentication handler >

[jira] [Commented] (FLINK-23273) Implement basic authentication handler

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421987#comment-17421987 ] Gabor Somogyi commented on FLINK-23273: --- It took some time on the legal side but now it's public

[GitHub] [flink] wangyang0918 merged pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

2021-09-29 Thread GitBox
wangyang0918 merged pull request #17371: URL: https://github.com/apache/flink/pull/17371 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Resolved] (FLINK-23272) FLIP-181: Custom netty HTTP request inbound/outbound handlers

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-23272. --- Fix Version/s: 1.14.0 Resolution: Fixed > FLIP-181: Custom netty HTTP request

[jira] [Closed] (FLINK-23272) FLIP-181: Custom netty HTTP request inbound/outbound handlers

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-23272. - > FLIP-181: Custom netty HTTP request inbound/outbound handlers >

[GitHub] [flink] matriv commented on a change in pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json

2021-09-29 Thread GitBox
matriv commented on a change in pull request #17343: URL: https://github.com/apache/flink/pull/17343#discussion_r718258195 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -102,6 +102,12 @@ The file system connector supports multiple formats: -

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * cf263d95d228b4ce6a65c887679d69fa33f1ba3a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17343: URL: https://github.com/apache/flink/pull/17343#issuecomment-925923764 ## CI report: * 876f47e4fd5e7cac49373b0317cb796e6ced32ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 2ef3f7299009cb78d02fa495d95520168b6b44b1 Azure:

[GitHub] [flink] MartijnVisser commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

2021-09-29 Thread GitBox
MartijnVisser commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r718315208 ## File path: docs/content/docs/connectors/table/formats/avro-glue.md ## @@ -0,0 +1,191 @@ +--- +title: AWS Glue Avro +weight: 4 +type: docs

[GitHub] [flink] zentol commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-09-29 Thread GitBox
zentol commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-930032978 @MartijnVisser Of course, but I would like to have those ready when I close the ticket such that I can document them in JIRA. -- This is an automated message from the Apache

[GitHub] [flink] MartijnVisser commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-09-29 Thread GitBox
MartijnVisser commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-930040850 @zentol I've updated the release notes in https://issues.apache.org/jira/browse/FLINK-20845 -- This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22088: --- Fix Version/s: (was: 1.14.1) (was: 1.15.0) >

[GitHub] [flink] wangyang0918 merged pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed

2021-09-29 Thread GitBox
wangyang0918 merged pull request #17370: URL: https://github.com/apache/flink/pull/17370 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed

2021-09-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-24380. - Resolution: Fixed > Flink should handle the state transition of the pod from Pending to Failed >

[GitHub] [flink-ml] gaoyunhaii opened a new pull request #13: [FLINK-7][iteration] Add bounded all-round iteration

2021-09-29 Thread GitBox
gaoyunhaii opened a new pull request #13: URL: https://github.com/apache/flink-ml/pull/13 This PR adds the support of the bounded all-round iteration. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] flinkbot edited a comment on pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #17343: URL: https://github.com/apache/flink/pull/17343#issuecomment-925923764 ## CI report: * 876f47e4fd5e7cac49373b0317cb796e6ced32ae Azure:

[GitHub] [flink] jongillham opened a new pull request #17380: [hotfix][docs] Fix typo in sources doc

2021-09-29 Thread GitBox
jongillham opened a new pull request #17380: URL: https://github.com/apache/flink/pull/17380 ## What is the purpose of the change Fix typo in sources doc. ## Brief change log - *Fix typo in sources doc* ## Verifying this change This change is

[GitHub] [flink-docker] dawidwys merged pull request #93: Update Dockerfiles for 1.14.0 release

2021-09-29 Thread GitBox
dawidwys merged pull request #93: URL: https://github.com/apache/flink-docker/pull/93 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-docker] dawidwys merged pull request #92: Add GPG key for 1.14.0 release

2021-09-29 Thread GitBox
dawidwys merged pull request #92: URL: https://github.com/apache/flink-docker/pull/92 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718296315 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718296315 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java ## @@

[jira] [Commented] (FLINK-24399) Make handling of DataType less verbose

2021-09-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422032#comment-17422032 ] Timo Walther commented on FLINK-24399: -- Let's skip structured types in the first version for

[jira] [Commented] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-09-29 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422036#comment-17422036 ] Roc Marshal commented on FLINK-10230: - [~airblader] Thank you so much for your suggestions. I

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

2021-09-29 Thread GitBox
flinkbot commented on pull request #17381: URL: https://github.com/apache/flink/pull/17381#issuecomment-930043917 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] fapaul commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-29 Thread GitBox
fapaul commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r718234851 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchProcessor.java ##

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json

2021-09-29 Thread GitBox
slinkydeveloper commented on a change in pull request #17343: URL: https://github.com/apache/flink/pull/17343#discussion_r718233963 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -102,6 +102,12 @@ The file system connector supports multiple formats: -

[jira] [Closed] (FLINK-23274) Implement SPNEGO authentication handler

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-23274. - > Implement SPNEGO authentication handler > --- > >

[jira] [Resolved] (FLINK-23274) Implement SPNEGO authentication handler

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-23274. --- Resolution: Information Provided > Implement SPNEGO authentication handler >

[jira] [Commented] (FLINK-23274) Implement SPNEGO authentication handler

2021-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421989#comment-17421989 ] Gabor Somogyi commented on FLINK-23274: --- It took some time on the legal side but now it's public

[jira] [Commented] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed

2021-09-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421993#comment-17421993 ] Yang Wang commented on FLINK-24380: --- Fixed via: master(1.15): 

[GitHub] [flink-docker] dawidwys commented on pull request #92: Add GPG key for 1.14.0 release

2021-09-29 Thread GitBox
dawidwys commented on pull request #92: URL: https://github.com/apache/flink-docker/pull/92#issuecomment-929931539 Sorry for pushing to dev-14 directly, I did it by mistake. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

2021-09-29 Thread Alice Friry (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422005#comment-17422005 ] Alice Friry commented on FLINK-17493: - I think I have the same problem. I'm trying to run a batch

[jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner

2021-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7: --- Labels: pull-request-available (was: ) > [GitHub] Enable Range Partitioner >

[jira] [Commented] (FLINK-24399) Make handling of DataType less verbose

2021-09-29 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422027#comment-17422027 ] Francesco Guardiani commented on FLINK-24399: - Should {{DataType#projectFields}} support

[GitHub] [flink] flinkbot commented on pull request #17380: [hotfix][docs] Fix typo in sources doc

2021-09-29 Thread GitBox
flinkbot commented on pull request #17380: URL: https://github.com/apache/flink/pull/17380#issuecomment-929996988 ## CI report: * 6ae4697e929283ee170ec125bff276ddbd0c2690 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] MartijnVisser commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-09-29 Thread GitBox
MartijnVisser commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-930028688 @zentol My proposal would be to add migration remarks in the release notes, are you OK with that? -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-20845) Drop support for Scala 2.11

2021-09-29 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20845: --- Release Note: Support for Scala 2.11 has been removed. All Flink dependencies that

[GitHub] [flink] YuriGusev opened a new pull request #17382: Flink 16504 dynamodb connector backpressure

2021-09-29 Thread GitBox
YuriGusev opened a new pull request #17382: URL: https://github.com/apache/flink/pull/17382 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-09-29 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * 580c1364bba239bed8bc3c90710c2097f4275d04 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

2021-09-29 Thread GitBox
twalthr commented on a change in pull request #17381: URL: https://github.com/apache/flink/pull/17381#discussion_r718413128 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/DataTypes.java ## @@ -96,6 +97,15 @@ @PublicEvolving public

[jira] [Updated] (FLINK-20845) Drop support for Scala 2.11

2021-09-29 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20845: --- Release Note: Support for Scala 2.11 has been removed. All Flink dependencies that

  1   2   3   4   >