[GitHub] [flink] flinkbot edited a comment on pull request #13434: [FLINK-19292][hive] HiveCatalog should support specifying Hadoop conf dir with configuration

flinkbot edited a comment on pull request #13434: URL: https://github.com/apache/flink/pull/13434#issuecomment-695893232 ## CI report: * b79b3d92803dc7478830ac866e68936d1d372f58 Azure:

[jira] [Commented] (FLINK-19409) The comment for getValue has wrong code in class ListView

[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202519#comment-17202519 ] Liu commented on FLINK-19409: - [~jark] I would like to fix it. Can you assign this ticket to me? Thanks. >

[GitHub] [flink] flinkbot edited a comment on pull request #13485: [hotfix][typos] Improve exception message of item operator

flinkbot edited a comment on pull request #13485: URL: https://github.com/apache/flink/pull/13485#issuecomment-699194102 ## CI report: * 8c088e989deb3d783868642c82c73c1fdd413ab8 Azure:

[jira] [Created] (FLINK-19422) Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002"

Dian Fu created FLINK-19422: --- Summary: Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002" Key: FLINK-19422 URL:

[jira] [Updated] (FLINK-19422) Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002"

[ https://issues.apache.org/jira/browse/FLINK-19422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19422: Component/s: Tests > Avro Confluent Schema Registry nightly end-to-end test failed with "Register >

[jira] [Updated] (FLINK-19422) Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002"

[ https://issues.apache.org/jira/browse/FLINK-19422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19422: Labels: test-stability (was: ) > Avro Confluent Schema Registry nightly end-to-end test failed with

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202484#comment-17202484 ] Dian Fu commented on FLINK-19388: -

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202482#comment-17202482 ] Dian Fu commented on FLINK-19388: -

[jira] [Closed] (FLINK-19421) Support Python UDAF in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19421. --- Resolution: Fixed master: ba520e90731e2c924664cf5b8fc1f99c2ba76d78 > Support Python UDAF in streaming mode

[jira] [Updated] (FLINK-19421) Support Python UDAF in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-19421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19421: --- Labels: pull-request-available (was: ) > Support Python UDAF in streaming mode >

[GitHub] [flink] dianfu closed pull request #13462: [FLINK-19421][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

dianfu closed pull request #13462: URL: https://github.com/apache/flink/pull/13462 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] dianfu edited a comment on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

dianfu edited a comment on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-698914901 @WeiZhong94 It seems you have shared the same JIRA between two Pull Requests. I have created a separate JIRA for this issue: FLINK-19421

[jira] [Created] (FLINK-19421) Support Python UDAF in streaming mode

Dian Fu created FLINK-19421: --- Summary: Support Python UDAF in streaming mode Key: FLINK-19421 URL: https://issues.apache.org/jira/browse/FLINK-19421 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-19229) Introduce the PythonStreamGroupAggregateOperator for Python UDAF

[ https://issues.apache.org/jira/browse/FLINK-19229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19229: Summary: Introduce the PythonStreamGroupAggregateOperator for Python UDAF (was: Support ValueState and

[GitHub] [flink] flinkbot edited a comment on pull request #13485: [hotfix][typos] Improve exception message of item operator

flinkbot edited a comment on pull request #13485: URL: https://github.com/apache/flink/pull/13485#issuecomment-699194102 ## CI report: * 8c088e989deb3d783868642c82c73c1fdd413ab8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 859b19e0af50e8188addfa7ce42179b25c806c80 Azure:

[GitHub] [flink] flinkbot commented on pull request #13485: [hotfix][typos] Improve exception message of item operator

flinkbot commented on pull request #13485: URL: https://github.com/apache/flink/pull/13485#issuecomment-699194102 ## CI report: * 8c088e989deb3d783868642c82c73c1fdd413ab8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19379) Submitting job to running YARN session fails

[ https://issues.apache.org/jira/browse/FLINK-19379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202446#comment-17202446 ] Kostas Kloudas commented on FLINK-19379: Sorry for being late in the discussion. I agree with

[GitHub] [flink] flinkbot commented on pull request #13485: [hotfix][typos] Improve exception message of item operator

flinkbot commented on pull request #13485: URL: https://github.com/apache/flink/pull/13485#issuecomment-699189501 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] wangxlong opened a new pull request #13485: [hotfix][typos] Improve exception of item operator

wangxlong opened a new pull request #13485: URL: https://github.com/apache/flink/pull/13485 ## What is the purpose of the change Improve exception of item operator when not supporting. ## Brief change log change exception message from 'Expect an array or a map' to

[GitHub] [flink] kl0u commented on pull request #13353: [FLINK-17104] Support registering custom JobStatusListeners from config

kl0u commented on pull request #13353: URL: https://github.com/apache/flink/pull/13353#issuecomment-699168042 @EchoLee5 Thanks for the PR. I left a comment at the JIRA. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-17104) Support registering custom JobStatusListeners from config

[ https://issues.apache.org/jira/browse/FLINK-17104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202434#comment-17202434 ] Kostas Kloudas commented on FLINK-17104: Hi [~felixzheng], I would just like to point you to

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * c86880fdde55700b120aa62eb463f3b6977546f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 4a598b96aa0250255f8758ce4ce57df23072dac7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13351: [FLINK-18990][task] Read channel state sequentially

flinkbot edited a comment on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-688741492 ## CI report: * 4a598b96aa0250255f8758ce4ce57df23072dac7 Azure:

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202371#comment-17202371 ] Kenzyme Le commented on FLINK-15578: Hi [~roman_khachatryan] , I was wondering if there was any

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 ## CI report: * 0e3916e68d38b432ebc33248d3a1ce7f7213b1f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 76fd1dd425f5889049cfb269f67778d04ae7dc2b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 76fd1dd425f5889049cfb269f67778d04ae7dc2b Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202337#comment-17202337 ] Antti Kaikkonen commented on FLINK-17493: - I started noticing the same memory leak after

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 76fd1dd425f5889049cfb269f67778d04ae7dc2b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13484: [FLINK-19419][Connectors][HBase] "null-string-literal" does not work in HBaseSource decoder

flinkbot edited a comment on pull request #13484: URL: https://github.com/apache/flink/pull/13484#issuecomment-698934692 ## CI report: * 163753486bb991b2bd670f91e5e213791644f3af Azure:

[jira] [Closed] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17479. -- Resolution: Abandoned > Occasional checkpoint failure due to null pointer exception in Flink

[jira] [Updated] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17470: --- Component/s: (was: Runtime / Task) Runtime / Coordination > Flink task

[GitHub] [flink] flinkbot edited a comment on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

flinkbot edited a comment on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-697272556 ## CI report: * de30de5e091feb6a9fe731ceff575ea2242f5ba9 Azure:

[jira] [Closed] (FLINK-17413) Refactor the usages of ThreadSafeUnaligner#storeNewBuffers

[ https://issues.apache.org/jira/browse/FLINK-17413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17413. -- Resolution: Duplicate > Refactor the usages of ThreadSafeUnaligner#storeNewBuffers >

[jira] [Updated] (FLINK-17341) freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-17341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17341: --- Component/s: (was: Runtime / Task) Runtime / Coordination > freeSlot

[jira] [Closed] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17315. -- Resolution: Fixed >

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495115239 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateSerializerImplTest.java ## @@ -36,7 +36,6 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495115053 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ChannelPersistenceITCase.java ## @@ -76,17 +67,17 @@ public void

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495114636 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RecoveredInputChannel.java ## @@ -77,13 +78,18 @@

[jira] [Closed] (FLINK-17157) TaskMailboxProcessorTest.testIdleTime failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17157. -- Resolution: Cannot Reproduce Closing for now, {{testIdleTime}} might have been fixed via

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495112681 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImplTest.java ## @@ -0,0 +1,321

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202288#comment-17202288 ] Piotr Nowojski commented on FLINK-16850: [~yunta], would you like to complete this ticket, now

[GitHub] [flink] flinkbot edited a comment on pull request #13483: [FLINK-19403][python] Support Pandas Stream Group Window Aggregation

flinkbot edited a comment on pull request #13483: URL: https://github.com/apache/flink/pull/13483#issuecomment-698904241 ## CI report: * c89615b7eb8f36e5e8966ad6f0098aa4757b5206 Azure:

[jira] [Updated] (FLINK-16789) Retrieve JMXRMI information via REST API or WebUI

[ https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16789: --- Component/s: (was: Runtime / Task) > Retrieve JMXRMI information via REST API or WebUI

[jira] [Closed] (FLINK-16728) Taskmanager dies after job got stuck and canceling fails

[ https://issues.apache.org/jira/browse/FLINK-16728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16728. -- Resolution: Not A Bug As [~zhuzh] suggested, this is probably an issue that some operator was

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495107404 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImplTest.java ## @@ -0,0 +1,321

[jira] [Closed] (FLINK-16368) ZooKeeperHighAvailabilityITCase test fail

[ https://issues.apache.org/jira/browse/FLINK-16368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16368. -- Resolution: Cannot Reproduce I will close it for now, as it wasn't reported for quite some

[GitHub] [flink] flinkbot edited a comment on pull request #13481: [FLINK-19395][sql] Replace SqlConversionException with either TableException or ValidationException

flinkbot edited a comment on pull request #13481: URL: https://github.com/apache/flink/pull/13481#issuecomment-698895442 ## CI report: * fdba66defaa6c4092feffe3e361e56886193c80e Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495101122 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java ## @@ -0,0 +1,162 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 2891af0eed55092a0710ae425990408a8564963b Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495098945 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateChunkReaderTest.java ## @@ -0,0 +1,162 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495095577 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[jira] [Commented] (FLINK-19344) DispatcherResourceCleanupTest#testJobSubmissionUnderSameJobId is unstable on Azure Pipeline

[ https://issues.apache.org/jira/browse/FLINK-19344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202269#comment-17202269 ] Piotr Nowojski commented on FLINK-19344: another instance:

[GitHub] [flink] flinkbot edited a comment on pull request #13480: [FLINK-19341][table] Update all API related methods to FLIP-107

flinkbot edited a comment on pull request #13480: URL: https://github.com/apache/flink/pull/13480#issuecomment-698886630 ## CI report: * 382e46040d85bbed2df63d12698a8475d890ec35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 2891af0eed55092a0710ae425990408a8564963b Azure:

[jira] [Comment Edited] (FLINK-19326) Allow explicitly configuring time behaviour on CEP PatternStream

[ https://issues.apache.org/jira/browse/FLINK-19326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202125#comment-17202125 ] Nicholas Jiang edited comment on FLINK-19326 at 9/25/20, 4:05 PM: --

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495088222 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495087939 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r495087415 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

rkhachatryan commented on a change in pull request #13040: URL: https://github.com/apache/flink/pull/13040#discussion_r495083202 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java ## @@ -283,6 +286,54 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13423: [FLINK-19269] Make the PushingAsyncDataInput.DataOutput aware of endOfInput

flinkbot edited a comment on pull request #13423: URL: https://github.com/apache/flink/pull/13423#issuecomment-694841940 ## CI report: * ef80141dd2339d94d2497c22b298474d5aee680f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 ## CI report: * 0e3916e68d38b432ebc33248d3a1ce7f7213b1f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 ## CI report: * 0e3916e68d38b432ebc33248d3a1ce7f7213b1f8 Azure:

[jira] [Closed] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19098. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master: ef4d997756756bf0e1e722af8a3fcd6995f37dc8 >

[jira] [Updated] (FLINK-19098) Make RowData CSV and JSON converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19098: Summary: Make RowData CSV and JSON converters public (was: Make Rowdata converters public) > Make

[GitHub] [flink] wuchong commented on pull request #13303: [FLINK-19098][format] Make row data converters public

wuchong commented on pull request #13303: URL: https://github.com/apache/flink/pull/13303#issuecomment-698973858 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] wuchong merged pull request #13303: [FLINK-19098][format] Make row data converters public

wuchong merged pull request #13303: URL: https://github.com/apache/flink/pull/13303 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

[jira] [Closed] (FLINK-19407) Translate "Elasticsearch Connector" page of "Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19407. --- Assignee: (was: weixubin) Resolution: Duplicate Sorry, I just find this is a duplicate issue. >

[jira] [Closed] (FLINK-19413) Translate "FileSystem" page of "Table & SQL Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19413. --- Resolution: Duplicate This is a duplicate issue. > Translate "FileSystem" page of "Table & SQL Connectors"

[jira] [Comment Edited] (FLINK-19419) "null-string-literal" does not work in HBaseSource decoder

[ https://issues.apache.org/jira/browse/FLINK-19419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202214#comment-17202214 ] Jark Wu edited comment on FLINK-19419 at 9/25/20, 2:47 PM: --- Sorry. I don't

[jira] [Commented] (FLINK-19419) "null-string-literal" does not work in HBaseSource decoder

[ https://issues.apache.org/jira/browse/FLINK-19419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202214#comment-17202214 ] Jark Wu commented on FLINK-19419: - Sorry. I don't think so. In the source side, the {{nullStringBytes}}

[GitHub] [flink] kezhuw commented on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

kezhuw commented on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-698972020 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-19409) The comment for getValue has wrong code in class ListView

[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202212#comment-17202212 ] Jark Wu commented on FLINK-19409: - +1 > The comment for getValue has wrong code in class ListView >

[jira] [Updated] (FLINK-19409) The comment for getValue has wrong code in class ListView

[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19409: Component/s: Table SQL / API > The comment for getValue has wrong code in class ListView >

[jira] [Assigned] (FLINK-19420) Translate "Program Packaging" page of "Managing Execution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19420: --- Assignee: Jark Wu > Translate "Program Packaging" page of "Managing Execution" into Chinese >

[jira] [Updated] (FLINK-19420) Translate "Program Packaging" page of "Managing Execution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19420: Component/s: Documentation > Translate "Program Packaging" page of "Managing Execution" into Chinese >

[jira] [Assigned] (FLINK-19420) Translate "Program Packaging" page of "Managing Execution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19420: --- Assignee: (was: Jark Wu) > Translate "Program Packaging" page of "Managing Execution" into

[jira] [Created] (FLINK-19420) Translate "Program Packaging" page of "Managing Execution" into Chinese

Xiao Huang created FLINK-19420: -- Summary: Translate "Program Packaging" page of "Managing Execution" into Chinese Key: FLINK-19420 URL: https://issues.apache.org/jira/browse/FLINK-19420 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

flinkbot edited a comment on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-697272556 ## CI report: * f7b3ffb121b22f9792fefab2ab681e5e05b65dd4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13484: [FLINK-19419][Connectors][HBase] "null-string-literal" does not work in HBaseSource decoder

flinkbot edited a comment on pull request #13484: URL: https://github.com/apache/flink/pull/13484#issuecomment-698934692 ## CI report: * 163753486bb991b2bd670f91e5e213791644f3af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13423: [FLINK-19269] Make the PushingAsyncDataInput.DataOutput aware of endOfInput

flinkbot edited a comment on pull request #13423: URL: https://github.com/apache/flink/pull/13423#issuecomment-694841940 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Closed] (FLINK-19411) MultipleInputStreamTask fails with RuntimeException when its input contains union

[ https://issues.apache.org/jira/browse/FLINK-19411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-19411. -- Resolution: Fixed Merged to master as 7bfd8ec1e3 > MultipleInputStreamTask fails with

[GitHub] [flink] pnowojski commented on pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

pnowojski commented on pull request #13466: URL: https://github.com/apache/flink/pull/13466#issuecomment-698940593 Thanks for the review @rkhachatryan . Merging. This is an automated message from the Apache Git Service. To

[GitHub] [flink] pnowojski merged pull request #13478: [FLINK-19411][task] Fix construction of MultipleInputStreamTask with union inputs

pnowojski merged pull request #13478: URL: https://github.com/apache/flink/pull/13478 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

[GitHub] [flink] flinkbot commented on pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

flinkbot commented on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698822482 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] pnowojski commented on pull request #13465: [FLINK-18906][task] Support checkpointing with multiple input operator chained with sources

pnowojski commented on pull request #13465: URL: https://github.com/apache/flink/pull/13465#issuecomment-698796760 Thanks for the review. Private azure build is green, merging. This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #13478: [FLINK-19411][task] Fix construction of MultipleInputStreamTask with union inputs

flinkbot edited a comment on pull request #13478: URL: https://github.com/apache/flink/pull/13478#issuecomment-698809939 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-statefun-docker] tzulitai closed pull request #9: [release] Add Dockerfiles for 2.2.0 release

tzulitai closed pull request #9: URL: https://github.com/apache/flink-statefun-docker/pull/9 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

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * 4a09743987db91b50c41e4fa597767b5ea3fbc8b Azure:

[GitHub] [flink] pnowojski merged pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

pnowojski merged pull request #13466: URL: https://github.com/apache/flink/pull/13466 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

[jira] [Closed] (FLINK-18907) Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

[ https://issues.apache.org/jira/browse/FLINK-18907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18907. -- Resolution: Fixed Merged to master as d922f8655b..d38bd893bc > Add watermarks and metrics

[GitHub] [flink] aljoscha closed pull request #13471: [FLINK-19124][datastream] Some JobClient methods are not ergonomic, require ClassLoader argument

aljoscha closed pull request #13471: URL: https://github.com/apache/flink/pull/13471 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

[GitHub] [flink] rkhachatryan commented on a change in pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

rkhachatryan commented on a change in pull request #13466: URL: https://github.com/apache/flink/pull/13466#discussion_r494815993 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java ## @@ -68,7 +69,9 @@

[GitHub] [flink] aljoscha closed pull request #12754: [FLINK-5717][streaming] Fix NPE on SessionWindows with ContinuousProc…

aljoscha closed pull request #12754: URL: https://github.com/apache/flink/pull/12754 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

[GitHub] [flink] flinkbot edited a comment on pull request #13483: [FLINK-19403][python] Support Pandas Stream Group Window Aggregation

flinkbot edited a comment on pull request #13483: URL: https://github.com/apache/flink/pull/13483#issuecomment-698904241 ## CI report: * c89615b7eb8f36e5e8966ad6f0098aa4757b5206 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

pnowojski commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r494848434 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@ +/* +

[GitHub] [flink-statefun-docker] tzulitai commented on a change in pull request #10: [release] Add Dockerfiles for 2.2.0 release

tzulitai commented on a change in pull request #10: URL: https://github.com/apache/flink-statefun-docker/pull/10#discussion_r494808247 ## File path: 2.2.0-java11/Dockerfile ## @@ -0,0 +1,82 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +#

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r494813570 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -53,42 +53,48 @@ public

  1   2   3   4   5   >