[GitHub] [flink] flinkbot edited a comment on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-916768949 ## CI report: * 6fba18288bfbfb1f83a6ec568be35ef749c974bc Azure:

[GitHub] [flink] flinkbot commented on pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

2021-10-07 Thread GitBox
flinkbot commented on pull request #17423: URL: https://github.com/apache/flink/pull/17423#issuecomment-937528000 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] flinkbot edited a comment on pull request #17422: [FLINK-9432][table] Enable EXTRACT for DECADE, ISODOW, ISOYEAR

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17422: URL: https://github.com/apache/flink/pull/17422#issuecomment-937776577 ## CI report: * cb2bcd6ec000f84f73bfa38fb5c00ec33b9030de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17417: FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured.

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17417: URL: https://github.com/apache/flink/pull/17417#issuecomment-935782208 -- 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

[GitHub] [flink] AHeise commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-937485519 -- 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

[GitHub] [flink] flinkbot commented on pull request #17425: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

2021-10-07 Thread GitBox
flinkbot commented on pull request #17425: URL: https://github.com/apache/flink/pull/17425#issuecomment-937642490 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] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-929172201 -- 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

[GitHub] [flink] dannycranmer commented on pull request #17417: FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured.

2021-10-07 Thread GitBox
dannycranmer commented on pull request #17417: URL: https://github.com/apache/flink/pull/17417#issuecomment-937674900 @rudikershaw thanks for the contribution, can you also update the `cn` documentation? It is still in English but eventually someone will translate it:

[GitHub] [flink] twalthr closed pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-07 Thread GitBox
twalthr closed pull request #17350: URL: https://github.com/apache/flink/pull/17350 -- 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] mans2singh commented on pull request #17408: [FLINK-24442][table][docs] - Corrected markup to show back ticks

2021-10-07 Thread GitBox
mans2singh commented on pull request #17408: URL: https://github.com/apache/flink/pull/17408#issuecomment-938235770 @leonardBang @wuchong - Can you please review this PR ? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-24477) Add MongoDB sink

2021-10-07 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-24477: -- Summary: Add MongoDB sink Key: FLINK-24477 URL: https://issues.apache.org/jira/browse/FLINK-24477 Project: Flink Issue Type: New Feature Components:

[GitHub] [flink-benchmarks] dawidwys commented on a change in pull request #34: [hotfix] Increase warmup iterations and iterations in CheckpointingTimeBenchmark

2021-10-07 Thread GitBox
dawidwys commented on a change in pull request #34: URL: https://github.com/apache/flink-benchmarks/pull/34#discussion_r724221931 ## File path: src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java ## @@ -65,37 +61,20 @@ import

[GitHub] [flink] flinkbot commented on pull request #17424: [FLINK-24455][tests]FallbackAkkaRpcSystemLoader should check for mave…

2021-10-07 Thread GitBox
flinkbot commented on pull request #17424: URL: https://github.com/apache/flink/pull/17424#issuecomment-937547733 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] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 0a0cd972b9e8406a06ead5f7e9c8fd161340a625 Azure:

[GitHub] [flink] flinkbot commented on pull request #17426: [FLINK-24167][Runtime]Add default HeartbeatReceiver and HeartbeatSend…

2021-10-07 Thread GitBox
flinkbot commented on pull request #17426: URL: https://github.com/apache/flink/pull/17426#issuecomment-937651834 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-shaded] XComp commented on a change in pull request #100: [FLINK-24447][zk] Bundle netty

2021-10-07 Thread GitBox
XComp commented on a change in pull request #100: URL: https://github.com/apache/flink-shaded/pull/100#discussion_r724055043 ## File path: flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35/src/main/resources/META-INF/NOTICE ## @@ -7,6 +7,14 @@ The Apache Software

[GitHub] [flink] tillrohrmann commented on pull request #17262: [FLINK-24273][kubernetes] Relocate io.fabric8 dependency.

2021-10-07 Thread GitBox
tillrohrmann commented on pull request #17262: URL: https://github.com/apache/flink/pull/17262#issuecomment-937919332 -- 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

[GitHub] [flink] AHeise merged pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise merged pull request #17358: URL: https://github.com/apache/flink/pull/17358 -- 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] hililiwei commented on a change in pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-07 Thread GitBox
hililiwei commented on a change in pull request #17106: URL: https://github.com/apache/flink/pull/17106#discussion_r723857343 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java ## @@ -74,6

[GitHub] [flink] flinkbot commented on pull request #17429: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.14.x

2021-10-07 Thread GitBox
flinkbot commented on pull request #17429: URL: https://github.com/apache/flink/pull/17429#issuecomment-937884401 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] flinkbot commented on pull request #17427: [FLINK-24472][tests] Wait for cancellation future to complete

2021-10-07 Thread GitBox
flinkbot commented on pull request #17427: URL: https://github.com/apache/flink/pull/17427#issuecomment-937723783 -- 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

[GitHub] [flink-statefun] sjwiesman commented on pull request #273: [FLINK-24464][core] Metrics sometimes report negative backlog

2021-10-07 Thread GitBox
sjwiesman commented on pull request #273: URL: https://github.com/apache/flink-statefun/pull/273#issuecomment-937327204 I'll fix the header while merging, grazi! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #17428: [hotfix]Refactor the registerJobManager to registerJobMaster

2021-10-07 Thread GitBox
flinkbot commented on pull request #17428: URL: https://github.com/apache/flink/pull/17428#issuecomment-937842619 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] twalthr closed pull request #17418: [FLINK-24421][table-runtime] Fix conversion of strings to TIME

2021-10-07 Thread GitBox
twalthr closed pull request #17418: URL: https://github.com/apache/flink/pull/17418 -- 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] tillrohrmann commented on a change in pull request #17414: [FLINK-24451][HA]Replace the scattered objects with encapsulated LeaderIn…

2021-10-07 Thread GitBox
tillrohrmann commented on a change in pull request #17414: URL: https://github.com/apache/flink/pull/17414#discussion_r724319224 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java ## @@ -263,13 +257,11 @@ public

[GitHub] [flink] flinkbot commented on pull request #17432: [BP-1.14][FLINK-24437][HA]Remove unhandled exception handler from CuratorFramework before closing it

2021-10-07 Thread GitBox
flinkbot commented on pull request #17432: URL: https://github.com/apache/flink/pull/17432#issuecomment-937928876 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-shaded] zentol commented on a change in pull request #100: [FLINK-24447][zk] Bundle netty

2021-10-07 Thread GitBox
zentol commented on a change in pull request #100: URL: https://github.com/apache/flink-shaded/pull/100#discussion_r724110204 ## File path: flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35/src/main/resources/META-INF/NOTICE ## @@ -7,6 +7,14 @@ The Apache Software

[GitHub] [flink] alpreu commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-07 Thread GitBox
alpreu commented on a change in pull request #17374: URL: https://github.com/apache/flink/pull/17374#discussion_r724221489 ## File path:

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #273: [FLINK-24464][core] Metrics sometimes report negative backlog

2021-10-07 Thread GitBox
igalshilman commented on a change in pull request #273: URL: https://github.com/apache/flink-statefun/pull/273#discussion_r723750424 ## File path: statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/metrics/NonNegativeCounterTest.java ## @@

[GitHub] [flink] snuyanzin closed pull request #6614: [FLINK-9432] [table] Support extract timeunit: DECADE, EPOCH, ISODOW, ISOYEAR…

2021-10-07 Thread GitBox
snuyanzin closed pull request #6614: URL: https://github.com/apache/flink/pull/6614 -- 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] AHeise merged pull request #17420: [BP-1.14][FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat…

2021-10-07 Thread GitBox
AHeise merged pull request #17420: URL: https://github.com/apache/flink/pull/17420 -- 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] slinkydeveloper commented on pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

2021-10-07 Thread GitBox
slinkydeveloper commented on pull request #17423: URL: https://github.com/apache/flink/pull/17423#issuecomment-937820171 @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

[GitHub] [flink] flinkbot commented on pull request #17431: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.12.x

2021-10-07 Thread GitBox
flinkbot commented on pull request #17431: URL: https://github.com/apache/flink/pull/17431#issuecomment-937896727 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] dannycranmer merged pull request #17417: FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured.

2021-10-07 Thread GitBox
dannycranmer merged pull request #17417: URL: https://github.com/apache/flink/pull/17417 -- 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] snuyanzin commented on pull request #6614: [FLINK-9432] [table] Support extract timeunit: DECADE, EPOCH, ISODOW, ISOYEAR…

2021-10-07 Thread GitBox
snuyanzin commented on pull request #6614: URL: https://github.com/apache/flink/pull/6614#issuecomment-937270898 I will close this PR and create a new one as there are from one side to many merge conflicts and from another calcite was updated to 1.2x since the time the PR was created.

[GitHub] [flink] fapaul commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-07 Thread GitBox
fapaul commented on a change in pull request #17374: URL: https://github.com/apache/flink/pull/17374#discussion_r723896941 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java

[GitHub] [flink] tisonkun closed pull request #16763: [hotfix][state_processor_api][union_state][doc] Updated variable name to match method invocation

2021-10-07 Thread GitBox
tisonkun closed pull request #16763: URL: https://github.com/apache/flink/pull/16763 -- 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] AHeise commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

2021-10-07 Thread GitBox
AHeise commented on pull request #17401: URL: https://github.com/apache/flink/pull/17401#issuecomment-937502238 @PatrickRen could you PTAL? I think we should have a test case for record lag metric as well. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dawidwys commented on a change in pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

2021-10-07 Thread GitBox
dawidwys commented on a change in pull request #17253: URL: https://github.com/apache/flink/pull/17253#discussion_r723934098 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java ## @@ -324,16 +324,19 @@ public

[GitHub] [flink] flinkbot commented on pull request #17422: [FLINK-9432] Enable EXTRACT for DECADE, ISODOW, ISOYEAR

2021-10-07 Thread GitBox
flinkbot commented on pull request #17422: URL: https://github.com/apache/flink/pull/17422#issuecomment-937329360 -- 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

[GitHub] [flink] AHeise merged pull request #17421: [FLINK-24405][tests] Introduce util to reliably drain all messages from a kafka topic

2021-10-07 Thread GitBox
AHeise merged pull request #17421: URL: https://github.com/apache/flink/pull/17421 -- 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] [Created] (FLINK-24478) gradle quickstart is out-of-date

2021-10-07 Thread David Anderson (Jira)
David Anderson created FLINK-24478: -- Summary: gradle quickstart is out-of-date Key: FLINK-24478 URL: https://issues.apache.org/jira/browse/FLINK-24478 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17253: URL: https://github.com/apache/flink/pull/17253#issuecomment-917975072 -- 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

[GitHub] [flink] pnowojski merged pull request #17425: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

2021-10-07 Thread GitBox
pnowojski merged pull request #17425: URL: https://github.com/apache/flink/pull/17425 -- 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-shaded] zentol merged pull request #100: [FLINK-24447][zk] Bundle netty

2021-10-07 Thread GitBox
zentol merged pull request #100: URL: https://github.com/apache/flink-shaded/pull/100 -- 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] snuyanzin commented on pull request #17422: [FLINK-9432][table] Enable EXTRACT for DECADE, ISODOW, ISOYEAR

2021-10-07 Thread GitBox
snuyanzin commented on pull request #17422: URL: https://github.com/apache/flink/pull/17422#issuecomment-937735175 yes, sure, just added -- 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

[GitHub] [flink] AHeise merged pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on the unified sink (FLIP-143)

2021-10-07 Thread GitBox
AHeise merged pull request #17363: URL: https://github.com/apache/flink/pull/17363 -- 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-statefun] sjwiesman closed pull request #273: [FLINK-24464][core] Metrics sometimes report negative backlog

2021-10-07 Thread GitBox
sjwiesman closed pull request #273: URL: https://github.com/apache/flink-statefun/pull/273 -- 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 #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 -- 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

[GitHub] [flink] twalthr commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-07 Thread GitBox
twalthr commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r724214646 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java ## @@ -331,7 +338,7 @@ private

[GitHub] [flink] flinkbot commented on pull request #17430: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.13.x

2021-10-07 Thread GitBox
flinkbot commented on pull request #17430: URL: https://github.com/apache/flink/pull/17430#issuecomment-937889110 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] StephanEwen commented on pull request #17425: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

2021-10-07 Thread GitBox
StephanEwen commented on pull request #17425: URL: https://github.com/apache/flink/pull/17425#issuecomment-937676627 +1 to merge -- 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] AHeise commented on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2021-10-07 Thread GitBox
AHeise commented on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-937503443 @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] tisonkun closed pull request #16790: [hotfix][connector][serialization][docs] Fix some typos in readme.md , kafka.md , schema_evolution.md docs

2021-10-07 Thread GitBox
tisonkun closed pull request #16790: URL: https://github.com/apache/flink/pull/16790 -- 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 #17427: [FLINK-24472][tests] Wait for cancellation future to complete

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17427: URL: https://github.com/apache/flink/pull/17427#issuecomment-937776797 ## CI report: * 1741d035b576d508032d7e963376238ffaeef39b Azure:

[GitHub] [flink] Aitozi commented on pull request #17410: [FLINK-24445][build] Copy rpc-akka jar in package phase

2021-10-07 Thread GitBox
Aitozi commented on pull request #17410: URL: https://github.com/apache/flink/pull/17410#issuecomment-937564663 Hi @zentol, I still have some doubts that after changing to the `package` phase , the `mvn clean test` will fail when executing in `flink-rpc-akka-loader` folder. Because the

[GitHub] [flink] zentol merged pull request #17427: [FLINK-24472][tests] Wait for cancellation future to complete

2021-10-07 Thread GitBox
zentol merged pull request #17427: URL: https://github.com/apache/flink/pull/17427 -- 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] [Commented] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExec

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425894#comment-17425894 ] shengkui leng commented on FLINK-24408: --- [^sql.txt]   I built it with this code: 

[jira] [Closed] (FLINK-24442) Flink Queries Docs markup does not show escape ticks

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24442. --- Fix Version/s: 1.15.0 Assignee: Mans Singh Resolution: Fixed Fixed in - master:

[GitHub] [flink] jjiey closed pull request #15902: [FLINK-19028][docs] Translate the "application_parameters.md" into Chinese

2021-10-07 Thread GitBox
jjiey closed pull request #15902: URL: https://github.com/apache/flink/pull/15902 -- 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] xintongsong commented on a change in pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

2021-10-07 Thread GitBox
xintongsong commented on a change in pull request #16821: URL: https://github.com/apache/flink/pull/16821#discussion_r724660924 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java ## @@ -127,9 +149,13 @@

[jira] [Updated] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecVa

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengkui leng updated FLINK-24408: -- Attachment: sql.txt > org.codehaus.janino.InternalCompilerException: Compiling >

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-10-07 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425908#comment-17425908 ] liwei li commented on FLINK-24351: -- [~monster#12], Sorry, I don't have permission. Maybe we can ask

[jira] [Updated] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecVa

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengkui leng updated FLINK-24408: -- Attachment: HudiBenchS3.java > org.codehaus.janino.InternalCompilerException: Compiling >

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 edited a comment on pull request #15: URL: https://github.com/apache/flink-ml/pull/15#issuecomment-938323217 I have rebased this PR on [Flink-10][iteration](https://github.com/apache/flink-ml/pull/17) and the new PR is [here](https://github.com/apache/flink-ml/pull/18). So

[GitHub] [flink-ml] zhipeng93 commented on pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 commented on pull request #15: URL: https://github.com/apache/flink-ml/pull/15#issuecomment-938323217 I have rebased this PR on [Flink-10][iteration](https://github.com/apache/flink-ml/pull/17) and the new PR is [here](https://github.com/apache/flink-ml/pull/18) -- This is an

[GitHub] [flink] dianfu opened a new pull request #17433: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5

2021-10-07 Thread GitBox
dianfu opened a new pull request #17433: URL: https://github.com/apache/flink/pull/17433 ## What is the purpose of the change *This pull request limits the grpcio version <= 1.40.0 for Python 3.5 as the latest grpcio (1.41.0 which was released in 9.28) has dropped the support for

[jira] [Updated] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24390: --- Labels: pull-request-available (was: ) > Python 'build_wheels mac' fails on azure >

[jira] [Commented] (FLINK-23271) RuntimeException: while resolving method 'booleanValue' in class class java.math.BigDecimal

2021-10-07 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425946#comment-17425946 ] xuyangzhong commented on FLINK-23271: - Hi , [~matriv]. The result of the discussion in calcite is

[jira] [Comment Edited] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "Strea

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425894#comment-17425894 ] shengkui leng edited comment on FLINK-24408 at 10/8/21, 1:08 AM: - The

[GitHub] [flink] jjiey commented on pull request #15902: [FLINK-19028][docs] Translate the "application_parameters.md" into Chinese

2021-10-07 Thread GitBox
jjiey commented on pull request #15902: URL: https://github.com/apache/flink/pull/15902#issuecomment-938295045 Already translated and merged on 3 Sep. see [pr 16949](https://github.com/apache/flink/pull/16949) -- This is an automated message from the Apache Git Service. To respond to

[jira] [Assigned] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24351: --- Assignee: ZhuoYu Chen > translate "JSON Function" pages into Chinese >

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425921#comment-17425921 ] Dian Fu commented on FLINK-24390: - It should be caused that the latest grpcio (1.41.0 which was released

[GitHub] [flink] flinkbot commented on pull request #17433: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5

2021-10-07 Thread GitBox
flinkbot commented on pull request #17433: URL: https://github.com/apache/flink/pull/17433#issuecomment-938293481 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] zhuzhurk commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-10-07 Thread GitBox
zhuzhurk commented on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-938299821 @tillrohrmann I have an idea already and will do it this week. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

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

2021-10-07 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Roc Marshal commented on FLINK-10230: - Could someone help me to merge it if there are nothing

[GitHub] [flink-ml] zhipeng93 opened a new pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 opened a new pull request #18: URL: https://github.com/apache/flink-ml/pull/18 This PR supports withBroadcast() function in DataStream by caching the broadcastInputs in static variables. Note that this PR is rebased on

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-10-07 Thread GitBox
xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-938283249 @galenwarren Great to hear from you. It would be nice to see this in the next release. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wuchong merged pull request #17408: [FLINK-24442][table][docs] - Corrected markup to show back ticks

2021-10-07 Thread GitBox
wuchong merged pull request #17408: URL: https://github.com/apache/flink/pull/17408 -- 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] [Assigned] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-24390: --- Assignee: Dian Fu > Python 'build_wheels mac' fails on azure >

[jira] [Assigned] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2021-10-07 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-24334: - Assignee: ouyangwulin > Configuration kubernetes.flink.log.dir not working >

[jira] [Commented] (FLINK-24474) Standalone clusters should bind to localhost by default

2021-10-07 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425931#comment-17425931 ] Yang Wang commented on FLINK-24474: --- What will happen if the standalone cluster is started across

[jira] [Commented] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2021-10-07 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425930#comment-17425930 ] Yang Wang commented on FLINK-24334: --- [~ouyangwuli] I think your suggestion makes sense and I have

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

2021-10-07 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425936#comment-17425936 ] Roc Marshal commented on FLINK-15352: - Could someone help me to merge it if there are nothing

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 edited a comment on pull request #15: URL: https://github.com/apache/flink-ml/pull/15#issuecomment-938323217 I have rebased this PR on [Flink-10, iteration](https://github.com/apache/flink-ml/pull/17) and the new PR is [here](https://github.com/apache/flink-ml/pull/18). So

[GitHub] [flink-ml] zhipeng93 closed pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 closed pull request #15: URL: https://github.com/apache/flink-ml/pull/15 -- 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] [Created] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24465: Summary: Wrong javadoc and documentation for buffer timeout Key: FLINK-24465 URL: https://issues.apache.org/jira/browse/FLINK-24465 Project: Flink

[jira] [Created] (FLINK-24466) Interval Join late events handling behaviour is not consistent

2021-10-07 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24466: --- Summary: Interval Join late events handling behaviour is not consistent Key: FLINK-24466 URL: https://issues.apache.org/jira/browse/FLINK-24466

[GitHub] [flink] AHeise merged pull request #17421: [FLINK-24405][tests] Introduce util to reliably drain all messages from a kafka topic

2021-10-07 Thread GitBox
AHeise merged pull request #17421: URL: https://github.com/apache/flink/pull/17421 -- 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] dawidwys commented on a change in pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

2021-10-07 Thread GitBox
dawidwys commented on a change in pull request #17253: URL: https://github.com/apache/flink/pull/17253#discussion_r723934098 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java ## @@ -324,16 +324,19 @@ public

[jira] [Updated] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24465: - Description: The javadoc for {{setBufferTimeout}} and similarly the documentation for

[jira] [Assigned] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors

2021-10-07 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-24409: Assignee: Qingsheng Ren (was: Alexander Preuss) > Kafka topics with periods in

[jira] [Updated] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

2021-10-07 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24405: Affects Version/s: 1.14.0 > KafkaWriterITCase.testLingeringTransaction fails on azure >

[jira] [Updated] (FLINK-24455) FallbackAkkaRpcSystemLoader should check for maven errors

2021-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24455: --- Labels: pull-request-available (was: ) > FallbackAkkaRpcSystemLoader should check for

[jira] [Comment Edited] (FLINK-24455) FallbackAkkaRpcSystemLoader should check for maven errors

2021-10-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425399#comment-17425399 ] Aitozi edited comment on FLINK-24455 at 10/7/21, 8:13 AM: -- I have created the

[GitHub] [flink] AHeise merged pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise merged pull request #17358: URL: https://github.com/apache/flink/pull/17358 -- 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] AHeise commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-937485519 Thanks. I'm merging. -- 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] AHeise commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-937497529 Also merged into release-1.14. -- 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

[GitHub] [flink] AHeise commented on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2021-10-07 Thread GitBox
AHeise commented on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-937503443 @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] AHeise merged pull request #17420: [BP-1.14][FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat…

2021-10-07 Thread GitBox
AHeise merged pull request #17420: URL: https://github.com/apache/flink/pull/17420 -- 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:

  1   2   3   >