arpadboda commented on a change in pull request #840:
URL: https://github.com/apache/nifi-minifi-cpp/pull/840#discussion_r455522730
##
File path: libminifi/test/unit/TimeUtilTests.cpp
##
@@ -0,0 +1,87 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
arpadboda commented on a change in pull request #840:
URL: https://github.com/apache/nifi-minifi-cpp/pull/840#discussion_r455522730
##
File path: libminifi/test/unit/TimeUtilTests.cpp
##
@@ -0,0 +1,87 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
arpadboda closed pull request #836:
URL: https://github.com/apache/nifi-minifi-cpp/pull/836
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
esecules commented on pull request #4401:
URL: https://github.com/apache/nifi/pull/4401#issuecomment-659026103
This exception only gets thrown when you're pulling the flow from the
registry. It would be better if it blocked versioning it to the registry in the
first place.
[
https://issues.apache.org/jira/browse/NIFI-7645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Turcsanyi updated NIFI-7645:
--
Description:
Reimplement PublishAMQP / ConsumeAMQP processors
* support record oriented
[
https://issues.apache.org/jira/browse/NIFI-7645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Turcsanyi updated NIFI-7645:
--
Component/s: Extensions
> Implement AMQPRecord processors
> ---
>
>
[
https://issues.apache.org/jira/browse/NIFI-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158707#comment-17158707
]
Peter Turcsanyi commented on NIFI-6312:
---
Opened a PR ([https://github.com/apache/nifi/pull/4411])
[
https://issues.apache.org/jira/browse/NIFI-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Turcsanyi updated NIFI-6312:
--
Status: Patch Available (was: Open)
> AMQP processors seem to have thread cleanup issues
>
turcsanyip opened a new pull request #4411:
URL: https://github.com/apache/nifi/pull/4411
Disable connection automatic recovery which can lead to uncontrolled/stale
threads. Handle the recovery in the processors instead.
Use poisoning in case of errors, then discarding and recreating
[
https://issues.apache.org/jira/browse/NIFI-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Turcsanyi reassigned NIFI-6312:
-
Assignee: Peter Turcsanyi
> AMQP processors seem to have thread cleanup issues
>
Peter Turcsanyi created NIFI-7645:
-
Summary: Implement AMQPRecord processors
Key: NIFI-7645
URL: https://issues.apache.org/jira/browse/NIFI-7645
Project: Apache NiFi
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/NIFI-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158700#comment-17158700
]
Bryan Bende commented on NIFI-7628:
---
You can also have read/write policies on parameter contexts, in
Ihar Hulevich created NIFI-7644:
---
Summary: New Relic reporting task
Key: NIFI-7644
URL: https://issues.apache.org/jira/browse/NIFI-7644
Project: Apache NiFi
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/NIFI-7643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tamás Bunth updated NIFI-7643:
--
Description:
Steps to reproduce:
# Create a tar or zip file with some arbitrary content in its root.
Tamás Bunth created NIFI-7643:
-
Summary: Unpackcontent writing absolute path property does not
make sense
Key: NIFI-7643
URL: https://issues.apache.org/jira/browse/NIFI-7643
Project: Apache NiFi
arpadboda commented on pull request #836:
URL: https://github.com/apache/nifi-minifi-cpp/pull/836#issuecomment-658855469
@fgerlits :
The stringutils part seems to fail on gcc:
https://travis-ci.org/github/apache/nifi-minifi-cpp/jobs/708347373
arpadboda commented on pull request #821:
URL: https://github.com/apache/nifi-minifi-cpp/pull/821#issuecomment-658816200
@hunyadi-dev : could you rebase and push?
The changes look good to me, but I would like to see it build on Win without
errors.
goosalex opened a new pull request #4410:
URL: https://github.com/apache/nifi/pull/4410
Thank you for submitting a contribution to Apache NiFi.
Please provide a short description of the PR here:
Description of PR
Improves receiving large batches of Kafka messages
fgerlits opened a new pull request #840:
URL: https://github.com/apache/nifi-minifi-cpp/pull/840
See https://issues.apache.org/jira/browse/MINIFICPP-1293 for the description
of the bug.
Description of the change: instead of using `mktime` and adjusting by the
time zone offset, use
goosalex closed pull request #4409:
URL: https://github.com/apache/nifi/pull/4409
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
arpadboda commented on a change in pull request #833:
URL: https://github.com/apache/nifi-minifi-cpp/pull/833#discussion_r455083609
##
File path: libminifi/src/core/ProcessGroup.cpp
##
@@ -412,6 +414,18 @@ void ProcessGroup::drainConnections() {
}
}
+std::size_t
arpadboda commented on a change in pull request #833:
URL: https://github.com/apache/nifi-minifi-cpp/pull/833#discussion_r455083106
##
File path: libminifi/test/flow-tests/FlowControllerTests.cpp
##
@@ -119,7 +107,125 @@ TEST_CASE("Flow shutdown drains connections",
goosalex opened a new pull request #4409:
URL: https://github.com/apache/nifi/pull/4409
Thank you for submitting a contribution to Apache NiFi.
Please provide a short description of the PR here:
Description of PR
Improves receiving large batches of Kafka messages
[
https://issues.apache.org/jira/browse/NIFI-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard updated NIFI-7628:
-
Component/s: SDLC
Flow Versioning
> Parameter context in multi tenant
[
https://issues.apache.org/jira/browse/NIFI-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158178#comment-17158178
]
Pierre Villard commented on NIFI-7628:
--
Not sure to understand the request here. A parameter context
[
https://issues.apache.org/jira/browse/NIFI-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard updated NIFI-7628:
-
Issue Type: Improvement (was: Bug)
> Parameter context in multi tenant environment
>
arpadboda closed pull request #838:
URL: https://github.com/apache/nifi-minifi-cpp/pull/838
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
[
https://issues.apache.org/jira/browse/NIFIREG-344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bryan Bende updated NIFIREG-344:
Fix Version/s: (was: 0.7.0)
> ClientUtils reads "Content-Disposition" before checking status
[
https://issues.apache.org/jira/browse/NIFIREG-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bryan Bende updated NIFIREG-292:
Fix Version/s: (was: 0.7.0)
> Add database implementations of UserGroupProvider and
[
https://issues.apache.org/jira/browse/NIFIREG-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bryan Bende resolved NIFIREG-321.
-
Resolution: Fixed
> Integrate nifi-registry-revsion into REST API and service layers
>
Bryan Bende created NIFIREG-404:
---
Summary: Perform release manager activities for 0.7.0 release
Key: NIFIREG-404
URL: https://issues.apache.org/jira/browse/NIFIREG-404
Project: NiFi Registry
[
https://issues.apache.org/jira/browse/NIFIREG-381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bryan Bende resolved NIFIREG-381.
-
Resolution: Fixed
> Skip integration tests in Github CI/Actions
>
[
https://issues.apache.org/jira/browse/NIFI-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Goos updated NIFI-7642:
Summary: KafkaConsumers: Improve batching into fewer FlowFiles under high
latency conditions (was:
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r455004287
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -540,111 +481,97 @@ void ProcessSession::import(const std::string& source,
Adam Debreceni created MINIFICPP-1294:
-
Summary: Move stream ref counting to the ResourceClaim class
Key: MINIFICPP-1294
URL: https://issues.apache.org/jira/browse/MINIFICPP-1294
Project: Apache
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r455004287
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -540,111 +481,97 @@ void ProcessSession::import(const std::string& source,
[
https://issues.apache.org/jira/browse/NIFI-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Goos updated NIFI-7642:
Labels: kafka (was: )
> KafkaConsumers: Improve batching into fewer FlowFiles under high latency
>
Alex Goos created NIFI-7642:
---
Summary: KafkaConsumers: Improve batching into fewer FlowFiles
under high latency conditios
Key: NIFI-7642
URL: https://issues.apache.org/jira/browse/NIFI-7642
Project: Apache
Pierre Villard created NIFI-7641:
Summary: NullPointerException with ExecuteFlumeSource
Key: NIFI-7641
URL: https://issues.apache.org/jira/browse/NIFI-7641
Project: Apache NiFi
Issue Type:
Pierre Villard created NIFI-7640:
Summary: HandleHttpRequest - define temporary files location
Key: NIFI-7640
URL: https://issues.apache.org/jira/browse/NIFI-7640
Project: Apache NiFi
Issue
KuKuDeCheng commented on pull request #4326:
URL: https://github.com/apache/nifi/pull/4326#issuecomment-658667516
> I'm not change about github checks error.
> I run this check successful on my compute.
You need update DatabaseRecordSinkTest.java. Add your ExecuteSQL property
[
https://issues.apache.org/jira/browse/NIFI-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Gyori updated NIFI-7635:
--
Resolution: Fixed
Status: Resolved (was: Patch Available)
> Fix StandardConfigurationContext
pgyori commented on pull request #4408:
URL: https://github.com/apache/nifi/pull/4408#issuecomment-658628455
Thank you, @markap14 !
This is an automated message from the Apache Git Service.
To respond to the message, please
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454874069
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -540,111 +481,97 @@ void ProcessSession::import(const std::string& source,
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454874069
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -540,111 +481,97 @@ void ProcessSession::import(const std::string& source,
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454871893
##
File path: extensions/rocksdb-repos/FlowFileRepository.cpp
##
@@ -148,22 +148,27 @@ void FlowFileRepository::prune_stored_flowfiles() {
[
https://issues.apache.org/jira/browse/NIFI-6061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157981#comment-17157981
]
ZhangCheng commented on NIFI-6061:
--
For Oracle TIMESTAMP field, when PutDatabaseRecord tries to insert it
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454824460
##
File path: libminifi/include/core/Repository.h
##
@@ -228,6 +232,8 @@ class Repository : public virtual
core::SerializableComponent,
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454842291
##
File path: libminifi/include/core/FlowFile.h
##
@@ -35,9 +35,56 @@ namespace minifi {
namespace core {
class FlowFile : public
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454839615
##
File path: libminifi/test/persistence-tests/PersistenceTests.cpp
##
@@ -0,0 +1,218 @@
+/**
+ *
+ * Licensed to the Apache Software
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454836324
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -540,111 +481,97 @@ void ProcessSession::import(const std::string& source,
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454834083
##
File path: libminifi/src/FlowFileRecord.cpp
##
@@ -118,28 +110,27 @@ FlowFileRecord::~FlowFileRecord() {
logger_->log_debug("Delete
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454833537
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -248,35 +237,27 @@ void ProcessSession::penalize(const
std::shared_ptr ) {
void
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454833537
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -248,35 +237,27 @@ void ProcessSession::penalize(const
std::shared_ptr ) {
void
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454833537
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -248,35 +237,27 @@ void ProcessSession::penalize(const
std::shared_ptr ) {
void
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454833537
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -248,35 +237,27 @@ void ProcessSession::penalize(const
std::shared_ptr ) {
void
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454831606
##
File path: libminifi/src/core/ProcessSession.cpp
##
@@ -211,15 +206,6 @@ std::shared_ptr
ProcessSession::clone(const std::shared_ptr ) {
adamdebreceni commented on a change in pull request #807:
URL: https://github.com/apache/nifi-minifi-cpp/pull/807#discussion_r454824460
##
File path: libminifi/include/core/Repository.h
##
@@ -228,6 +232,8 @@ class Repository : public virtual
core::SerializableComponent,
58 matches
Mail list logo