[jira] [Updated] (FLINK-25041) E2E tar ball cache fails without error message if target directory not specified

2021-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25041: --- Labels: pull-request-available (was: ) > E2E tar ball cache fails without error message if

[GitHub] [flink] autophagy opened a new pull request #17896: [FLINK-25041][e2e] Improve error handling for missing environment variables in E2E tests

2021-11-24 Thread GitBox
autophagy opened a new pull request #17896: URL: https://github.com/apache/flink/pull/17896 ## What is the purpose of the change There are several points where the E2E tests check that an environment variable is nonempty before proceeding with the tests, such as the

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * ea0743d3a975253991d11e65195d45c656c5ccdc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17870: [FLINK-24596][kafka] Fix buffered KafkaUpsert sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17870: URL: https://github.com/apache/flink/pull/17870#issuecomment-975609035 ## CI report: * 01d64c49b39abde51cc5ca9d82b509d0555b79e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17870: [FLINK-24596][kafka] Fix buffered KafkaUpsert sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17870: URL: https://github.com/apache/flink/pull/17870#issuecomment-975609035 ## CI report: * 01d64c49b39abde51cc5ca9d82b509d0555b79e6 Azure:

[GitHub] [flink] fapaul commented on pull request #17870: [FLINK-24596][kafka] Fix buffered KafkaUpsert sink

2021-11-24 Thread GitBox
fapaul commented on pull request #17870: URL: https://github.com/apache/flink/pull/17870#issuecomment-977954695 @AHeise I addressed all your comments PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #17870: [FLINK-24596][kafka] Fix buffered KafkaUpsert sink

2021-11-24 Thread GitBox
fapaul commented on a change in pull request #17870: URL: https://github.com/apache/flink/pull/17870#discussion_r756154531 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java ## @@ -43,19

[GitHub] [flink] Aitozi commented on a change in pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

2021-11-24 Thread GitBox
Aitozi commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r756152018 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,36 +244,51 @@ private String

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

2021-11-24 Thread GitBox
wuchong commented on a change in pull request #17842: URL: https://github.com/apache/flink/pull/17842#discussion_r756141514 ## File path: flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java ## @@ -54,16 +54,6 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] zentol commented on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
zentol commented on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977940153 may have to add some explicit test-jar executions; strange that this didn't fail in my fork... -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-15736) Support Java 17 (LTS)

2021-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15736: - Priority: Major (was: Minor) > Support Java 17 (LTS) > - > >

[jira] [Commented] (FLINK-24926) Key group is not in KeyGroupRange when joining two streams with table API

2021-11-24 Thread Hongbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448649#comment-17448649 ] Hongbo commented on FLINK-24926: [~yunta]  Yes, we can reproduce every time. And we've seen this error

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 25da71fb7f65f2fc7c7ec8c890fd11be446553f4 Azure:

[GitHub] [flink] jackwener commented on a change in pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

2021-11-24 Thread GitBox
jackwener commented on a change in pull request #17842: URL: https://github.com/apache/flink/pull/17842#discussion_r756124578 ## File path: flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java ## @@ -54,16 +54,6 @@ public void

[GitHub] [flink] Airblader commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
Airblader commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-977922702 No, this doesn't look correct. It looks like you either merged or rebased against the wrong branch. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * 1592494d4260563af4f170fb1cd45ccec9e5f0cb Azure:

[jira] [Resolved] (FLINK-24858) TypeSerializer version mismatch during eagerly restore

2021-11-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-24858. - Release Note: This ticket resolves an issue that during state migration between Flink versions

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * 1592494d4260563af4f170fb1cd45ccec9e5f0cb Azure:

[jira] [Commented] (FLINK-24858) TypeSerializer version mismatch during eagerly restore

2021-11-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448633#comment-17448633 ] Fabian Paul commented on FLINK-24858: - Fixed: * master 601ef3b3bce040264daa3aedcb9d98ead8303485 *

[GitHub] [flink] fapaul merged pull request #17850: [FLINK-24858][core] Prevent version mismatches in TypeSerializers

2021-11-24 Thread GitBox
fapaul merged pull request #17850: URL: https://github.com/apache/flink/pull/17850 -- 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-25042) Allow calls to @VisibleForTesting from inner classes

2021-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25042. Resolution: Fixed master: d8ad669a4748fe083ef73991b16471fd0ed09266 > Allow calls to

[jira] [Updated] (FLINK-25042) Allow calls to @VisibleForTesting from inner classes

2021-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25042: - Issue Type: Technical Debt (was: Improvement) > Allow calls to @VisibleForTesting from

[GitHub] [flink] fapaul merged pull request #17755: [FLINK-24858][core] Prevent version mismatches in TypeSerializers

2021-11-24 Thread GitBox
fapaul merged pull request #17755: URL: https://github.com/apache/flink/pull/17755 -- 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] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 8364104af21c6c012779149008980072b18cb87c Azure:

[GitHub] [flink] zentol merged pull request #17894: [FLINK-25042] Allow calls to @VisibleForTesting from inner classes

2021-11-24 Thread GitBox
zentol merged pull request #17894: URL: https://github.com/apache/flink/pull/17894 -- 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] zentol merged pull request #17866: [FLINK-24996][ci] Update CI image to contain Java 17

2021-11-24 Thread GitBox
zentol merged pull request #17866: URL: https://github.com/apache/flink/pull/17866 -- 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-24996) Update CI image to contain Java 17

2021-11-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24996. Resolution: Fixed master: b09e4ae3790ef087abcafb684e8327025698b6a9 > Update CI image to

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 8364104af21c6c012779149008980072b18cb87c Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

2021-11-24 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r756106396 ## File path:

[GitHub] [flink] MonsterChenzhuo commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
MonsterChenzhuo commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-977910029 @Airblader Do you think I'm doing the right thing with this current git operation? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] MartijnVisser commented on pull request #17881: [FLINK-24971][tests] Adding retry mechanism in case git clone fails

2021-11-24 Thread GitBox
MartijnVisser commented on pull request #17881: URL: https://github.com/apache/flink/pull/17881#issuecomment-977909632 Ran the test locally: ```FLINK_DIR=/Users/martijnvisser/Developer/flink/build-target /Users/martijnvisser/Developer/flink/flink-end-to-end-tests/run-single-test.sh

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

2021-11-24 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r756106396 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17851: URL: https://github.com/apache/flink/pull/17851#issuecomment-975348551 ## CI report: * 30a825e6731cc02e07749d5b9af42469e8284fce Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17701: [FLINK-24294][streaming] Register all stream task resources to one cl…

2021-11-24 Thread GitBox
dawidwys commented on a change in pull request #17701: URL: https://github.com/apache/flink/pull/17701#discussion_r756102896 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -366,70 +368,100 @@ protected

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-976661814 ## CI report: * ff803e470139bc8af3c0beb2d33b278427b70569 Azure:

[GitHub] [flink] flinkbot commented on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot commented on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899948 ## CI report: * b0c02de88a629c7e488c3d414ee2f9725e71c164 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-976661814 ## CI report: * ff803e470139bc8af3c0beb2d33b278427b70569 Azure:

[GitHub] [flink] flinkbot commented on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

2021-11-24 Thread GitBox
flinkbot commented on pull request #17895: URL: https://github.com/apache/flink/pull/17895#issuecomment-977899310 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] JingGe commented on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

2021-11-24 Thread GitBox
JingGe commented on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-977898153 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-25039) AZP fails with license check

2021-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25039: --- Labels: pull-request-available (was: ) > AZP fails with license check >

[GitHub] [flink] zentol opened a new pull request #17895: [FLINK-25039][build] Disable shading of test jar

2021-11-24 Thread GitBox
zentol opened a new pull request #17895: URL: https://github.com/apache/flink/pull/17895 In 3.2.2 a bug was fixed in the `shade-plugin` that resulted in it creating empty test jars if `shadeTestJar` was set to `true` and no prior `test-jar` was generated by the `maven-jar-plugin.` This

[jira] [Comment Edited] (FLINK-25012) Cannot join hive tables with different column types

2021-11-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448569#comment-17448569 ] luoyuxia edited comment on FLINK-25012 at 11/24/21, 1:48 PM: - [~xiangqiao] 

[GitHub] [flink] flinkbot edited a comment on pull request #17755: [FLINK-24858][core] Prevent version mismatches in TypeSerializers

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17755: URL: https://github.com/apache/flink/pull/17755#issuecomment-965205123 ## CI report: * df0a363ef1ee99ca849a493c77a5969169a7a32e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * c0e2fa6e27549bf2cfc8f4c973ec2ba8d37a6556 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * c0e2fa6e27549bf2cfc8f4c973ec2ba8d37a6556 UNKNOWN

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

2021-11-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448614#comment-17448614 ] Roman Khachatryan commented on FLINK-24611: --- Just to clarify, the recent discussion is about

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * c0e2fa6e27549bf2cfc8f4c973ec2ba8d37a6556 UNKNOWN

[GitHub] [flink] luoyuxia commented on a change in pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

2021-11-24 Thread GitBox
luoyuxia commented on a change in pull request #17761: URL: https://github.com/apache/flink/pull/17761#discussion_r756082118 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java ## @@ -641,7 +641,8 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * c0e2fa6e27549bf2cfc8f4c973ec2ba8d37a6556 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * c0e2fa6e27549bf2cfc8f4c973ec2ba8d37a6556 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[GitHub] [flink] Airblader commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
Airblader commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-977873019 > What do I need to do? Do I close the current pr and pull the master branch for a new commit? No need to close the PR, you can just rebase your branch. For example if

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * Unknown: [CANCELED](TBD) * c0e2fa6e27549bf2cfc8f4c973ec2ba8d37a6556 UNKNOWN

[GitHub] [flink] alpreu commented on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
alpreu commented on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-977870573 @flinkbot run azure -- 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

[GitHub] [flink] MonsterChenzhuo commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
MonsterChenzhuo commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-977870414 @slinkydeveloper @Airblader Thank you for your guidance, I will revise the content you pointed out in the next few days -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] MonsterChenzhuo commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
MonsterChenzhuo commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-977858457 @Airblader I looked at the Connector Testing Framwork today and wondered if there was any connection with flink-architecture-tests. -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #17871: [hotfix] Add assertj in dependency management and link the code quality guide in the PR template

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17871: URL: https://github.com/apache/flink/pull/17871#issuecomment-975731882 ## CI report: * 986abcb5198c7d772fef99a0b076bd4818517495 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] MonsterChenzhuo commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-11-24 Thread GitBox
MonsterChenzhuo commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-977856887 @Airblader What do I need to do? Do I close the current pr and pull the master branch for a new commit? What does flink-architecture-tests do? Can you give me a brief

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2021-11-24 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448591#comment-17448591 ] Zichen Liu commented on FLINK-24229: hey [~Gusev]  Hope you're well. Was wondering how the DynamoDB

[jira] [Updated] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

2021-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-24892: --- Description: Introduce a new scheduler to Flink: adaptive batch scheduler. The new scheduler can

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[jira] [Updated] (FLINK-25035) Shuffle Service Supports Consuming Subpartition Range

2021-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-25035: --- Description: In adaptive batch scheduler, the shuffle service needs to support a SingleInputGate to

[jira] [Updated] (FLINK-24980) Collect sizes of finished BLOCKING result partitions

2021-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-24980: --- Description: The adaptive batch scheduler needs to know the size of each result partition when the

[jira] [Updated] (FLINK-25031) Job finishes iff all job vertices finish

2021-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-25031: --- Description: The adaptive batch scheduler needs to build ExecutionGraph dynamically. For a dynamic

[jira] [Updated] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

2021-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-24892: --- Summary: FLIP-187: Adaptive Batch Scheduler (was: FLIP-187: Adaptive Batch Job Scheduler) >

[jira] [Created] (FLINK-25046) Convert forward edge to rescale when using adapive batch scheduler

2021-11-24 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-25046: -- Summary: Convert forward edge to rescale when using adapive batch scheduler Key: FLINK-25046 URL: https://issues.apache.org/jira/browse/FLINK-25046 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17893: [FLINK-24987][Configuration] Add explicit enum value NO_EXTERNAL_CHECKPOINTS as default for ExternalizedCheckpointRetention

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17893: URL: https://github.com/apache/flink/pull/17893#issuecomment-977732141 ## CI report: * a87ce21ece7603f461e387fcc8eff13bdf1fb41a Azure:

[jira] [Updated] (FLINK-25033) Let some scheduler components updatable

2021-11-24 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-25033: --- Summary: Let some scheduler components updatable (was: Let some scheduler components updatable.)

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[jira] [Created] (FLINK-25045) Introduce AdaptiveBatchScheduler

2021-11-24 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-25045: -- Summary: Introduce AdaptiveBatchScheduler Key: FLINK-25045 URL: https://issues.apache.org/jira/browse/FLINK-25045 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 07d1221acb25978fb79a84beed8e81122e40daca Azure:

[jira] [Created] (FLINK-25044) Add More Unit Test For Pulsar Source

2021-11-24 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-25044: --- Summary: Add More Unit Test For Pulsar Source Key: FLINK-25044 URL: https://issues.apache.org/jira/browse/FLINK-25044 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25044) Add More Unit Test For Pulsar Source

2021-11-24 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448579#comment-17448579 ] Yufei Zhang commented on FLINK-25044: - I am currently working on this issue, feel free to assign it

[GitHub] [flink] flinkbot edited a comment on pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17892: URL: https://github.com/apache/flink/pull/17892#issuecomment-977710431 ## CI report: * ef9bf98289409eafd1c3e49e9ae96317a4397a34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17871: [hotfix] Add assertj in dependency management and link the code quality guide in the PR template

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17871: URL: https://github.com/apache/flink/pull/17871#issuecomment-975731882 ## CI report: * 986abcb5198c7d772fef99a0b076bd4818517495 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-24 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r756004235 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/linear/HasPredictionDetailCol.java ## @@ -0,0 +1,39 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-24 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r756012363 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasL2.java ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-24 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r756011254 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasBatchSize.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #17871: [hotfix] Add assertj in dependency management and link the code quality guide in the PR template

2021-11-24 Thread GitBox
flinkbot edited a comment on pull request #17871: URL: https://github.com/apache/flink/pull/17871#issuecomment-975731882 ## CI report: * 986abcb5198c7d772fef99a0b076bd4818517495 Azure:

<    1   2   3   4   5   6   >